ZeroMQ with scheduler doesn't work since 0.11.8 #401
Description
Version 0.11.7 is the last working release for this code.
from taskiq import TaskiqScheduler, ZeroMQBroker
from taskiq.schedule_sources import LabelScheduleSource
broker = ZeroMQBroker()
scheduler = TaskiqScheduler(
broker=broker,
sources=[LabelScheduleSource(broker)],
)
@broker.task(schedule=[{"cron": "* * * * *"}])
async def hi() -> None:
print("Hello")Then runs:
taskiq worker module:broker -w 1
taskiq scheduler module:schedulerExpected output:
[2025-01-16 16:21:17,802][taskiq.worker][INFO ][MainProcess] Pid of a main process: 91204
[2025-01-16 16:21:17,803][taskiq.worker][INFO ][MainProcess] Starting 1 worker processes.
[2025-01-16 16:21:17,805][taskiq.process-manager][INFO ][MainProcess] Started process worker-0 with pid 91205
[2025-01-16 16:21:17,809][taskiq.receiver.receiver][INFO ][worker-0] Listening started.
[2025-01-16 16:22:00,041][taskiq.receiver.receiver][INFO ][worker-0] Executing task module:hi with ID: a529cfa06fa246e0b3181d7bf468746f
HelloReality:
Worker doesn't execute task.