From c5e3a6408ed4e62189da9a2e0ee80f3d0781d5ef Mon Sep 17 00:00:00 2001 From: Alexander <56935749+alex2211-put@users.noreply.github.com> Date: Wed, 25 Sep 2024 11:29:28 +0300 Subject: [PATCH] Update topic_reader_asyncio.py --- 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 a118deb0..e871e549 100644 --- a/ydb/_topic_reader/topic_reader_asyncio.py +++ b/ydb/_topic_reader/topic_reader_asyncio.py @@ -169,7 +169,7 @@ def __init__(self, driver: Driver, settings: topic_reader.PublicReaderSettings): self._state_changed = asyncio.Event() self._stream_reader = None - self._background_tasks.add(asyncio.create_task(self._connection_loop() )) + self._background_tasks.add(asyncio.create_task(self._connection_loop())) self._first_error = asyncio.get_running_loop().create_future() async def _connection_loop(self):