mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-12-15 08:16:43 +00:00
update
This commit is contained in:
@@ -148,9 +148,8 @@ func (jm *JobManager) start() {
|
|||||||
}
|
}
|
||||||
if flag && onlyPS {
|
if flag && onlyPS {
|
||||||
jm.stop()
|
jm.stop()
|
||||||
log.Info("Only PS is running, stop", jm.job.Name)
|
log.Info("Only PS is running, stop ", jm.job.Name)
|
||||||
jm.killedFlag = false
|
jm.killedFlag = false
|
||||||
break
|
|
||||||
}
|
}
|
||||||
if !flag {
|
if !flag {
|
||||||
break
|
break
|
||||||
@@ -162,7 +161,7 @@ func (jm *JobManager) start() {
|
|||||||
|
|
||||||
if !jm.killedFlag {
|
if !jm.killedFlag {
|
||||||
jm.scheduler.UpdateProgress(jm.job.Name, Finished)
|
jm.scheduler.UpdateProgress(jm.job.Name, Finished)
|
||||||
log.Info("finish job", jm.job.Name)
|
log.Info("finish job ", jm.job.Name)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user