From 340c1448515fb6c9ea77ff2dfd106a7182dce16d Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 25 May 2020 17:37:07 +0800 Subject: [PATCH] update --- src/job_manager.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/job_manager.go b/src/job_manager.go index 88fec86..1e5190a 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -20,7 +20,8 @@ type JobManager struct { resourcesMu sync.Mutex isRunning bool killFlag bool - network string + + network string } func (jm *JobManager) start() { @@ -188,9 +189,11 @@ func (jm *JobManager) checkStatus(status []TaskStatus) { } } } - if flagRunning && onlyPS { + if flagRunning && onlyPS && !jm.killFlag { log.Info("Only PS is running, stop ", jm.job.Name) jm.stop(false) + jm.killFlag = true + jm.scheduler.UpdateProgress(jm.job, Finished) } if !flagRunning && !jm.killFlag {