

def get_connector_info(self):
    output = self.cluster.exec_cmd_on_host(self.cluster.master, "curl --silent -X POST http://localhost:8080/v1/statement -H 'X-Presto-User:$USER' -H 'X-Presto-Schema:metadata' -H 'X-Presto-Catalog:system' -d 'select catalog_name from catalogs'")
    data = self.get_key_value(output, 'data')
    next_uri = self.get_key_value(output, 'nextUri')
    while ((not data) and next_uri):
        output = self.cluster.exec_cmd_on_host(self.cluster.master, ('curl --silent %s' % self.get_key_value(output, 'nextUri')))
        data = self.get_key_value(output, 'data')
        next_uri = self.get_key_value(output, 'nextUri')
    if (not data):
        raise PrestoError(('Could not get catalogs from json output. Output was: \n%s' % output))
    return data

dataset/ETHPy150Open prestodb/presto-admin/tests/product/test_connectors.py TestConnectors.get_connector_info/original