From c8d3b308d9b20e92023ef366de83fdc5c6875ce8 Mon Sep 17 00:00:00 2001 From: Newnius Date: Tue, 5 May 2020 16:12:46 +0800 Subject: [PATCH] update --- src/job_manager.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/job_manager.go b/src/job_manager.go index d30be85..e7f35c0 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -11,8 +11,8 @@ import ( ) type JobManager struct { - scheduler Scheduler - job Job + scheduler Scheduler + job Job jobStatus JobStatus resources []NodeStatus killedFlag bool @@ -80,9 +80,11 @@ func (jm *JobManager) start() { } } - jm.scheduler.UpdateProgress(jm.job, Running) + if !jm.killedFlag { + jm.scheduler.UpdateProgress(jm.job, Running) - log.Info("ready to run job ", jm.job.Name, time.Now()) + log.Info("ready to run job ", jm.job.Name, time.Now()) + } /* bring up containers */ for i := range jm.job.Tasks { @@ -102,6 +104,7 @@ func (jm *JobManager) start() { // break // } time.Sleep(time.Second * 1) + break //} }