From 1953676ee01d23de34a4714d6895c4e534beded3 Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Fri, 21 Mar 2025 19:36:15 +0800
Subject: [PATCH] fix: Set task queue time before enqueue (#40815)

Related to #40814

---------

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/datacoord/task_scheduler.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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))
 	}
 }