From ba8c392888d3136a760ac298768f0ec2ef1d031e Mon Sep 17 00:00:00 2001 From: Newnius Date: Sat, 30 May 2020 15:16:29 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index e345179..186bbc7 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -133,10 +133,13 @@ func (scheduler *SchedulerFair) Start() { minRequestGPU = needGPU } } + if quota, ok := scheduler.queuesQuota[bestQueue]; ok { + totalGPU -= quota.NumberGPU + } /* if totalGPU can satisfy that job, start borrowing */ if bestQueue != "" && totalGPU >= minRequestGPU { log.Info("start borrow phase") - log.Info(totalGPU, " still need ", minRequestGPU) + log.Info(bestQueue, ": ", "total=", totalGPU, " still need ", minRequestGPU) for { /* if all satisfied, break */ if minRequestGPU == 0 {