Skip to content

Commit e33b9c4

Browse files
committed
fix linters
1 parent 1bcb726 commit e33b9c4

File tree

1 file changed

+4
-11
lines changed

1 file changed

+4
-11
lines changed

ydb/_topic_writer/topic_writer_asyncio.py

Lines changed: 4 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -367,14 +367,10 @@ async def _connection_loop(self):
367367

368368
self._stream_connected.set()
369369

370-
send_loop = topic_common.wrap_create_asyncio_task(
371-
self._send_loop,
372-
"writer send loop",
373-
stream_writer,
374-
)
370+
send_loop = topic_common.wrap_create_asyncio_task(self._send_loop, "writer send loop", stream_writer)
375371
receive_loop = topic_common.wrap_create_asyncio_task(
376-
self._read_loop,
377-
"writer receive loop",
372+
self._read_loop,
373+
"writer receive loop",
378374
stream_writer,
379375
)
380376

@@ -662,10 +658,7 @@ async def _start(self, stream: IGrpcWrapperAsyncIO, init_message: StreamWriteMes
662658

663659
if self._update_token_interval is not None:
664660
self._update_token_event.set()
665-
self._update_token_task = topic_common.wrap_create_asyncio_task(
666-
self._update_token_loop,
667-
"update_token_loop",
668-
)
661+
self._update_token_task = topic_common.wrap_create_asyncio_task(self._update_token_loop, "update_token_loop")
669662

670663
@staticmethod
671664
def _ensure_ok(message: WriterMessagesFromServerToClient):

0 commit comments

Comments
 (0)