Commit dea86434 authored by duanjinfei's avatar duanjinfei

update standard task handler

parent b4b5057f
......@@ -110,12 +110,12 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
t.IsExecAiTask = true
if t.IsExecStandardTask {
//todo: 停止标准任务容器
containers := t.DockerOp.ListContainer()
for _, container := range containers {
if container.Image == taskCmd.ImageName && container.State == "running" {
t.DockerOp.StopContainer(container.ID)
}
}
//containers := t.DockerOp.ListContainer()
//for _, container := range containers {
// if container.Image == taskCmd.ImageName && container.State == "running" {
// t.DockerOp.StopContainer(container.ID)
// }
//}
t.IsExecStandardTask = false
}
} else if taskMsg.TaskKind == baseV1.TaskKind_StandardTask {
......
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