feat: Pass loop to aiohttp client

Author: Uziel Silva

google/cloud/sql/connector/client.py

@@ -58,6 +58,7 @@ def __init__(
         client: Optional[aiohttp.ClientSession] = None,
         driver: Optional[str] = None,
         user_agent: Optional[str] = None,
+        loop: Optional[asyncio.AbstractEventLoop] = None,
     ) -> None:
         """Establishes the client to be used for Cloud SQL Admin API requests.
 
@@ -84,8 +85,7 @@ def __init__(
         }
         if quota_project:
             headers["x-goog-user-project"] = quota_project
-
-        self._client = client if client else aiohttp.ClientSession(headers=headers)
+        self._client = client if client else aiohttp.ClientSession(headers=headers, loop=loop)
         self._credentials = credentials
         if sqladmin_api_endpoint is None:
             self._sqladmin_api_endpoint = DEFAULT_SERVICE_ENDPOINT

google/cloud/sql/connector/connector.py

@@ -371,6 +371,7 @@ def _init_client(self, driver: Optional[str]) -> CloudSQLClient:
                 self._credentials,
                 user_agent=self._user_agent,
                 driver=driver,
+                loop=self._loop
             )
         return self._client
 
@@ -432,6 +433,7 @@ async def connect_async(
                 self._credentials,
                 user_agent=self._user_agent,
                 driver=driver,
+                loop=self._loop
             )
         enable_iam_auth = kwargs.pop("enable_iam_auth", self._enable_iam_auth)
 

tests/system/test_psycopg_connection.py

@@ -58,10 +58,6 @@ async def test_psycopg_connection() -> None:
         await connector.start_unix_socket_proxy_async(
             instance_connection_name,
             unix_socket_path,
-            driver="psycopg",
-            user=user,
-            password=password,
-            db=db,
             ip_type=ip_type,  # can be "public", "private" or "psc"
         )