summaryrefslogtreecommitdiff
path: root/distbuild
diff options
context:
space:
mode:
authorRichard Ipsum <richard.ipsum@codethink.co.uk>2014-04-23 15:46:58 (GMT)
committerRichard Ipsum <richard.ipsum@codethink.co.uk>2014-04-23 16:32:36 (GMT)
commit33e2ba3457d6626f24057084f54319cb29338771 (patch)
treed9112b77e5d0e697a97e1ded51921db33f5b7825 /distbuild
parentf25aa728184e0b63998f0c1d8a37df5a2e449568 (diff)
downloadmorph-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
Diffstat (limited to 'distbuild')
-rw-r--r--distbuild/worker_build_scheduler.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/distbuild/worker_build_scheduler.py b/distbuild/worker_build_scheduler.py
index e58cfb1..77dfa55 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)