YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-13 07:46:43 +00:00
Code Issues Releases Wiki Activity

update shceduler_fair, bugfix

Browse Source
This commit is contained in:
Newnius
2019-08-01 14:13:14 +08:00
parent bac49853db
commit cfad24d26c
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/scheduler_fair.go
View File

@@ -96,7 +96,6 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) {
scheduler.history[i].Status = Finished scheduler.history[i].Status = Finished
} }
} }
scheduler.UpdateNextQueue()
break break
case Stopped: case Stopped:
for i := range scheduler.history { for i := range scheduler.history {
@@ -104,7 +103,6 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) {
scheduler.history[i].Status = Stopped scheduler.history[i].Status = Stopped
} }
} }
scheduler.UpdateNextQueue()
break break
} }
} }
@@ -192,7 +190,9 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus {
cnt.MemoryGPU += v.MemoryTotal cnt.MemoryGPU += v.MemoryTotal
} }
log.Info(job.Group, cnt) log.Info(job.Group, cnt)
scheduler.UpdateNextQueue() if len(res.Status) != 0 {
scheduler.UpdateNextQueue()
}
}(res) }(res)
return res return res
} }