(self, node_name)
return db
Connect to node.
Connect to node.
Connect to node .
def get_node_database(self, node_name):
        """Connect to node."""
        if node_name == self.queue_info.local_node.name:
            db = self.get_database(self.initial_db_name)
        else:
            m = self.queue_info.get_member(node_name)
            if not m:
                self.log.error("get_node_database: cannot resolve %s", node_name)
                sys.exit(1)
            #self.log.info("%s: dead=%s", m.name, m.dead)
            if m.dead:
                return None
            loc = m.location
            db = self.get_database('node.' + node_name, connstr = loc, profile = 'remote')
        return db
def get_node_database ( self , node_name ) : if node_name == self . queue_info . local_node . name : db = self . get_database ( self . initial_db_name ) else : m = self . queue_info . get_member ( node_name ) if not m : self . log . error ( "get_node_database: cannot resolve %s" , node_name ) sys . exit ( 1 ) #self.log.info("%s: dead=%s", m.name, m.dead) if m . dead : return None loc = m . location db = self . get_database ( 'node.' + node_name , connstr = loc , profile = 'remote' ) return db