job/job: Move log for when task is actually being scheduled

Signed-off-by: Alexander Jung <a.jung@lancs.ac.uk>
lancs-net · Dec 21, 2020 · 8764d55 · 8764d55
1 parent 5f3e46b
commit 8764d55
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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()