diff --git a/federationapi/routing/send.go b/federationapi/routing/send.go index dde07701..d5e44f72 100644 --- a/federationapi/routing/send.go +++ b/federationapi/routing/send.go @@ -358,6 +358,7 @@ func (t *inputWorker) run() { select { case <-task.ctx.Done(): task.err = context.DeadlineExceeded + pduCountTotal.WithLabelValues("expired").Inc() return default: evStart := time.Now()