1
0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-06-06 22:01:55 +00:00
This commit is contained in:
Newnius 2020-06-11 21:21:57 +08:00
parent 6c1c93b362
commit b979373cbd

View File

@ -206,6 +206,7 @@ func (jm *JobManager) checkStatus(status []TaskStatus) {
jm.killFlag = true
jm.scheduler.UpdateProgress(jm.job, Failed)
} else if !jm.killFlag {
log.Info("Some instance exited, close others")
jm.stop(false)
jm.killFlag = true
jm.scheduler.UpdateProgress(jm.job, Finished)
@ -365,7 +366,7 @@ func (jm *JobManager) stop(force bool) MsgStop {
if res.Code != 0 {
log.Warn(res.Error)
}
log.Info(task.Id, " is killed")
log.Info(task.HostName, " is killed:", task.Id)
}(taskStatus)
}