From 103be36e904fd16848607173e3ca3d01ccaf5da4 Mon Sep 17 00:00:00 2001 From: Ryan Leung Date: Tue, 14 May 2024 15:35:45 +0800 Subject: [PATCH] address comments Signed-off-by: Ryan Leung --- pkg/ratelimit/runner.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/ratelimit/runner.go b/pkg/ratelimit/runner.go index a3f6a5e4a17f..0ce3a77df220 100644 --- a/pkg/ratelimit/runner.go +++ b/pkg/ratelimit/runner.go @@ -195,7 +195,7 @@ func (cr *ConcurrentRunner) RunTask(ctx context.Context, name string, f func(con for _, opt := range opts { opt(task) } - + cr.processPendingTasks() cr.pendingMu.Lock() defer func() { cr.pendingMu.Unlock()