update sync mao load taskId error

58123d00 · duanjinfei · ac8fe82c · 58123d00
Commit 58123d00 authored Mar 21, 2024 by duanjinfei
Hide whitespace changes
Inline Side-by-side

Showing with 6 additions and 1 deletion

task_msg.go nm/task_msg.go +6 -1

No files found.
--- a/nm/task_msg.go
+++ b/nm/task_msg.go
@@ -115,7 +115,12 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 				oldTaskId = taskMsg.TaskId
 				break
 			}
-			value, _ := t.ExecTaskIdIsSuccess.Load(oldTaskId)
+			value, ok := t.ExecTaskIdIsSuccess.Load(oldTaskId)
+			log.WithField("isSuccess", value).Info("Task id exec info")
+			if !ok {
+				log.Warn("First exec task")
+				break
+			}
 			isSuccess := value.(bool)
 			if isSuccess {
 				oldTaskId = taskMsg.TaskId