GetAckResp

nm/msg_resp.go

@@ -261,6 +261,7 @@ func FetchStandardTaskResp(params ...interface{}) *nodemanagerV2.WorkerMessage {
 }
 
 func RespTaskAck(params ...interface{}) *nodemanagerV2.WorkerMessage {
+	log.Info("RespTaskAck params :", params)
 	taskId := params[0].(string)
 	canExecute := params[1].(bool)
 	bootUpTime := params[2].(int64)

nm/task_handler.go

@@ -264,7 +264,7 @@ func (t *TaskWorker) GetAckResp(taskMsg *nodemanagerV2.PushTaskMessage) (isCanEx
 	//}
 	log.Info("found task image finished")
 	isCanExecute = true
-	modelInfo, err := db.GetModel(t.lastExecTaskImageName)
+	modelInfo, err := db.GetModel(taskCmd.ImageName)
 	if err != nil {
 		return false, 0, 0, 0, ""
 	}
@@ -272,7 +272,7 @@ func (t *TaskWorker) GetAckResp(taskMsg *nodemanagerV2.PushTaskMessage) (isCanEx
 		bootUpTime = modelInfo.StartUpTime
 		executeTime = int64(modelInfo.EstimatExeTime)
 	}
-	imageName = modelInfo.ImageName
+	imageName = taskCmd.ImageName
 	return
 }