From 9f1a6277c66d98961d8c8cb93cd67e3c6a5d881f Mon Sep 17 00:00:00 2001 From: Jan Losinski Date: Mon, 17 Jan 2022 21:13:21 +0100 Subject: [PATCH] fix: remove loop argument from asyncio calls The loop parameter was removed in python 3.10 and causes a TypeError there. --- aioelasticsearch/transport.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/aioelasticsearch/transport.py b/aioelasticsearch/transport.py index 8fe11127..0092817c 100644 --- a/aioelasticsearch/transport.py +++ b/aioelasticsearch/transport.py @@ -71,7 +71,7 @@ def __init__( # store all strategies... self.connection_pool_class = connection_pool_class self.connection_class = connection_class - self._connection_pool_lock = asyncio.Lock(loop=self.loop) + self._connection_pool_lock = asyncio.Lock() # ...save kwargs to be passed to the connections self.kwargs = kwargs @@ -219,7 +219,7 @@ async def _initial_sniff_wrapper(): coros.append(self.connection_pool.close()) - await asyncio.gather(*coros, loop=self.loop) + await asyncio.gather(*coros) self._closed = True async def get_connection(self):