From 5890d07306819f923c5d82cac3255fc76480d43d Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 17:32:24 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 22bc10e..cc47242 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -382,8 +382,9 @@ func (scheduler *SchedulerFair) UpdateQuota() { weight := InstanceOfGroupManager().groups[queue].Weight quota := scheduler.queuesQuota[queue] + /* if allocate is more than request, reduce weight */ if quota.NumberGPU+per*weight > requests[queue].NumberGPU { - weight = requests[queue].NumberGPU / (quota.NumberGPU + per) + weight = (requests[queue].NumberGPU - quota.NumberGPU + per - 1) / per } quota.NumberGPU += per * weight