Commit 5253bc59 authored by duanjinfei's avatar duanjinfei

add monitor node manager status

parent cbda927b
......@@ -173,6 +173,9 @@ func monitorWorker(op *operate.DockerOp) {
log.Error("Rev failed:", err)
params := buildParams(fmt.Sprintf("Rev failed:%s", err.Error()))
msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
if nodeManager.Status {
nodeManager.UpdateStatus(false)
}
return
}
log.Info("---------------------Received message---------------------")
......
......@@ -74,7 +74,7 @@ func (t *TaskHandler) HandlerTask(runCount int) {
}
case baseV1.TaskKind_StandardTask:
{
t.StandardTaskHandler(taskMsg)
t.ComputeTaskHandler(taskMsg)
}
}
}
......
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