Skip to content

P
power-node
Commit 381dcbb6 authored by duanjinfei's avatar duanjinfei
Browse files
Options

add stop container log

parent 9f8679df
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
nm/task_msg.go
View file @ 381dcbb6
...@@ -127,6 +127,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -127,6 +127,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
} else if taskMsg.TaskKind == baseV1.TaskKind_StandardTask { } else if taskMsg.TaskKind == baseV1.TaskKind_StandardTask {
t.IsExecStandardTask = true t.IsExecStandardTask = true
} }
log.WithField("oldTaskImageName", oldTaskImageName).WithField("newTaskImageName", taskCmd.ImageName).Info("task image info")
if oldTaskImageName != "" && oldTaskImageName != taskCmd.ImageName { if oldTaskImageName != "" && oldTaskImageName != taskCmd.ImageName {
//todo: 停止标准任务容器 //todo: 停止标准任务容器
containers := t.DockerOp.ListContainer() containers := t.DockerOp.ListContainer()
...@@ -137,6 +138,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -137,6 +138,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
} }
if container.Image == taskCmd.ImageName && container.State == "running" { if container.Image == taskCmd.ImageName && container.State == "running" {
t.DockerOp.StopContainer(container.ID) t.DockerOp.StopContainer(container.ID)
log.WithField("Image name", container.Image).Info("Stopping container")
} }
} }
oldTaskImageName = taskCmd.ImageName oldTaskImageName = taskCmd.ImageName
......
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