Show More
@@ -298,7 +298,13 b' class TaskScheduler(SessionFactory):' | |||
|
298 | 298 | raise error.EngineError("Engine %r died while running task %r"%(engine, msg_id)) |
|
299 | 299 | except: |
|
300 | 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 | 308 | raw_reply = map(zmq.Message, self.session.serialize(msg, ident=idents)) |
|
303 | 309 | # and dispatch it |
|
304 | 310 | self.dispatch_result(raw_reply) |
General Comments 0
You need to be logged in to leave comments.
Login now