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]