##// END OF EJS Templates
small bugs
MinRK -
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=self.block, targets=self.targets)
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