environment/lib/python2.7/site-packages/IPython/parallel/client/client.py
def _stop_scheduling_tasks(self):
        """Stop scheduling tasks because an engine has been unregistered
        from a pure ZMQ scheduler.
        """
        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)
def _stop_scheduling_tasks(self):
        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)
def _stop_scheduling_tasks ( self ) : 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 )
Stop scheduling tasks because an engine has been unregistered
        from a pure ZMQ scheduler.
Stop scheduling tasks because an engine has been unregistered from a pure ZMQ scheduler .