summaryrefslogtreecommitdiff
path: root/src/buildstream/_scheduler/scheduler.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/buildstream/_scheduler/scheduler.py')
-rw-r--r--src/buildstream/_scheduler/scheduler.py9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/buildstream/_scheduler/scheduler.py b/src/buildstream/_scheduler/scheduler.py
index 0bcbb7182..ae510c2e0 100644
--- a/src/buildstream/_scheduler/scheduler.py
+++ b/src/buildstream/_scheduler/scheduler.py
@@ -375,7 +375,15 @@ class Scheduler:
# job (Job): The job to start
#
def _start_job(self, job):
+
+ # From the scheduler perspective, the following
+ # is considered atomic; started jobs are always in the
+ # active_jobs list, and jobs in the active_jobs list
+ # are always started.
+ #
self._active_jobs.append(job)
+ job.start()
+
notification = Notification(
NotificationType.JOB_START,
full_name=job.name,
@@ -383,7 +391,6 @@ class Scheduler:
time=self._state.elapsed_time(start_time=self._starttime),
)
self._notify(notification)
- job.start()
# _sched_queue_jobs()
#