Remove loop arguments from deprecated functions, ready for newer Pyth…

aiologstash/base_handler.py

@@ -33,7 +33,7 @@ def __init__(
         self._thread_id = threading.get_ident()
 
         self._queue: asyncio.Queue[Union[logging.LogRecord, None]] = asyncio.Queue(
-            maxsize=qsize, loop=self._loop
+            maxsize=qsize
         )
 
         super().__init__(level=level)
@@ -113,7 +113,7 @@ async def _reconnect(self) -> None:
                 delay = self._random.gauss(
                     self._reconnect_delay, self._reconnect_jitter
                 )
-                await asyncio.sleep(delay, loop=self._loop)
+                await asyncio.sleep(delay)
 
     def _serialize(self, record: logging.LogRecord) -> bytes:
         for key, value in self._extra.items():

aiologstash/tcp_handler.py

@@ -36,7 +36,7 @@ def __init__(
 
     async def _connect(self) -> None:
         self._reader, self._writer = await asyncio.open_connection(
-            self._host, self._port, loop=self._loop, **self._kwargs
+            self._host, self._port, **self._kwargs
         )
 
     async def _send(self, data: bytes) -> None:
@@ -47,6 +47,6 @@ async def _send(self, data: bytes) -> None:
     async def _disconnect(self) -> None:
         if self._writer is not None:
             self._writer.close()
-            await asyncio.sleep(0, loop=self._loop)  # wait for writer closing
+            await asyncio.sleep(0)  # wait for writer closing
             self._reader = None
             self._writer = None

tests/test_emit.py

@@ -60,7 +60,7 @@ async def coro(record):
 
     m.side_effect = [OSError(), None]
     log.info("Msg 1")
-    await asyncio.sleep(0.1, loop=loop)
+    await asyncio.sleep(0.1)
     m_log.info.assert_has_calls(
         [mock.call("Transport disconnected"), mock.call("Transport reconnected")]
     )