diff options
| author | Benjamin Schubert <contact@benschubert.me> | 2020-07-04 16:30:48 +0000 |
|---|---|---|
| committer | bst-marge-bot <marge-bot@buildstream.build> | 2020-07-06 18:07:53 +0000 |
| commit | 3cb61cfee0fb7c66be1af9d19b3316f966ce3090 (patch) | |
| tree | 2d1eba782fd4ef3c63396ee8c2c2fdc34062e527 /src/buildstream/_stream.py | |
| parent | e16433a8b72a81d2afd11dd4d2d58f24512e259d (diff) | |
| download | buildstream-3cb61cfee0fb7c66be1af9d19b3316f966ce3090.tar.gz | |
scheduler.py: Remove task-based notifications and use the state
The State is the interface between both, there is no need to do multiple
round-trips to handle such notifications
Diffstat (limited to 'src/buildstream/_stream.py')
| -rw-r--r-- | src/buildstream/_stream.py | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/src/buildstream/_stream.py b/src/buildstream/_stream.py index 64e4d09ec..277ea7394 100644 --- a/src/buildstream/_stream.py +++ b/src/buildstream/_stream.py @@ -45,7 +45,6 @@ from ._scheduler import ( ArtifactPushQueue, NotificationType, Notification, - JobStatus, ) from .element import Element from ._pipeline import Pipeline @@ -1662,12 +1661,6 @@ class Stream: self._interrupt_callback() elif notification.notification_type == NotificationType.TICK: self._ticker_callback() - elif notification.notification_type == NotificationType.JOB_START: - self._state.add_task(notification.job_action, notification.full_name, notification.time) - elif notification.notification_type == NotificationType.JOB_COMPLETE: - self._state.remove_task(notification.job_action, notification.full_name) - if notification.job_status == JobStatus.FAIL: - self._state.fail_task(notification.job_action, notification.full_name, notification.element) elif notification.notification_type == NotificationType.SCHED_START_TIME: self._starttime = notification.time elif notification.notification_type == NotificationType.RUNNING: |