diff --git a/src/history_logger.go b/src/history_logger.go index b2d264b..53ac340 100644 --- a/src/history_logger.go +++ b/src/history_logger.go @@ -35,7 +35,7 @@ func (jhl *JobHistoryLogger) init() { } 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.tasks[job.Name] = []TaskStatus{} } @@ -48,7 +48,7 @@ func (jhl *JobHistoryLogger) updateJobStatus(jobName string, state State) { } 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 { jhl.tasks[jobName] = append(tasks, task) } diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index f688157..cd6f923 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -84,6 +84,7 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) { for i := range scheduler.history { if scheduler.history[i].Name == jobName { scheduler.history[i].Status = Running + scheduler.history[i].UpdatedAt = int(time.Now().Unix()) } } break @@ -91,6 +92,7 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) { for i := range scheduler.history { if scheduler.history[i].Name == jobName { scheduler.history[i].Status = Finished + scheduler.history[i].UpdatedAt = int(time.Now().Unix()) } } break @@ -98,6 +100,7 @@ func (scheduler *SchedulerFair) UpdateProgress(jobName string, state State) { for i := range scheduler.history { if scheduler.history[i].Name == jobName { scheduler.history[i].Status = Stopped + scheduler.history[i].UpdatedAt = int(time.Now().Unix()) } } break