diff --git a/pkg/ratelimit/runner_test.go b/pkg/ratelimit/runner_test.go index 8a9eff77379..85f7d5b23c4 100644 --- a/pkg/ratelimit/runner_test.go +++ b/pkg/ratelimit/runner_test.go @@ -27,6 +27,7 @@ func TestAsyncRunner(t *testing.T) { t.Run("RunTask", func(t *testing.T) { limiter := NewConcurrencyLimiter(1) runner := NewAsyncRunner("test", time.Second) + runner.Start() defer runner.Stop() var wg sync.WaitGroup @@ -48,6 +49,7 @@ func TestAsyncRunner(t *testing.T) { t.Run("MaxPendingDuration", func(t *testing.T) { limiter := NewConcurrencyLimiter(1) runner := NewAsyncRunner("test", 2*time.Millisecond) + runner.Start() defer runner.Stop() var wg sync.WaitGroup for i := 0; i < 10; i++ {