close reader/writer by del without flush

Author: Valeriya Popova

ydb/_topic_reader/topic_reader_asyncio.py

@@ -75,7 +75,7 @@ async def __aexit__(self, exc_type, exc_val, exc_tb):
 
     def __del__(self):
         if not self._closed:
-            self._loop.create_task(self.close(), name="close reader")
+            self._loop.create_task(self.close(flush=False), name="close reader")
 
     async def receive_batch(
         self,

ydb/_topic_reader/topic_reader_sync.py

@@ -50,7 +50,7 @@ async def create_reader():
         ).result()
 
     def __del__(self):
-        self.close()
+        self.close(flush=False)
 
     def __enter__(self):
         return self
@@ -152,13 +152,13 @@ def async_commit_with_ack(
             self._async_reader.commit_with_ack(mess)
         )
 
-    def close(self, *, timeout: TimeoutType = None):
+    def close(self, *, flush: bool = True, timeout: TimeoutType = None):
         if self._closed:
             return
 
         self._closed = True
 
-        self._caller.safe_call_with_result(self._async_reader.close(), timeout)
+        self._caller.safe_call_with_result(self._async_reader.close(flush), timeout)
 
     def _check_closed(self):
         if self._closed:

ydb/_topic_writer/topic_writer_asyncio.py

@@ -61,7 +61,7 @@ def __del__(self):
         if self._closed or self._loop.is_closed():
             return
 
-        self._loop.call_soon(self.close)
+        self._loop.call_soon(self.close, False)
 
     async def close(self, *, flush: bool = True):
         if self._closed:

ydb/_topic_writer/topic_writer_sync.py

@@ -56,6 +56,9 @@ def __enter__(self):
     def __exit__(self, exc_type, exc_val, exc_tb):
         self.close()
 
+    def __del__(self):
+        self.close(flush=False)
+
     def close(self, *, flush: bool = True, timeout: TimeoutType = None):
         if self._closed:
             return