Skip to content

Commit d757d83

Browse files
committed
chore: add debug logging for token length and expiry
1 parent 4b5f2b0 commit d757d83

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
@@ -259,6 +259,7 @@ async def connect_async(self, instance_uri: str, driver: str, **kwargs: Any) ->
259259
try:
260260
metadata_partial = partial(
261261
self.metadata_exchange,
262+
instance_uri,
262263
ip_address,
263264
await conn_info.create_ssl_context(),
264265
enable_iam_auth,
@@ -272,7 +273,11 @@ async def connect_async(self, instance_uri: str, driver: str, **kwargs: Any) ->
272273
raise
273274

274275
def metadata_exchange(
275-
self, ip_address: str, ctx: ssl.SSLContext, enable_iam_auth: bool
276+
self,
277+
instance_uri: str,
278+
ip_address: str,
279+
ctx: ssl.SSLContext,
280+
enable_iam_auth: bool,
276281
) -> ssl.SSLSocket:
277282
"""
278283
Sends metadata about the connection prior to the database
@@ -318,6 +323,12 @@ def metadata_exchange(
318323
if not self._db_credentials.token_state == TokenState.FRESH:
319324
self._db_credentials.refresh(requests.Request())
320325

326+
logger.debug(
327+
f"['{instance_uri}']: OAuth2 token used for metadata exchange has "
328+
f"expiration={self._credentials.expiry}, "
329+
f"size={len(self._credentials.token)}"
330+
)
331+
321332
# form metadata exchange request
322333
req = connectorspb.MetadataExchangeRequest(
323334
user_agent=f"{self._client._user_agent}", # type: ignore

0 commit comments

Comments
 (0)