environment/lib/python2.7/site-packages/IPython/parallel/client/client.py
def db_query(self, query, keys=None):
        """Query the Hub's TaskRecord database

        This will return a list of task record dicts that match `query`

        Parameters
        ----------

        query : mongodb query dict
            The search dict. See mongodb query docs for details.
        keys : list of strs [optional]
            The subset of keys to be returned.  The default is to fetch everything but buffers.
            'msg_id' will *always* be included.
        """
        if isinstance(keys, basestring):
            keys = [keys]
        content = dict(query=query, keys=keys)
        self.session.send(self._query_socket, "db_request", content=content)
        idents, msg = self.session.recv(self._query_socket, 0)
        if self.debug:
            pprint(msg)
        content = msg['content']
        if content['status'] != 'ok':
            raise self._unwrap_exception(content)

        records = content['records']

        buffer_lens = content['buffer_lens']
        result_buffer_lens = content['result_buffer_lens']
        buffers = msg['buffers']
        has_bufs = buffer_lens is not None
        has_rbufs = result_buffer_lens is not None
        for i,rec in enumerate(records):
            # relink buffers
            if has_bufs:
                blen = buffer_lens[i]
                rec['buffers'], buffers = buffers[:blen],buffers[blen:]
            if has_rbufs:
                blen = result_buffer_lens[i]
                rec['result_buffers'], buffers = buffers[:blen],buffers[blen:]

        return records
def db_query(self, query, keys=None):
        if isinstance(keys, basestring):
            keys = [keys]
        content = dict(query=query, keys=keys)
        self.session.send(self._query_socket, "db_request", content=content)
        idents, msg = self.session.recv(self._query_socket, 0)
        if self.debug:
            pprint(msg)
        content = msg['content']
        if content['status'] != 'ok':
            raise self._unwrap_exception(content)

        records = content['records']

        buffer_lens = content['buffer_lens']
        result_buffer_lens = content['result_buffer_lens']
        buffers = msg['buffers']
        has_bufs = buffer_lens is not None
        has_rbufs = result_buffer_lens is not None
        for i,rec in enumerate(records):
            # relink buffers
            if has_bufs:
                blen = buffer_lens[i]
                rec['buffers'], buffers = buffers[:blen],buffers[blen:]
            if has_rbufs:
                blen = result_buffer_lens[i]
                rec['result_buffers'], buffers = buffers[:blen],buffers[blen:]

        return records
def db_query ( self , query , keys = None ) : if isinstance ( keys , basestring ) : keys = [ keys ] content = dict ( query = query , keys = keys ) self . session . send ( self . _query_socket , "db_request" , content = content ) idents , msg = self . session . recv ( self . _query_socket , 0 ) if self . debug : pprint ( msg ) content = msg [ 'content' ] if content [ 'status' ] != 'ok' : raise self . _unwrap_exception ( content ) records = content [ 'records' ] buffer_lens = content [ 'buffer_lens' ] result_buffer_lens = content [ 'result_buffer_lens' ] buffers = msg [ 'buffers' ] has_bufs = buffer_lens is not None has_rbufs = result_buffer_lens is not None for i , rec in enumerate ( records ) : # relink buffers if has_bufs : blen = buffer_lens [ i ] rec [ 'buffers' ] , buffers = buffers [ : blen ] , buffers [ blen : ] if has_rbufs : blen = result_buffer_lens [ i ] rec [ 'result_buffers' ] , buffers = buffers [ : blen ] , buffers [ blen : ] return records
Query the Hub's TaskRecord database

        This will return a list of task record dicts that match `query`

        Parameters
        ----------

        query : mongodb query dict
            The search dict. See mongodb query docs for details.
        keys : list of strs [optional]
            The subset of keys to be returned.  The default is to fetch everything but buffers.
            'msg_id' will *always* be included.
Query the Hub s TaskRecord database