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