YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-12 23:36:44 +00:00
Code Issues Releases Wiki Activity

update

Browse Source
This commit is contained in:
Newnius
2020-05-01 13:01:53 +08:00
parent 72ba430f4d
commit c295f9eb6f
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/job_manager.go
View File

@@ -129,14 +129,17 @@ func (jm *JobManager) start() {
//}
/* return resource */
jm.scheduler.ReleaseResource(jm.job, jm.resources[i])
log.Info("return resource ", jm.resources[i].ClientID)
if jm.resources[i].ClientID != "null" {
jm.scheduler.ReleaseResource(jm.job, jm.resources[i])
log.Info("return resource ", jm.resources[i].ClientID)
jm.resources[i].ClientID = "null"
for _, t := range jm.resources[i].Status {
jm.scheduler.Detach(t.UUID, jm.job.Name)
for _, t := range jm.resources[i].Status {
jm.scheduler.Detach(t.UUID, jm.job.Name)
}
InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, res.Status[i])
}
InstanceJobHistoryLogger().submitTaskStatus(jm.job.Name, res.Status[i])
}
}
if flag && onlyPS {