From c64ed900a7766a2b6a001813afcd94d7acf4a4b5 Mon Sep 17 00:00:00 2001
From: Newnius <newnius.cn@gmail.com>
Date: Mon, 4 May 2020 14:04:32 +0800
Subject: [PATCH] update

---
 src/job_manager.go    | 2 +-
 src/scheduler_fair.go | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

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"