From bfbf90289badccef458d593fe5d431fe4bcf8087 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 21:52:09 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 660b312..c521827 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -170,6 +170,7 @@ func (scheduler *SchedulerFair) Start() { } IOU.NumberGPU += least minRequestGPU -= least + scheduler.queuesQuota[bestQueue].NumberGPU += least if least != 0 { log.Info(bestQueue, " borrow ", least, " from ", queue) } @@ -624,5 +625,6 @@ func (scheduler *SchedulerFair) DebugDump() map[string]interface{} { res["schedulingJobs"] = scheduler.schedulingJobs res["resourceAllocations"] = scheduler.resourceAllocations res["allocatingGPU"] = scheduler.allocatingGPU + res["IOUs"] = scheduler.IOUs return res }