diff --git a/src/job_manager.go b/src/job_manager.go index 15ba5ad..743a2f1 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -19,7 +19,7 @@ type JobManager struct { } func (jm *JobManager) start() { - log.Debug("start job ", jm.job.Name, time.Now()) + log.Info("start job ", jm.job.Name, time.Now()) jm.jobStatus = JobStatus{Name: jm.job.Name, tasks: map[string]TaskStatus{}} network := jm.scheduler.AcquireNetwork() @@ -49,7 +49,7 @@ func (jm *JobManager) start() { } jm.scheduler.UpdateProgress(jm.job.Name, Running) - log.Debug("ready to run job ", jm.job.Name, time.Now()) + log.Info("ready to run job ", jm.job.Name, time.Now()) /* bring up containers */ for i := range jm.job.Tasks { diff --git a/src/optimizer.go b/src/optimizer.go index 3a59c99..d3e57f6 100644 --- a/src/optimizer.go +++ b/src/optimizer.go @@ -43,7 +43,7 @@ func (optimizer *Optimizer) feed(job string, utils []int) { } postCnt := 0 - for i := len(utils); i >= 0; i-- { + for i := len(utils)-1; i >= 0; i-- { if utils[i] > 15 { break } diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 508d6f0..4fd6243 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -88,7 +88,7 @@ func (scheduler *SchedulerFair) Start() { jm.start() }() } else { - log.Info("No more jobs to scheduling", time.Now()) + log.Debug("No more jobs to scheduling", time.Now()) scheduler.schedulingMu.Lock() scheduler.schedulingJobsCnt-- scheduler.schedulingMu.Unlock()