From 74d22c58cdba0bf578bbf80d3c91ebcfecc6e58a Mon Sep 17 00:00:00 2001 From: Gleb Nosov Date: Tue, 25 Jun 2024 17:13:20 +0300 Subject: [PATCH] fix stream_reader close --- ydb/_topic_reader/topic_reader_asyncio.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ydb/_topic_reader/topic_reader_asyncio.py b/ydb/_topic_reader/topic_reader_asyncio.py index 7b3d1cfa..81c6d9f4 100644 --- a/ydb/_topic_reader/topic_reader_asyncio.py +++ b/ydb/_topic_reader/topic_reader_asyncio.py @@ -192,7 +192,7 @@ async def _connection_loop(self): if self._stream_reader is not None: # noinspection PyBroadException try: - await self._stream_reader.close() + await self._stream_reader.close(flush=False) except BaseException: # supress any error on close stream reader pass