

def _stop_scheduling_tasks(self):
    'Stop scheduling tasks because an engine has been unregistered\n        from a pure ZMQ scheduler.\n        '
    self._task_socket.close()
    self._task_socket = None
    msg = ('An engine has been unregistered, and we are using pure ' + 'ZMQ task scheduling.  Task farming will be disabled.')
    if self.outstanding:
        msg += (' If you were running tasks when this happened, ' + 'some `outstanding` msg_ids may never resolve.')
    warnings.warn(msg, RuntimeWarning)

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