diff --git a/src/job_manager.go b/src/job_manager.go index a93f750..458008c 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -8,6 +8,7 @@ import ( "encoding/json" "strconv" log "github.com/sirupsen/logrus" + "reflect" ) type JobManager struct { @@ -169,8 +170,8 @@ 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 != 0 { log.Warn(jm.job.Name+"-"+jm.job.Tasks[i].Name+" exited unexpected, exitCode=", exitCode)