fix linters

ydb-platform · Sep 25, 2024 · 1bcb726 · 1bcb726
1 parent a779513
commit 1bcb726
Showing 1 changed file with 10 additions and 5 deletions.
diff --git 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