Commit 85d4f254 authored by duanjinfei's avatar duanjinfei

GetAckResp

parent c01ba4b9
...@@ -254,14 +254,14 @@ func (t *TaskWorker) GetAckResp(taskMsg *nodemanagerV2.PushTaskMessage) (isCanEx ...@@ -254,14 +254,14 @@ func (t *TaskWorker) GetAckResp(taskMsg *nodemanagerV2.PushTaskMessage) (isCanEx
} }
} }
} }
if t.foundTaskImage(taskCmd) == "" { //if t.foundTaskImage(taskCmd) == "" {
log.WithField("imageName", taskCmd.ImageName).Error("The image is not found") // log.WithField("imageName", taskCmd.ImageName).Error("The image is not found")
return // return
} //}
running, _ := t.foundImageIsRunning(taskCmd.ImageName) //running, _ := t.foundImageIsRunning(taskCmd.ImageName)
if !running { //if !running {
//
} //}
log.Info("found task image finished") log.Info("found task image finished")
isCanExecute = true isCanExecute = true
modelInfo, err := db.GetModel(t.lastExecTaskImageName) modelInfo, err := db.GetModel(t.lastExecTaskImageName)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment