diff --git a/ydb/_topic_writer/topic_writer_asyncio.py b/ydb/_topic_writer/topic_writer_asyncio.py
index 6608d464..a6983178 100644
--- a/ydb/_topic_writer/topic_writer_asyncio.py
+++ b/ydb/_topic_writer/topic_writer_asyncio.py
@@ -368,11 +368,15 @@ async def _connection_loop(self):
                 self._stream_connected.set()
 
                 send_loop = topic_common.wrap_create_asyncio_task(
-                    self._send_loop, "writer send loop", stream_writer,
-                    )
+                    self._send_loop, 
+                    "writer send loop", 
+                    stream_writer,
+                )
                 receive_loop = topic_common.wrap_create_asyncio_task(
-                    self._read_loop, "writer receive loop", stream_writer,
-                    )
+                    self._read_loop, 
+                    "writer receive loop", 
+                    stream_writer,
+                )
 
                 tasks = [send_loop, receive_loop]
                 done, _ = await asyncio.wait([send_loop, receive_loop], return_when=asyncio.FIRST_COMPLETED)
@@ -659,7 +663,8 @@ async def _start(self, stream: IGrpcWrapperAsyncIO, init_message: StreamWriteMes
         if self._update_token_interval is not None:
             self._update_token_event.set()
             self._update_token_task = topic_common.wrap_create_asyncio_task(
-                self._update_token_loop, "update_token_loop",
+                self._update_token_loop, 
+                "update_token_loop",
             )
 
     @staticmethod