##// END OF EJS Templates
load header with engine id when engine dies in TaskScheduler...
MinRK -
Show More
@@ -298,7 +298,13 b' class TaskScheduler(SessionFactory):'
298 raise error.EngineError("Engine %r died while running task %r"%(engine, msg_id))
298 raise error.EngineError("Engine %r died while running task %r"%(engine, msg_id))
299 except:
299 except:
300 content = error.wrap_exception()
300 content = error.wrap_exception()
301 msg = self.session.msg('apply_reply', content, parent=parent, subheader={'status':'error'})
301 # build fake header
302 header = dict(
303 status='error',
304 engine=engine,
305 date=datetime.now(),
306 )
307 msg = self.session.msg('apply_reply', content, parent=parent, subheader=header)
302 raw_reply = map(zmq.Message, self.session.serialize(msg, ident=idents))
308 raw_reply = map(zmq.Message, self.session.serialize(msg, ident=idents))
303 # and dispatch it
309 # and dispatch it
304 self.dispatch_result(raw_reply)
310 self.dispatch_result(raw_reply)
General Comments 0
You need to be logged in to leave comments. Login now