diff --git a/internal/querycoord/task_scheduler.go b/internal/querycoord/task_scheduler.go index fce81dd048..5a8f081557 100644 --- a/internal/querycoord/task_scheduler.go +++ b/internal/querycoord/task_scheduler.go @@ -120,6 +120,7 @@ func NewTaskQueue() *TaskQueue { } } +// TaskScheduler controls the scheduling of trigger tasks and internal tasks type TaskScheduler struct { triggerTaskQueue *TaskQueue activateTaskChan chan task