Update topic_reader_asyncio.py

ydb-platform · Sep 25, 2024 · c5e3a64 · c5e3a64
1 parent 8767bd3
commit c5e3a64
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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):