@@ -231,8 +231,8 @@ def __init__(self, driver: SupportedDriverType, settings: WriterSettings):
231
231
self ._new_messages = asyncio .Queue ()
232
232
self ._stop_reason = self ._loop .create_future ()
233
233
self ._background_tasks = [
234
- asyncio .create_task (self ._connection_loop (), name = "connection_loop" ),
235
- asyncio .create_task (self ._encode_loop (), name = "encode_loop" ),
234
+ asyncio .create_task (self ._connection_loop ()),
235
+ asyncio .create_task (self ._encode_loop ()),
236
236
]
237
237
238
238
self ._state_changed = asyncio .Event ()
@@ -366,8 +366,8 @@ async def _connection_loop(self):
366
366
367
367
self ._stream_connected .set ()
368
368
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 ))
371
371
372
372
tasks = [send_loop , receive_loop ]
373
373
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
653
653
654
654
if self ._update_token_interval is not None :
655
655
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 ())
657
657
658
658
@staticmethod
659
659
def _ensure_ok (message : WriterMessagesFromServerToClient ):
0 commit comments