diff options
| author | Richard Ipsum <richard.ipsum@codethink.co.uk> | 2014-04-22 19:28:39 +0100 |
|---|---|---|
| committer | Richard Ipsum <richard.ipsum@codethink.co.uk> | 2014-04-23 17:32:36 +0100 |
| commit | ce9bd13839d4a20f31ae44b74b8f3e4a48bb75b6 (patch) | |
| tree | 45710a53db17a5640d04e26fccf5dad624a1446b | |
| parent | 23436a1fd5151f5d643bf159187f3779f590e671 (diff) | |
| download | morph-ce9bd13839d4a20f31ae44b74b8f3e4a48bb75b6.tar.gz | |
Initiator: Handle step-already-started message
| -rw-r--r-- | distbuild/initiator.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/distbuild/initiator.py b/distbuild/initiator.py index 6e4ca65a..67f37764 100644 --- a/distbuild/initiator.py +++ b/distbuild/initiator.py @@ -94,6 +94,7 @@ class Initiator(distbuild.StateMachine): 'build-progress': self._handle_build_progress_message, 'build-steps': self._handle_build_steps_message, 'step-started': self._handle_step_started_message, + 'step-already-started': self._handle_step_already_started_message, 'step-output': self._handle_step_output_message, 'step-finished': self._handle_step_finished_message, 'step-failed': self._handle_step_failed_message, @@ -127,6 +128,12 @@ class Initiator(distbuild.StateMachine): self._step_outputs[msg['step_name']].close() del self._step_outputs[msg['step_name']] + def _handle_step_already_started_message(self, msg): + self._app.status( + msg='%s is already building on %s' % (msg['step_name'], + msg['worker_name'])) + self._open_output(msg) + def _handle_step_started_message(self, msg): self._app.status( msg='Started building %(step_name)s on %(worker_name)s', |