diff --git a/src/job_manager.go b/src/job_manager.go index a1d1226..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 { @@ -123,7 +123,7 @@ func (jm *JobManager) start() { /* return resource */ jm.scheduler.ReleaseResource(jm.job, jm.resources[i]) - log.Debug("return resource ", jm.resources[i].ClientID) + log.Info("return resource ", jm.resources[i].ClientID) for _, t := range jm.resources[i].Status { jm.scheduler.Detach(t.UUID, jm.job.Name) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 64fd919..a9bc783 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -71,7 +71,6 @@ func (scheduler *SchedulerFair) Start() { jm.start() }() } else { - log.Info("No more jobs to schedule", time.Now()) scheduler.scheduling.Unlock() go func() { scheduler.UpdateNextQueue()