diff --git a/src/job_manager.go b/src/job_manager.go index 767e435..a93f750 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -169,8 +169,8 @@ func (jm *JobManager) start() { InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, res.Status[i]) } else { log.Info(jm.job.Name, "-", i, " ", res.Status[i].Status) - /* save logs etc. */ + log.Info(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) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 162a12e..c5c5e03 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -63,6 +63,8 @@ func (s FairJobSorter) Less(i, j int) bool { } func (scheduler *SchedulerFair) Start() { + log.Info("JS started") + scheduler.jobs = map[string]*JobManager{} scheduler.history = []*Job{} scheduler.nextQueue = "default"