mirror of https://github.com/milvus-io/milvus.git
[skip e2e] Improve annotation (#14799)
Signed-off-by: Xieql <qianglong.xie@zilliz.com>pull/14829/head
parent
77ae88fc37
commit
1e7c51859a
|
@ -578,7 +578,7 @@ func (scheduler *TaskScheduler) scheduleLoop() {
|
|||
log.Debug("scheduleLoop: num of child task", zap.Int("num child task", len(activateTasks)))
|
||||
for _, childTask := range activateTasks {
|
||||
if childTask != nil {
|
||||
log.Debug("scheduleLoop: add a activate task to activateChan", zap.Int64("taskID", childTask.getTaskID()))
|
||||
log.Debug("scheduleLoop: add an activate task to activateChan", zap.Int64("taskID", childTask.getTaskID()))
|
||||
scheduler.activateTaskChan <- childTask
|
||||
activeTaskWg.Add(1)
|
||||
go scheduler.waitActivateTaskDone(activeTaskWg, childTask, triggerTask)
|
||||
|
|
Loading…
Reference in New Issue