@@ -85,7 +85,7 @@ def __init__(
8585 self ._client = client if client else alloydb_v1beta .AlloyDBAdminAsyncClient (
8686 credentials = credentials ,
8787 client_options = ClientOptions (
88- api_endpoint = alloydb_api_endpoint ,
88+ api_endpoint = "alloydb.googleapis.com" ,
8989 quota_project_id = quota_project ,
9090 ),
9191 client_info = ClientInfo (
@@ -123,11 +123,10 @@ async def _get_metadata(
123123 Returns:
124124 dict: IP addresses of the AlloyDB instance.
125125 """
126- parent = f"{ self . _alloydb_api_endpoint } / { API_VERSION } / projects/{ project } /locations/{ region } /clusters/{ cluster } /instances/{ name } "
126+ parent = f"projects/{ project } /locations/{ region } /clusters/{ cluster } /instances/{ name } "
127127
128128 req = alloydb_v1beta .GetConnectionInfoRequest (parent = parent )
129129 resp = await self ._client .get_connection_info (request = req )
130- resp = await resp
131130 # # try to get response json for better error message
132131 # try:
133132 # resp_dict = await resp.json()
@@ -178,7 +177,7 @@ async def _get_client_certificate(
178177 tuple[str, list[str]]: tuple containing the CA certificate
179178 and certificate chain for the AlloyDB instance.
180179 """
181- parent = f"{ self . _alloydb_api_endpoint } / { API_VERSION } / projects/{ project } /locations/{ region } /clusters/{ cluster } "
180+ parent = f"projects/{ project } /locations/{ region } /clusters/{ cluster } "
182181 dur = duration_pb2 .Duration ()
183182 dur .seconds = 3600
184183 req = alloydb_v1beta .GenerateClientCertificateRequest (
@@ -188,7 +187,6 @@ async def _get_client_certificate(
188187 use_metadata_exchange = self ._use_metadata ,
189188 )
190189 resp = await self ._client .generate_client_certificate (request = req )
191- resp = await resp
192190 # # try to get response json for better error message
193191 # try:
194192 # resp_dict = await resp.json()
0 commit comments