diff --git a/pkg/ratelimit/runner.go b/pkg/ratelimit/runner.go index a2bfe0f514b..661668af3b9 100644 --- a/pkg/ratelimit/runner.go +++ b/pkg/ratelimit/runner.go @@ -92,6 +92,7 @@ func (s *AsyncRunner) Start() { go s.run(task.Ctx, task.f, nil) } case <-s.stopChan: + log.Info("stopping async task runner", zap.String("name", s.name)) return } }