From 1bcb7262f8572029907065d9ebb254f4d399f018 Mon Sep 17 00:00:00 2001 From: Alexander <56935749+alex2211-put@users.noreply.github.com> Date: Wed, 25 Sep 2024 16:32:40 +0000 Subject: [PATCH] fix linters --- ydb/_topic_writer/topic_writer_asyncio.py | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) 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