YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-13 07:46:43 +00:00
Code Issues Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
Newnius
2020-04-26 18:48:49 +08:00
parent 6730dfc58e
commit 856e65c9dd
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/job_manager.go
View File

@@ -19,7 +19,7 @@ type JobManager struct {
} }
func (jm *JobManager) start() { 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{}} jm.jobStatus = JobStatus{Name: jm.job.Name, tasks: map[string]TaskStatus{}}
network := jm.scheduler.AcquireNetwork() network := jm.scheduler.AcquireNetwork()
@@ -49,7 +49,7 @@ func (jm *JobManager) start() {
} }
jm.scheduler.UpdateProgress(jm.job.Name, Running) 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 */ /* bring up containers */
for i := range jm.job.Tasks { for i := range jm.job.Tasks {

2
src/optimizer.go
View File

@@ -43,7 +43,7 @@ func (optimizer *Optimizer) feed(job string, utils []int) {
} }
postCnt := 0 postCnt := 0
for i := len(utils); i >= 0; i-- { for i := len(utils)-1; i >= 0; i-- {
if utils[i] > 15 { if utils[i] > 15 {
break break
} }

2
src/scheduler_fair.go
View File

@@ -88,7 +88,7 @@ func (scheduler *SchedulerFair) Start() {
jm.start() jm.start()
}() }()
} else { } else {
log.Info("No more jobs to scheduling", time.Now()) log.Debug("No more jobs to scheduling", time.Now())
scheduler.schedulingMu.Lock() scheduler.schedulingMu.Lock()
scheduler.schedulingJobsCnt-- scheduler.schedulingJobsCnt--
scheduler.schedulingMu.Unlock() scheduler.schedulingMu.Unlock()