diff options
| author | Richard Ipsum <richard.ipsum@codethink.co.uk> | 2014-04-23 16:46:58 +0100 |
|---|---|---|
| committer | Richard Ipsum <richard.ipsum@codethink.co.uk> | 2014-04-23 17:32:36 +0100 |
| commit | 33e2ba3457d6626f24057084f54319cb29338771 (patch) | |
| tree | d9112b77e5d0e697a97e1ded51921db33f5b7825 | |
| parent | f25aa728184e0b63998f0c1d8a37df5a2e449568 (diff) | |
| download | morph-33e2ba3457d6626f24057084f54319cb29338771.tar.gz | |
WorkerConnection: _handle_exec_output
msg now contains a list of initiator ids rather than a single one,
since BuiltOutput needs to be sent to a number of initiators
| -rw-r--r-- | distbuild/worker_build_scheduler.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/distbuild/worker_build_scheduler.py b/distbuild/worker_build_scheduler.py index e58cfb11..77dfa550 100644 --- a/distbuild/worker_build_scheduler.py +++ b/distbuild/worker_build_scheduler.py @@ -391,11 +391,11 @@ class WorkerConnection(distbuild.StateMachine): def _handle_exec_output(self, msg): new = dict(msg) - new['id'] = self._route_map.get_incoming_id(msg['id']) + new['ids'] = self._job.initiators logging.debug('WC: emitting: %s', repr(new)) self.mainloop.queue_event( WorkerConnection, - WorkerBuildOutput(new, self._artifact.cache_key)) + WorkerBuildOutput(new, self._job.artifact.cache_key)) def _handle_exec_response(self, msg): logging.debug('WC: finished building: %s' % self._artifact.name) |