Update topic_reader_asyncio.py

ydb-platform · Sep 23, 2024 · 2d5c288 · 2d5c288
1 parent 8c18767
commit 2d5c288
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
@@ -341,7 +341,7 @@ async def _start(self, stream: IGrpcWrapperAsyncIO, init_message: StreamReadMess
         self._background_tasks.add(asyncio.create_task(self._decode_batches_loop()))
         if self._get_token_function:
             self._background_tasks.add(asyncio.create_task(self._update_token_loop()))
-            self._background_tasks.add(asyncio.create_task(self._handle_background_errors()))
+        self._background_tasks.add(asyncio.create_task(self._handle_background_errors()))
 
     async def wait_error(self):
         raise await self._first_error