kvserver: fix bug in baseQueue.AddAsync

Release note: None
andreimatei · Apr 28, 2022 · bbbfb1a · bbbfb1a
1 parent 0782bef
commit bbbfb1a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 	})
 }