Update topic_writer_asyncio.py

ydb-platform · Sep 23, 2024 · 7116965 · 7116965
1 parent 66d9725
commit 7116965
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/ydb/_topic_writer/topic_writer_asyncio.py b/ydb/_topic_writer/topic_writer_asyncio.py
@@ -231,8 +231,8 @@ def __init__(self, driver: SupportedDriverType, settings: WriterSettings):
         self._new_messages = asyncio.Queue()
         self._stop_reason = self._loop.create_future()
         self._background_tasks = [
-            asyncio.create_task(self._connection_loop(), name="connection_loop"),
-            asyncio.create_task(self._encode_loop(), name="encode_loop"),
+            asyncio.create_task(self._connection_loop()),
+            asyncio.create_task(self._encode_loop()),
         ]
 
         self._state_changed = asyncio.Event()