From c804102e4bc965f10f7713f0ef4f6140bff1db67 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 10:37:21 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index a61a349..b2b27b2 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -320,7 +320,12 @@ func (scheduler *SchedulerFair) UpdateQuota() { available := pool.TotalGPU - usingGPU log.Info("Can allocate ", available) - log.Info("Before ", scheduler.queuesQuota) + log.Info("Before ") + for _, quota := range scheduler.queuesQuota { + log.Info("GPU:", quota.NumberGPU) + log.Info("CPU:", quota.CPU) + log.Info("Memory:", quota.Memory) + } per := available / len(scheduler.queues) for queue := range scheduler.queues { if _, ok := scheduler.queuesQuota[queue]; !ok { @@ -337,7 +342,12 @@ func (scheduler *SchedulerFair) UpdateQuota() { break } } - log.Info("After ", scheduler.queuesQuota) + log.Info("After ") + for _, quota := range scheduler.queuesQuota { + log.Info("GPU:", quota.NumberGPU) + log.Info("CPU:", quota.CPU) + log.Info("Memory:", quota.Memory) + } } func (scheduler *SchedulerFair) QueryState(jobName string) MsgJobStatus {