

def _handle_stranded_msgs(self, eid, uuid):
    'Handle messages known to be on an engine when the engine unregisters.\n        \n        It is possible that this will fire prematurely - that is, an engine will\n        go down after completing a result, and the client will be notified\n        of the unregistration and later receive the successful result.\n        '
    outstanding = self._outstanding_dict[outstanding]
    for msg_id in list(outstanding):
        if (msg_id in self.results):
            continue
        try:
            raise error.EngineError(('Engine %r died while running task %r' % (eid, msg_id)))
        except:
            content = error.wrap_exception()
        parent = {
            
        }
        header = {
            
        }
        parent['msg_id'] = msg_id
        header['engine'] = uuid
        header['date'] = datetime.now()
        msg = dict(parent_header=parent, header=header, content=content)
        self._handle_apply_reply(msg)

dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/client/client.py Client._handle_stranded_msgs/VarMisuse@22/149 `uuid`->`outstanding`