@@ -450,6 +450,8 @@ async def create_async_connector(
450450 sqladmin_api_endpoint : Optional [str ] = None ,
451451 user_agent : Optional [str ] = None ,
452452 universe_domain : Optional [str ] = None ,
453+ refresh_strategy : str | RefreshStrategy = RefreshStrategy .BACKGROUND ,
454+ resolver : type [DefaultResolver ] | type [DnsResolver ] = DefaultResolver ,
453455) -> Connector :
454456 """Helper function to create Connector object for asyncio connections.
455457
@@ -486,6 +488,21 @@ async def create_async_connector(
486488 Admin API endpoint. Defaults to "https://sqladmin.googleapis.com",
487489 this argument should only be used in development.
488490
491+ universe_domain (str): The universe domain for Cloud SQL API calls.
492+ Default: "googleapis.com".
493+
494+ refresh_strategy (str | RefreshStrategy): The default refresh strategy
495+ used to refresh SSL/TLS cert and instance metadata. Can be one
496+ of the following: RefreshStrategy.LAZY ("LAZY") or
497+ RefreshStrategy.BACKGROUND ("BACKGROUND").
498+ Default: RefreshStrategy.BACKGROUND
499+
500+ resolver (DefaultResolver | DnsResolver): The class name of the
501+ resolver to use for resolving the Cloud SQL instance connection
502+ name. To resolve a DNS record to an instance connection name, use
503+ DnsResolver.
504+ Default: DefaultResolver
505+
489506 Returns:
490507 A Connector instance configured with running event loop.
491508 """
@@ -501,4 +518,7 @@ async def create_async_connector(
501518 quota_project = quota_project ,
502519 sqladmin_api_endpoint = sqladmin_api_endpoint ,
503520 user_agent = user_agent ,
521+ universe_domain = universe_domain ,
522+ refresh_strategy = refresh_strategy ,
523+ resolver = resolver ,
504524 )
0 commit comments