Use get_running_loop instead of get_event_loop

mongodb · Jan 15, 2025 · f6c0136 · f6c0136
1 parent 882c0db
commit f6c0136
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/pymongo/asynchronous/auth.py b/pymongo/asynchronous/auth.py
@@ -185,7 +185,7 @@ async def _canonicalize_hostname(hostname: str, option: str | bool) -> str:
         return hostname
 
     if not _IS_SYNC:
-        loop = asyncio.get_event_loop()
+        loop = asyncio.get_running_loop()
         af, socktype, proto, canonname, sockaddr = (
             await loop.getaddrinfo(
                 hostname,

diff --git a/pymongo/asynchronous/pool.py b/pymongo/asynchronous/pool.py
@@ -815,7 +815,7 @@ async def _create_connection(address: _Address, options: PoolOptions) -> socket.
 
     err = None
     if not _IS_SYNC:
-        loop = asyncio.get_event_loop()
+        loop = asyncio.get_running_loop()
         results = await loop.getaddrinfo(  # type: ignore[assignment]
             host, port, family=family, type=socket.SOCK_STREAM
         )

diff --git a/pymongo/synchronous/auth.py b/pymongo/synchronous/auth.py
@@ -182,7 +182,7 @@ def _canonicalize_hostname(hostname: str, option: str | bool) -> str:
         return hostname
 
     if not _IS_SYNC:
-        loop = asyncio.get_event_loop()
+        loop = asyncio.get_running_loop()
         af, socktype, proto, canonname, sockaddr = (
             loop.getaddrinfo(
                 hostname,

diff --git a/pymongo/synchronous/pool.py b/pymongo/synchronous/pool.py
@@ -813,7 +813,7 @@ def _create_connection(address: _Address, options: PoolOptions) -> socket.socket
 
     err = None
     if not _IS_SYNC:
-        loop = asyncio.get_event_loop()
+        loop = asyncio.get_running_loop()
         results = loop.getaddrinfo(  # type: ignore[assignment]
             host, port, family=family, type=socket.SOCK_STREAM
         )