From e6864ed18cbf748546724f109e56779aadc44e8b Mon Sep 17 00:00:00 2001 From: Noah Stapp Date: Wed, 15 Jan 2025 09:34:29 -0500 Subject: [PATCH] PYTHON-5039 - Always use asyncio.get_running_loop() instead of asyncio.get_event_loop() --- pymongo/network_layer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pymongo/network_layer.py b/pymongo/network_layer.py index 4d21300bc6..c1db31f89c 100644 --- a/pymongo/network_layer.py +++ b/pymongo/network_layer.py @@ -72,7 +72,7 @@ async def async_sendall(sock: Union[socket.socket, _sslConn], buf: bytes) -> None: timeout = sock.gettimeout() sock.settimeout(0.0) - loop = asyncio.get_event_loop() + loop = asyncio.get_running_loop() try: if _HAVE_SSL and isinstance(sock, (SSLSocket, _sslConn)): await asyncio.wait_for(_async_sendall_ssl(sock, buf, loop), timeout=timeout) @@ -259,7 +259,7 @@ async def async_receive_data( timeout = sock_timeout sock.settimeout(0.0) - loop = asyncio.get_event_loop() + loop = asyncio.get_running_loop() cancellation_task = create_task(_poll_cancellation(conn)) try: if _HAVE_SSL and isinstance(sock, (SSLSocket, _sslConn)): @@ -290,7 +290,7 @@ async def async_receive_data_socket( timeout = sock_timeout sock.settimeout(0.0) - loop = asyncio.get_event_loop() + loop = asyncio.get_running_loop() try: if _HAVE_SSL and isinstance(sock, (SSLSocket, _sslConn)): return await asyncio.wait_for(