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