diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index a97c00b..06712d9 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -125,6 +125,11 @@ func (scheduler *SchedulerFair) Start() { if _, ok := scheduler.queuesQuota[queue]; !ok { scheduler.queuesQuota[queue] = &ResourceCount{} } + /* one cannot borrow more before he has cleared his IOUs */ + if len(scheduler.IOUs[queue]) > 0 { + continue + } + needGPU := numberGPUtmp*1000 - scheduler.queuesQuota[queue].NumberGPU /* the less, the better */ if bestQueue == "" || needGPU < minRequestGPU {