(self, node_name)
return res
Fetch consumer list from a node.
Fetch consumer list from a node.
Fetch consumer list from a node .
def get_node_consumer_map(self, node_name):
        """Fetch consumer list from a node."""
        q = "select consumer_name, provider_node, last_tick_id from pgq_node.get_consumer_info(%s)"
        db = self.get_node_database(node_name)
        rows = self.exec_query(db, q, [self.queue_name])
        res = {}
        for r in rows:
            res[r['consumer_name']] = r
        return res
def get_node_consumer_map ( self , node_name ) : q = "select consumer_name, provider_node, last_tick_id from pgq_node.get_consumer_info(%s)" db = self . get_node_database ( node_name ) rows = self . exec_query ( db , q , [ self . queue_name ] ) res = { } for r in rows : res [ r [ 'consumer_name' ] ] = r return res