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 {