Skip to content

Commit 036ea0b

Browse files
authored
Update topic_writer_asyncio.py
1 parent 8928b00 commit 036ea0b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ydb/_topic_writer/topic_writer_asyncio.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -366,8 +366,8 @@ async def _connection_loop(self):
366366

367367
self._stream_connected.set()
368368

369-
send_loop = asyncio.create_task(self._send_loop(stream_writer), name="writer send loop")
370-
receive_loop = asyncio.create_task(self._read_loop(stream_writer), name="writer receive loop")
369+
send_loop = asyncio.create_task(self._send_loop(stream_writer))
370+
receive_loop = asyncio.create_task(self._read_loop(stream_writer))
371371

372372
tasks = [send_loop, receive_loop]
373373
done, _ = await asyncio.wait([send_loop, receive_loop], return_when=asyncio.FIRST_COMPLETED)
@@ -653,7 +653,7 @@ async def _start(self, stream: IGrpcWrapperAsyncIO, init_message: StreamWriteMes
653653

654654
if self._update_token_interval is not None:
655655
self._update_token_event.set()
656-
self._update_token_task = asyncio.create_task(self._update_token_loop(), name="update_token_loop")
656+
self._update_token_task = asyncio.create_task(self._update_token_loop())
657657

658658
@staticmethod
659659
def _ensure_ok(message: WriterMessagesFromServerToClient):

0 commit comments

Comments
 (0)