From 526a9d8b4ca8a3519b38b246eea6ecb39d9cb788 Mon Sep 17 00:00:00 2001 From: Newnius Date: Tue, 30 Jun 2020 20:43:42 +0800 Subject: [PATCH] update --- src/resource_pool.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/resource_pool.go b/src/resource_pool.go index 3485844..352f490 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -769,10 +769,9 @@ func (pool *ResourcePool) doAcquireResource(job Job) []NodeStatus { utilT := InstanceOfOptimizer().PredictReq(job, "Worker").UtilGPU totalUtil += utilT } - if totalUtil < 250 { + if totalUtil < 100 { available = append(available, status) } - log.Info(pred.UtilGPU, totalUtil) } } } @@ -860,6 +859,7 @@ func (pool *ResourcePool) doAcquireResource(job Job) []NodeStatus { /* third round, find gpu to be released */ if len(candidates) == 0 && len(job.Tasks) == 1 && task.NumberGPU == 1 && pool.enablePreSchedule { estimate := InstanceOfOptimizer().PredictTime(job) + log.Info(estimate) if loadRatio >= pool.enablePreScheduleRatio { allocationType = 3