FIxed tests.

s3rius · s3rius · commit 88b97b427c46 · 2025-03-31T22:59:34.000+02:00
diff --git a/taskiq/cli/scheduler/run.py b/taskiq/cli/scheduler/run.py
@@ -174,7 +174,7 @@ async def run_scheduler_loop(scheduler: TaskiqScheduler) -> None:
                     continue
                 if task_delay is not None:
                     send_task = loop.create_task(
-                        delayed_send(scheduler, source, task, 1),
+                        delayed_send(scheduler, source, task, task_delay),
                     )
                     running_schedules.add(send_task)
                     send_task.add_done_callback(running_schedules.discard)

Original file line number	Diff line number	Diff line change
`@@ -174,7 +174,7 @@ async def run_scheduler_loop(scheduler: TaskiqScheduler) -> None:`
`174`	`174`	`continue`
`175`	`175`	`if task_delay is not None:`
`176`	`176`	`send_task = loop.create_task(`
`177`		`- delayed_send(scheduler, source, task, 1),`
	`177`	`+ delayed_send(scheduler, source, task, task_delay),`
`178`	`178`	`)`
`179`	`179`	`running_schedules.add(send_task)`
`180`	`180`	`send_task.add_done_callback(running_schedules.discard)`