diff --git a/src/job_manager.go b/src/job_manager.go index 4fc8fe5..45f01ce 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -146,7 +146,7 @@ func (jm *JobManager) start() { /* monitor job execution */ for { //jm.status() - if !jm.isRunning { + if !jm.isRunning || jm.killFlag { break } time.Sleep(time.Second * 1) diff --git a/src/resource_pool.go b/src/resource_pool.go index 31ae736..1281495 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -861,7 +861,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) + log.Debug(estimate) if loadRatio >= pool.enablePreScheduleRatio { allocationType = 3