diff options
| author | Angelos Evripiotis <jevripiotis@bloomberg.net> | 2019-05-30 09:37:26 +0100 |
|---|---|---|
| committer | bst-marge-bot <marge-bot@buildstream.build> | 2019-06-05 14:13:10 +0000 |
| commit | 0050f81c9d52e42e2ea3d19782a46635521ecbd3 (patch) | |
| tree | 11ddd96c0910b21a93eab9c6bd4af844f4c04439 | |
| parent | efc8a4dbb54b63cd5412218e17c9fa9801356aff (diff) | |
| download | buildstream-0050f81c9d52e42e2ea3d19782a46635521ecbd3.tar.gz | |
_scheduler/jobs/job: refactor, use send_message
| -rw-r--r-- | src/buildstream/_scheduler/jobs/job.py | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/src/buildstream/_scheduler/jobs/job.py b/src/buildstream/_scheduler/jobs/job.py index 178c84703..92559e9f7 100644 --- a/src/buildstream/_scheduler/jobs/job.py +++ b/src/buildstream/_scheduler/jobs/job.py @@ -701,7 +701,7 @@ class ChildJob(): elapsed=elapsed, detail=e.detail, logfile=filename, sandbox=e.sandbox) - self._queue.put(_Envelope('child_data', self.child_process_data())) + self.send_message('child_data', self.child_process_data()) # Report the exception to the parent (for internal testing purposes) self._child_send_error(e) @@ -727,7 +727,7 @@ class ChildJob(): else: # No exception occurred in the action - self._queue.put(_Envelope('child_data', self.child_process_data())) + self.send_message('child_data', self.child_process_data()) self._child_send_result(result) elapsed = datetime.datetime.now() - starttime @@ -758,11 +758,10 @@ class ChildJob(): domain = e.domain reason = e.reason - envelope = _Envelope('error', { + self.send_message('error', { 'domain': domain, 'reason': reason }) - self._queue.put(envelope) # _child_send_result() # @@ -776,8 +775,7 @@ class ChildJob(): # def _child_send_result(self, result): if result is not None: - envelope = _Envelope('result', result) - self._queue.put(envelope) + self.send_message('result', result) # _child_shutdown() # @@ -813,4 +811,4 @@ class ChildJob(): if message.message_type == MessageType.LOG: return - self._queue.put(_Envelope('message', message)) + self.send_message('message', message) |