From fcd0ac52f0ae97de3f5e80d0f30d679ceb4fc3a2 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 17:53:17 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index d3ae4fa..35194c7 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -394,7 +394,7 @@ func (scheduler *SchedulerFair) UpdateQuota() { quota.CPU += (requests[queue].CPU * base) / requests[queue].NumberGPU availableCPU -= (requests[queue].CPU * base) / requests[queue].NumberGPU - quota.Memory += (requests[queue].Memory * base) / requests[queue].NumberGPU / 1000 + quota.Memory += ((requests[queue].Memory * base) / requests[queue].NumberGPU) / 1000 } if availableGPU > 0 { for _, queue := range candidates { @@ -403,6 +403,8 @@ func (scheduler *SchedulerFair) UpdateQuota() { } quota := scheduler.queuesQuota[queue] quota.NumberGPU += availableGPU + quota.CPU += (requests[queue].CPU * availableGPU) / requests[queue].NumberGPU + quota.Memory += ((requests[queue].Memory * availableGPU) / requests[queue].NumberGPU) / 1000 break } }