diff --git a/internal/querycoord/task_scheduler.go b/internal/querycoord/task_scheduler.go index 12a1ef3b5e..9cdddbabfe 100644 --- a/internal/querycoord/task_scheduler.go +++ b/internal/querycoord/task_scheduler.go @@ -791,6 +791,7 @@ func (scheduler *TaskScheduler) waitActivateTaskDone(wg *sync.WaitGroup, t task, } } +// processActivateTaskLoop process internal task, such as loadSegment, watchQUeryChannel, watDmChannel func (scheduler *TaskScheduler) processActivateTaskLoop() { defer scheduler.wg.Done() for {