Skip to content

Commit dba02f0

Browse files
committed
chore: add one more noqa for C901
1 parent f885cf4 commit dba02f0

2 files changed

Lines changed: 16 additions & 6 deletions

File tree

‎taskiq/cli/scheduler/run.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,7 @@ def _is_schedule_ready_to_send(
313313

314314
return is_ready_to_send
315315

316-
async def run(
316+
async def run( # noqa: C901
317317
self,
318318
*,
319319
update_interval: timedelta | None = None,

‎tests/cli/scheduler/test_send_with_timeout.py‎

Lines changed: 15 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,9 @@ def __init__(self, hang_seconds: float = 60.0) -> None:
3131
self.on_ready_calls = 0
3232

3333
async def on_ready( # type: ignore[override]
34-
self, source: ScheduleSource, task: ScheduledTask
34+
self,
35+
source: ScheduleSource,
36+
task: ScheduledTask,
3537
) -> None:
3638
self.on_ready_calls += 1
3739
await asyncio.sleep(self.hang_seconds)
@@ -98,7 +100,9 @@ def __init__(self) -> None:
98100
self.calls = 0
99101

100102
async def on_ready( # type: ignore[override]
101-
self, source: ScheduleSource, task: ScheduledTask
103+
self,
104+
source: ScheduleSource,
105+
task: ScheduledTask,
102106
) -> None:
103107
self.calls += 1
104108

@@ -131,7 +135,9 @@ def __init__(self) -> None:
131135
super().__init__(broker=InMemoryBroker(), sources=[_StubSource()])
132136

133137
async def on_ready( # type: ignore[override]
134-
self, source: ScheduleSource, task: ScheduledTask
138+
self,
139+
source: ScheduleSource,
140+
task: ScheduledTask,
135141
) -> None:
136142
raise RuntimeError("boom")
137143

@@ -153,7 +159,9 @@ def __init__(self) -> None:
153159
super().__init__(broker=InMemoryBroker(), sources=[_StubSource()])
154160

155161
async def on_ready( # type: ignore[override]
156-
self, source: ScheduleSource, task: ScheduledTask
162+
self,
163+
source: ScheduleSource,
164+
task: ScheduledTask,
157165
) -> None:
158166
try:
159167
await asyncio.sleep(30.0)
@@ -184,7 +192,9 @@ def __init__(self) -> None:
184192
self.calls: list[Any] = []
185193

186194
async def on_ready( # type: ignore[override]
187-
self, source: ScheduleSource, task: ScheduledTask
195+
self,
196+
source: ScheduleSource,
197+
task: ScheduledTask,
188198
) -> None:
189199
self.calls.append((source, task))
190200

0 commit comments

Comments
 (0)