From 152d7dfa92decde2883366707e76d3ddd0268e98 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Sat, 9 Oct 2021 19:54:16 +0800 Subject: [PATCH] [skip ci] Add comment for enqueue (#9593) Signed-off-by: xige-16 --- internal/querycoord/task_scheduler.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querycoord/task_scheduler.go b/internal/querycoord/task_scheduler.go index 5a8f081557..28748eaf0f 100644 --- a/internal/querycoord/task_scheduler.go +++ b/internal/querycoord/task_scheduler.go @@ -422,6 +422,7 @@ func (scheduler *TaskScheduler) unmarshalTask(t string) (task, error) { return newTask, nil } +// Enqueue pushs a trigger task to triggerTaskQueue and assigns task id func (scheduler *TaskScheduler) Enqueue(tasks []task) { for _, t := range tasks { id, err := scheduler.taskIDAllocator()