ZeroMQ with scheduler doesn't work since 0.11.8

[vunhatchuong]

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:scheduler

Expected 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
Hello

Reality:

Worker doesn't execute task.