diff --git a/internal/datacoord/task_scheduler.go b/internal/datacoord/task_scheduler.go index 4089936dda..a31eb8a15e 100644 --- a/internal/datacoord/task_scheduler.go +++ b/internal/datacoord/task_scheduler.go @@ -243,8 +243,8 @@ func (s *taskScheduler) enqueue(task Task) { taskID := task.GetTaskID() _, ok := s.runningTasks.Get(taskID) if !ok { - s.pendingTasks.Push(task) task.SetQueueTime(time.Now()) + s.pendingTasks.Push(task) log.Ctx(s.ctx).Info("taskScheduler enqueue task", zap.Int64("taskID", taskID)) } }