YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-06-07 22:31:55 +00:00
Code Issues Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
Newnius 2020-04-12 18:42:55 +08:00
parent f57294b703
commit 4ce9378bf6
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/history_logger.go
View File

@ -35,7 +35,7 @@ func (jhl *JobHistoryLogger) init() {
} }
func (jhl *JobHistoryLogger) submitJob(job Job) { func (jhl *JobHistoryLogger) submitJob(job Job) {
log.Debug("submit job task status", job.Name) log.Debug("submit job", job.Name)
jhl.jobs[job.Name] = job jhl.jobs[job.Name] = job
jhl.tasks[job.Name] = []TaskStatus{} jhl.tasks[job.Name] = []TaskStatus{}
} }
@ -48,7 +48,7 @@ func (jhl *JobHistoryLogger) updateJobStatus(jobName string, state State) {
} }
func (jhl *JobHistoryLogger) submitTaskStatus(jobName string, task TaskStatus) { func (jhl *JobHistoryLogger) submitTaskStatus(jobName string, task TaskStatus) {
log.Info("submit job task", jobName) log.Info("submit job task status", jobName)
if tasks, ok := jhl.tasks[jobName]; ok { if tasks, ok := jhl.tasks[jobName]; ok {
jhl.tasks[jobName] = append(tasks, task) jhl.tasks[jobName] = append(tasks, task)
} }

3
src/scheduler_fair.go
View File

@ -84,6 +84,7 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) {
for i := range scheduler.history { for i := range scheduler.history {
if scheduler.history[i].Name == jobName { if scheduler.history[i].Name == jobName {
scheduler.history[i].Status = Running scheduler.history[i].Status = Running
scheduler.history[i].UpdatedAt = int(time.Now().Unix())
} }
} }
break break
@ -91,6 +92,7 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) {
for i := range scheduler.history { for i := range scheduler.history {
if scheduler.history[i].Name == jobName { if scheduler.history[i].Name == jobName {
scheduler.history[i].Status = Finished scheduler.history[i].Status = Finished
scheduler.history[i].UpdatedAt = int(time.Now().Unix())
} }
} }
break break
@ -98,6 +100,7 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) {
for i := range scheduler.history { for i := range scheduler.history {
if scheduler.history[i].Name == jobName { if scheduler.history[i].Name == jobName {
scheduler.history[i].Status = Stopped scheduler.history[i].Status = Stopped
scheduler.history[i].UpdatedAt = int(time.Now().Unix())
} }
} }
break break