Skip to content

Commit 8c18767

Browse files
authored
Update topic_reader_asyncio.py
1 parent 10974e0 commit 8c18767

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ydb/_topic_reader/topic_reader_asyncio.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -341,7 +341,7 @@ async def _start(self, stream: IGrpcWrapperAsyncIO, init_message: StreamReadMess
341341
self._background_tasks.add(asyncio.create_task(self._decode_batches_loop()))
342342
if self._get_token_function:
343343
self._background_tasks.add(asyncio.create_task(self._update_token_loop()))
344-
self._background_tasks.add(asyncio.create_task(self._handle_background_errors()))
344+
self._background_tasks.add(asyncio.create_task(self._handle_background_errors()))
345345

346346
async def wait_error(self):
347347
raise await self._first_error

0 commit comments

Comments
 (0)