environment/lib/python2.7/site-packages/IPython/parallel/controller/hub.py
def queue_status(self, client_id, msg):
        """Return the Queue status of one or more targets.
        if verbose: return the msg_ids
        else: return len of each type.
        keys: queue (pending MUX jobs)
            tasks (pending Task jobs)
            completed (finished jobs from both queues)"""
        content = msg['content']
        targets = content['targets']
        try:
            targets = self._validate_targets(targets)
        except:
            content = error.wrap_exception()
            self.session.send(self.query, "hub_error",
                    content=content, ident=client_id)
            return
        verbose = content.get('verbose', False)
        content = dict(status='ok')
        for t in targets:
            queue = self.queues[t]
            completed = self.completed[t]
            tasks = self.tasks[t]
            if not verbose:
                queue = len(queue)
                completed = len(completed)
                tasks = len(tasks)
            content[str(t)] = {'queue': queue, 'completed': completed , 'tasks': tasks}
        content['unassigned'] = list(self.unassigned) if verbose else len(self.unassigned)
        # print (content)
        self.session.send(self.query, "queue_reply", content=content, ident=client_id)
def queue_status(self, client_id, msg):
        """Return the Queue status of one or more targets.
        if verbose: return the msg_ids
        else: return len of each type.
        keys: queue (pending MUX jobs)
            tasks (pending Task jobs)
            completed (finished jobs from both queues)"""
        content = msg['content']
        targets = content['targets']
        try:
            targets = self._validate_targets(targets)
        except:
            content = error.wrap_exception()
            self.session.send(self.query, "hub_error",
                    content=content, ident=client_id)
            return
        verbose = content.get('verbose', False)
        content = dict(status='ok')
        for t in targets:
            queue = self.queues[t]
            completed = self.completed[t]
            tasks = self.tasks[t]
            if not verbose:
                queue = len(queue)
                completed = len(completed)
                tasks = len(tasks)
            content[str(t)] = {'queue': queue, 'completed': completed , 'tasks': tasks}
        content['unassigned'] = list(self.unassigned) if verbose else len(self.unassigned)
        # print (content)
        self.session.send(self.query, "queue_reply", content=content, ident=client_id)
def queue_status ( self , client_id , msg ) : content = msg [ 'content' ] targets = content [ 'targets' ] try : targets = self . _validate_targets ( targets ) except : content = error . wrap_exception ( ) self . session . send ( self . query , "hub_error" , content = content , ident = client_id ) return verbose = content . get ( 'verbose' , False ) content = dict ( status = 'ok' ) for t in targets : queue = self . queues [ t ] completed = self . completed [ t ] tasks = self . tasks [ t ] if not verbose : queue = len ( queue ) completed = len ( completed ) tasks = len ( tasks ) content [ str ( t ) ] = { 'queue' : queue , 'completed' : completed , 'tasks' : tasks } content [ 'unassigned' ] = list ( self . unassigned ) if verbose else len ( self . unassigned ) # print (content) self . session . send ( self . query , "queue_reply" , content = content , ident = client_id )
Return the Queue status of one or more targets.
        if verbose: return the msg_ids
        else: return len of each type.
        keys: queue (pending MUX jobs)
            tasks (pending Task jobs)
            completed (finished jobs from both queues)
Return the Queue status of one or more targets . if verbose : return the msg_ids else : return len of each type . keys : queue ( pending MUX jobs ) tasks ( pending Task jobs ) completed ( finished jobs from both queues )