environment/lib/python2.7/site-packages/IPython/parallel/client/client.py
def queue_status(self, targets='all', verbose=False):
        """Fetch the status of engine queues.

        Parameters
        ----------

        targets : int/str/list of ints/strs
                the engines whose states are to be queried.
                default : all
        verbose : bool
                Whether to return lengths only, or lists of ids for each element
        """
        if targets == 'all':
            # allow 'all' to be evaluated on the engine
            engine_ids = None
        else:
            engine_ids = self._build_targets(targets)[1]
        content = dict(targets=engine_ids, verbose=verbose)
        self.session.send(self._query_socket, "queue_request", content=content)
        idents,msg = self.session.recv(self._query_socket, 0)
        if self.debug:
            pprint(msg)
        content = msg['content']
        status = content.pop('status')
        if status != 'ok':
            raise self._unwrap_exception(content)
        content = rekey(content)
        if isinstance(targets, int):
            return content[targets]
        else:
            return content
def queue_status(self, targets='all', verbose=False):
        if targets == 'all':
            # allow 'all' to be evaluated on the engine
            engine_ids = None
        else:
            engine_ids = self._build_targets(targets)[1]
        content = dict(targets=engine_ids, verbose=verbose)
        self.session.send(self._query_socket, "queue_request", content=content)
        idents,msg = self.session.recv(self._query_socket, 0)
        if self.debug:
            pprint(msg)
        content = msg['content']
        status = content.pop('status')
        if status != 'ok':
            raise self._unwrap_exception(content)
        content = rekey(content)
        if isinstance(targets, int):
            return content[targets]
        else:
            return content
def queue_status ( self , targets = 'all' , verbose = False ) : if targets == 'all' : # allow 'all' to be evaluated on the engine engine_ids = None else : engine_ids = self . _build_targets ( targets ) [ 1 ] content = dict ( targets = engine_ids , verbose = verbose ) self . session . send ( self . _query_socket , "queue_request" , content = content ) idents , msg = self . session . recv ( self . _query_socket , 0 ) if self . debug : pprint ( msg ) content = msg [ 'content' ] status = content . pop ( 'status' ) if status != 'ok' : raise self . _unwrap_exception ( content ) content = rekey ( content ) if isinstance ( targets , int ) : return content [ targets ] else : return content
Fetch the status of engine queues.

        Parameters
        ----------

        targets : int/str/list of ints/strs
                the engines whose states are to be queried.
                default : all
        verbose : bool
                Whether to return lengths only, or lists of ids for each element
Fetch the status of engine queues .