Fix taskDispatcher add multiple tasks will ignore following ones (#27885)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2023-10-24 17:18:13 +08:00 · 2023-10-24 17:18:13 +08:00 · 323fc107a7
parent 9ba79a97e4
commit 323fc107a7
1 changed files with 1 additions and 1 deletions
--- a/internal/querycoordv2/observers/task_dispatcher.go
+++ b/internal/querycoordv2/observers/task_dispatcher.go
@ -70,7 +70,7 @@ func (d *taskDispatcher[K]) Stop() {
 func (d *taskDispatcher[K]) AddTask(keys ...K) {
 	var added bool
 	for _, key := range keys {
-		added = added || d.tasks.Insert(key)
+		added = d.tasks.Insert(key) || added
 	}
 	if added {
 		d.notify()