From 515290736ce5cadda144a832f16e06540720e457 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 4 May 2020 14:10:29 +0800 Subject: [PATCH] update --- src/job_manager.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/job_manager.go b/src/job_manager.go index ffdce96..c14348e 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -8,7 +8,7 @@ import ( "encoding/json" "strconv" log "github.com/sirupsen/logrus" - ) +) type JobManager struct { scheduler Scheduler @@ -170,7 +170,7 @@ func (jm *JobManager) start() { } else { log.Info(jm.job.Name, "-", i, " ", res.Status[i].Status) if exitCode, ok := res.Status[i].State["ExitCode"].(float64); ok { - if exitCode != 0 { + if exitCode != 0 && !jm.killedFlag { log.Warn(jm.job.Name+"-"+jm.job.Tasks[i].Name+" exited unexpected, exitCode=", exitCode) jm.killedFlag = true jm.scheduler.UpdateProgress(jm.job, Failed)