From bbbfb1a2eb26115ae95f9c3592b09eb03854e41a Mon Sep 17 00:00:00 2001 From: Aayush Shah Date: Thu, 28 Apr 2022 02:42:07 -0400 Subject: [PATCH] kvserver: fix bug in `baseQueue.AddAsync` Release note: None --- pkg/kv/kvserver/queue.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/kv/kvserver/queue.go b/pkg/kv/kvserver/queue.go index 24a4dc1ba7b4..1d44114a365e 100644 --- a/pkg/kv/kvserver/queue.go +++ b/pkg/kv/kvserver/queue.go @@ -601,7 +601,7 @@ func (bq *baseQueue) MaybeAddAsync( // for other operations to finish instead of turning into a noop (because // unlikely MaybeAdd, Add is not subject to being called opportunistically). func (bq *baseQueue) AddAsync(ctx context.Context, repl replicaInQueue, prio float64) { - bq.Async(ctx, "Add", false /* wait */, func(ctx context.Context, h queueHelper) { + bq.Async(ctx, "Add", true /* wait */, func(ctx context.Context, h queueHelper) { h.Add(ctx, repl, prio) }) }