From 193ccaa24e596a00c94ac48af21c12fe2e7c5b1f 2012-08-11 05:15:13 From: MinRK Date: 2012-08-11 05:15:13 Subject: [PATCH] fix message built for engine dying during task The test_z__crash tests actually test this, but they have long-since been skipped because people don't like the crash dialogs some OSes give. --- diff --git a/IPython/parallel/client/client.py b/IPython/parallel/client/client.py index 4571023..2121a8d 100644 --- a/IPython/parallel/client/client.py +++ b/IPython/parallel/client/client.py @@ -694,12 +694,9 @@ class Client(HasTraits): except: content = error.wrap_exception() # build a fake message: - parent = {} - header = {} - parent['msg_id'] = msg_id - header['engine'] = uuid - header['date'] = datetime.now() - msg = dict(parent_header=parent, header=header, content=content) + msg = self.session.msg('apply_reply', content=content) + msg['parent_header']['msg_id'] = msg_id + msg['metadata']['engine'] = uuid self._handle_apply_reply(msg) def _handle_execute_reply(self, msg):