mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-12-15 08:16:43 +00:00
update
This commit is contained in:
@@ -178,6 +178,13 @@ func (jm *JobManager) checkStatus(status []TaskStatus) bool {
|
|||||||
if !jm.job.Tasks[i].IsPS {
|
if !jm.job.Tasks[i].IsPS {
|
||||||
onlyPS = false
|
onlyPS = false
|
||||||
}
|
}
|
||||||
|
} else if status[i].Status == "unknown" {
|
||||||
|
log.Debug(jm.job.Name, "-", i, " is starting")
|
||||||
|
flag = true
|
||||||
|
if !jm.job.Tasks[i].IsPS {
|
||||||
|
onlyPS = false
|
||||||
|
}
|
||||||
|
InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, status[i])
|
||||||
} else if status[i].Status == "running" {
|
} else if status[i].Status == "running" {
|
||||||
log.Debug(jm.job.Name, "-", i, " is running")
|
log.Debug(jm.job.Name, "-", i, " is running")
|
||||||
flag = true
|
flag = true
|
||||||
|
|||||||
Reference in New Issue
Block a user