From 8529d4aaa7b589a1dc40b14f3bf6e190b08f877d Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 30 Apr 2020 14:11:18 +0800 Subject: [PATCH] update --- src/job_manager.go | 2 +- src/scheduler_fair.go | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/src/job_manager.go b/src/job_manager.go index 572f15f..12b76e0 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -39,7 +39,7 @@ func (jm *JobManager) start() { } time.Sleep(time.Second * 1) } - log.Debug("Receive resource", resource) + log.Info("Receive resource", resource) jm.resources = append(jm.resources, resource) for _, t := range resource.Status { diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index d87cab9..38cd055 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -260,13 +260,12 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus { } } } + log.Info(candidates) } - log.Info(candidates) /*assign*/ if len(candidates) > 0 { node := candidates[0] - res := NodeStatus{} res.ClientID = node.ClientID res.ClientHost = node.ClientHost res.Status = candidates[0].Status[0:task.NumberGPU]