

def _unregister_engine(self, msg):
    'Unregister an engine that has died.'
    content = msg['content']
    eid = int(content['id'])
    if (eid in self._ids):
        self._ids.remove(eid)
        uuid = self._engines.pop(eid)
        self._handle_stranded_msgs(eid, uuid)
    if (self._task_socket and (self._task_scheme == 'pure')):
        self._stop_scheduling_tasks()

dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/client/client.py Client._unregister_engine/original