environment/lib/python2.7/site-packages/IPython/parallel/client/client.py
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()
def _unregister_engine(self, msg):
        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()
def _unregister_engine ( self , msg ) : 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 ( )
Unregister an engine that has died.
Unregister an engine that has died .