diff --git a/job/job.go b/job/job.go index 1b518c6..72feb1d 100644 --- a/job/job.go +++ b/job/job.go @@ -394,8 +394,6 @@ func (j *Job) Start() error { } } } - - log.Infof("Scheduling task run %s-%s...", task.(*Task).UUID(), nextRun.(Run).Name) tasksInFlight.RUnlock() // Select some core IDs for this run based on how many it requires @@ -416,6 +414,8 @@ func (j *Job) Start() error { goto iterator } + log.Infof("Scheduling task run %s-%s...", task.(*Task).UUID(), nextRun.(Run).Name) + // Finally, we can dequeue the run since we are about to schedule it nextRun, err = task.(*Task).runs.Dequeue()