diff --git a/pkg/storage/queue.go b/pkg/storage/queue.go index b0db5662ceba..3ef925cc0304 100644 --- a/pkg/storage/queue.go +++ b/pkg/storage/queue.go @@ -511,7 +511,7 @@ func (bq *baseQueue) Async( log.InfofDepth(ctx, 2, opName) } opName += " (" + bq.name + ")" - if err := bq.store.stopper.RunLimitedAsyncTask(ctx, opName, bq.addOrMaybeAddSem, wait, + if err := bq.store.stopper.RunLimitedAsyncTask(context.Background(), opName, bq.addOrMaybeAddSem, wait, func(ctx context.Context) { fn(ctx, baseQueueHelper{bq}) }); err != nil && bq.addLogN.ShouldLog() {