address comments

Signed-off-by: Ryan Leung <[email protected]>
tikv · May 14, 2024 · 09cc309 · 09cc309
1 parent a9eef12
commit 09cc309
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()