From 692d316c3f24c53496e376c4274450820d744c64 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 17:34:46 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index cc47242..c19a922 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -383,8 +383,8 @@ func (scheduler *SchedulerFair) UpdateQuota() { 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 - 1) / per + if quota.NumberGPU+per*weight > requests[queue].NumberGPU*1000 { + weight = (requests[queue].NumberGPU*1000 - quota.NumberGPU + per - 1) / per } quota.NumberGPU += per * weight