Skip to content

Commit 10974e0

Browse files
authored
Update topic_reader_asyncio.py
fix linters
1 parent 7116965 commit 10974e0

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

ydb/_topic_reader/topic_reader_asyncio.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -341,9 +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(
345-
asyncio.create_task(self._handle_background_errors())
346-
)
344+
self._background_tasks.add(asyncio.create_task(self._handle_background_errors()))
347345

348346
async def wait_error(self):
349347
raise await self._first_error

0 commit comments

Comments
 (0)