Help: Time Specific CRON Expressions Seems Not Working

[Atanusaha143]

Description
I'm testing the compatibility of taskiq-faststream for a project and ran into an issue while experimenting with typical CRON use cases. It appears that CRON expressions set to trigger at specific times aren't working as expected.

How to reproduce

from taskiq_faststream import StreamScheduler
from taskiq.schedule_sources import LabelScheduleSource

from app.background_service.subscriber.test_subscriber import broker

from taskiq_faststream import BrokerWrapper

taskiq_broker = BrokerWrapper(broker)

taskiq_broker.task(
    message={"test-schedule": "schedule test running every day at 11:00 PM"},
    subject="test_schedule_subject",
    schedule=[
        {"cron": "00 23 * * *"},  # At 11:00 PM
    ],
)

scheduler = StreamScheduler(
    broker=taskiq_broker,
    sources=[LabelScheduleSource(taskiq_broker)],
)

But the following CRON is working though

taskiq_broker.task(
    message={"task": "schedule test running at every two minute"},
    subject="test_schedule_subject",
    schedule=[
        {"cron": "*/2 * * * *"},  # Runs every two minute
    ],
)

Demo:

Taskiq.specific.time.cron.not.working.mp4

What might be causing CRON expressions specifying exact times to fail in taskiq-faststream? Are there any known limitations or additional configurations required for time-specific scheduling to work as expected?

[s3rius]

It can be that your time offset is not the same with UTC. There's a paragraph about timezones on docs. You can cron_offset to verify that it works.