Skip to content

Commit a3fe93b

Browse files
committed
chore: add debug logging for token length and expiry
1 parent 8598c0b commit a3fe93b

1 file changed

Lines changed: 12 additions & 1 deletion

File tree

google/cloud/alloydbconnector/connector.py

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -240,6 +240,7 @@ async def connect_async(self, instance_uri: str, driver: str, **kwargs: Any) ->
240240
try:
241241
metadata_partial = partial(
242242
self.metadata_exchange,
243+
instance_uri,
243244
ip_address,
244245
await conn_info.create_ssl_context(),
245246
enable_iam_auth,
@@ -253,7 +254,11 @@ async def connect_async(self, instance_uri: str, driver: str, **kwargs: Any) ->
253254
raise
254255

255256
def metadata_exchange(
256-
self, ip_address: str, ctx: ssl.SSLContext, enable_iam_auth: bool
257+
self,
258+
instance_uri: str,
259+
ip_address: str,
260+
ctx: ssl.SSLContext,
261+
enable_iam_auth: bool,
257262
) -> ssl.SSLSocket:
258263
"""
259264
Sends metadata about the connection prior to the database
@@ -299,6 +304,12 @@ def metadata_exchange(
299304
if not self._credentials.token_state == TokenState.FRESH:
300305
self._credentials.refresh(requests.Request())
301306

307+
logger.debug(
308+
f"['{instance_uri}']: OAuth2 token used for metadata exchange has "
309+
f"expiration={self._credentials.expiry}, "
310+
f"size={len(self._credentials.token)}"
311+
)
312+
302313
# form metadata exchange request
303314
req = connectorspb.MetadataExchangeRequest(
304315
user_agent=f"{self._client._user_agent}", # type: ignore

0 commit comments

Comments
 (0)