diff --git a/internal/querycoord/task_scheduler.go b/internal/querycoord/task_scheduler.go index 28748eaf0f..d792649a3d 100644 --- a/internal/querycoord/task_scheduler.go +++ b/internal/querycoord/task_scheduler.go @@ -96,6 +96,7 @@ func (queue *TaskQueue) addTaskToFront(t task) { } } +// PopTask pops a trigger task from task list func (queue *TaskQueue) PopTask() task { queue.Lock() defer queue.Unlock()