Merge pull request #314 from ydb-platform/aio-writer-del-fix

topic aio writer: fix __del__

ydb/_topic_writer/topic_writer_asyncio.py

@@ -1,6 +1,7 @@
 import asyncio
 import concurrent.futures
 import datetime
+import functools
 import gzip
 import typing
 from collections import deque
@@ -75,7 +76,7 @@ def __del__(self):
         if self._closed or self._loop.is_closed():
             return
 
-        self._loop.call_soon(self.close, False)
+        self._loop.call_soon(functools.partial(self.close, flush=False))
 
     async def close(self, *, flush: bool = True):
         if self._closed:

ydb/_topic_writer/topic_writer_asyncio_test.py

@@ -625,7 +625,7 @@ async def write_with_ack_future(self, messages: typing.List[InternalMessage]):
                 self.messages_writted.set()
                 return futures
 
-        async def close(self):
+        async def close(self, flush: bool):
             pass
 
     @pytest.fixture