Skip to content

Commit 66d9725

Browse files
authored
Update topic_reader_asyncio.py
1 parent 036ea0b commit 66d9725

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

ydb/_topic_reader/topic_reader_asyncio.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ async def __aexit__(self, exc_type, exc_val, exc_tb):
8787

8888
def __del__(self):
8989
if not self._closed:
90-
self._loop.create_task(self.close(flush=False), name="close reader")
90+
self._loop.create_task(self.close(flush=False))
9191

9292
async def wait_message(self):
9393
"""
@@ -337,12 +337,12 @@ async def _start(self, stream: IGrpcWrapperAsyncIO, init_message: StreamReadMess
337337

338338
self._update_token_event.set()
339339

340-
self._background_tasks.add(asyncio.create_task(self._read_messages_loop(), name="read_messages_loop"))
341-
self._background_tasks.add(asyncio.create_task(self._decode_batches_loop(), name="decode_batches"))
340+
self._background_tasks.add(asyncio.create_task(self._read_messages_loop()))
341+
self._background_tasks.add(asyncio.create_task(self._decode_batches_loop()))
342342
if self._get_token_function:
343-
self._background_tasks.add(asyncio.create_task(self._update_token_loop(), name="update_token_loop"))
343+
self._background_tasks.add(asyncio.create_task(self._update_token_loop()))
344344
self._background_tasks.add(
345-
asyncio.create_task(self._handle_background_errors(), name="handle_background_errors")
345+
asyncio.create_task(self._handle_background_errors())
346346
)
347347

348348
async def wait_error(self):

0 commit comments

Comments
 (0)