From b7bf5e139049b7dbbfe1c80b8cd26c7f9995992d Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 23:42:55 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index da0990a..cc8ac77 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -54,7 +54,7 @@ func (scheduler *SchedulerFair) Start() { go func() { flag := true for { - log.Info("Scheduling") + log.Debug("Scheduling") if !flag { /* no more job */ time.Sleep(time.Millisecond * 100) } @@ -94,10 +94,6 @@ func (scheduler *SchedulerFair) Start() { } /* the more, the better */ if bestQueue == "" || numberGPUtmp > maxNumberGPU || (numberGPUtmp == maxNumberGPU && numberCPUtmp > maxNumberCPU) { - /* cannot borrow more if already borrowed */ - if _, ok := scheduler.IOUs[queue]; ok && len(scheduler.IOUs[queue]) > 0 { - continue - } bestQueue = queue maxNumberGPU = numberGPUtmp maxNumberCPU = numberCPUtmp