Skip to content

Commit f4d3bcc

Browse files
committed
fix linters
1 parent 34e2a0a commit f4d3bcc

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

ydb/_topic_common/common.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,10 +30,10 @@ def wrapper(rpc_state, response_pb, driver=None):
3030
return wrapper
3131

3232

33-
def wrap_create_asyncio_task(func: typing.Callable, *args, **kwargs, task_name: str):
33+
def wrap_create_asyncio_task(func: typing.Callable, task_name: str, *args, **kwargs):
3434
if sys.hexversion < 0x03080000:
3535
return asyncio.create_task(func(*args, **kwargs))
36-
return asyncio.create_task(func(*args, **kwargs), task_name=loop_name)
36+
return asyncio.create_task(func(*args, **kwargs), name=task_name)
3737

3838

3939
_shared_event_loop_lock = threading.Lock()

ydb/_topic_writer/topic_writer_asyncio.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -368,10 +368,10 @@ async def _connection_loop(self):
368368
self._stream_connected.set()
369369

370370
send_loop = topic_common.wrap_create_asyncio_task(
371-
self._send_loop, stream_writer, task_name="writer send loop",
371+
self._send_loop, task_name="writer send loop", stream_writer,
372372
)
373373
receive_loop = topic_common.wrap_create_asyncio_task(
374-
self._read_loop, stream_writer, task_name="writer receive loop",
374+
self._read_loop, task_name="writer receive loop", stream_writer,
375375
)
376376

377377
tasks = [send_loop, receive_loop]

0 commit comments

Comments
 (0)