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

update fair

Browse Source
This commit is contained in:
Newnius
2020-05-31 19:44:52 +08:00
parent bbb5fda362
commit 242a213019
2 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/resource_pool.go
View File

@@ -144,7 +144,7 @@ func (pool *ResourcePool) checkDeadNodes() {
delete(pool.versions, k) delete(pool.versions, k)
pool.versionsMu.Unlock() pool.versionsMu.Unlock()
nodesToDel = append(nodesToDel, k) nodesToDel = append(nodesToDel, k)
log.Info(" node ", k, " is offline") log.Warn(" node ", k, " is offline")
} }
} }
for _, v := range nodesToDel { for _, v := range nodesToDel {

5
src/scheduler_fair.go
View File

@@ -163,11 +163,6 @@ func (scheduler *SchedulerFair) Start() {
if _, ok := quotas[queue]; !ok { if _, ok := quotas[queue]; !ok {
quotas[queue] = &ResourceCount{} quotas[queue] = &ResourceCount{}
} }
/* one cannot borrow more before he has cleared his IOUs */
//if len(scheduler.IOUs[queue]) > 0 {
// continue
//}
needGPU := numberGPUtmp*1000 - quotas[queue].NumberGPU needGPU := numberGPUtmp*1000 - quotas[queue].NumberGPU
/* the less, the better */ /* the less, the better */
if bestQueue == "" || needGPU < minRequestGPU { if bestQueue == "" || needGPU < minRequestGPU {