(self, db)
return qinf
Non-cached set info lookup.
Non-cached set info lookup.
Non - cached set info lookup .
def load_queue_info(self, db):
        """Non-cached set info lookup."""
        res = self.exec_query(db, "select * from pgq_node.get_node_info(%s)", [self.queue_name])
        info = res[0]

        q = "select * from pgq_node.get_queue_locations(%s)"
        member_list = self.exec_query(db, q, [self.queue_name])

        qinf = QueueInfo(self.queue_name, info, member_list)
        if self.options.dead:
            for node in self.options.dead:
                self.log.info("Assuming node '%s' as dead", node)
                qinf.tag_dead(node)
        return qinf
def load_queue_info ( self , db ) : res = self . exec_query ( db , "select * from pgq_node.get_node_info(%s)" , [ self . queue_name ] ) info = res [ 0 ] q = "select * from pgq_node.get_queue_locations(%s)" member_list = self . exec_query ( db , q , [ self . queue_name ] ) qinf = QueueInfo ( self . queue_name , info , member_list ) if self . options . dead : for node in self . options . dead : self . log . info ( "Assuming node '%s' as dead" , node ) qinf . tag_dead ( node ) return qinf