mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-06-07 22:31:55 +00:00
update
This commit is contained in:
parent
c64ed900a7
commit
012fb0b18a
@ -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)
|
||||
|
Loading…
Reference in New Issue
Block a user