in google/cloud/alloydb/connector/async_connector.py [0:0]
def get_authentication_token() -> str:
"""Get OAuth2 access token to be used for IAM database authentication"""
# refresh credentials if expired
if not self._credentials.valid:
request = google.auth.transport.requests.Request()
self._credentials.refresh(request)
return self._credentials.token