(self, node_name)
return NodeInfo(self.queue_name, rows[0])
Non-cached node info lookup.
Non-cached node info lookup.
Non - cached node info lookup .
def load_node_info(self, node_name):
        """Non-cached node info lookup."""
        db = self.get_node_database(node_name)
        if not db:
            self.log.warning('load_node_info(%s): ignoring dead node', node_name)
            return None
        q = "select * from pgq_node.get_node_info(%s)"
        rows = self.exec_query(db, q, [self.queue_name])
        return NodeInfo(self.queue_name, rows[0])
def load_node_info ( self , node_name ) : db = self . get_node_database ( node_name ) if not db : self . log . warning ( 'load_node_info(%s): ignoring dead node' , node_name ) return None q = "select * from pgq_node.get_node_info(%s)" rows = self . exec_query ( db , q , [ self . queue_name ] ) return NodeInfo ( self . queue_name , rows [ 0 ] )