Show More
@@ -225,7 +225,7 b' class TaskScheduler(SessionFactory):' | |||||
225 | """Deal with jobs resident in an engine that died.""" |
|
225 | """Deal with jobs resident in an engine that died.""" | |
226 | lost = self.pending.pop(engine) |
|
226 | lost = self.pending.pop(engine) | |
227 |
|
227 | |||
228 | for msg_id, (raw_msg,follow) in lost.iteritems(): |
|
228 | for msg_id, (raw_msg, targets, MET, follow, timeout) in lost.iteritems(): | |
229 | self.all_failed.add(msg_id) |
|
229 | self.all_failed.add(msg_id) | |
230 | self.all_done.add(msg_id) |
|
230 | self.all_done.add(msg_id) | |
231 | idents,msg = self.session.feed_identities(raw_msg, copy=False) |
|
231 | idents,msg = self.session.feed_identities(raw_msg, copy=False) |
@@ -266,7 +266,7 b' class DirectView(View):' | |||||
266 | @save_ids |
|
266 | @save_ids | |
267 | def execute(self, code, block=True): |
|
267 | def execute(self, code, block=True): | |
268 | """execute some code on my targets.""" |
|
268 | """execute some code on my targets.""" | |
269 |
return self.client.execute(code, block= |
|
269 | return self.client.execute(code, block=block, targets=self.targets) | |
270 |
|
270 | |||
271 | def update(self, ns): |
|
271 | def update(self, ns): | |
272 | """update remote namespace with dict `ns`""" |
|
272 | """update remote namespace with dict `ns`""" |
General Comments 0
You need to be logged in to leave comments.
Login now