CRON Job Overlapping Tasks Issue

[Atanusaha143]

I am using taskiq-faststream and encountering an issue with a CRON job scheduled using the following expression:

*/5 * * * *

Here is the scheduler setup I’m using:

from app.core.broker.nats_broker import taskiq_broker
from app.dependency import settings_helper


async def handle_schedulet():
    return {"message": "handle_schedulet"}


taskiq_broker.task(message=handle_schedulet,
                   subject=settings_helper.NATS_SUBJECT,
                   schedule=[{"cron": settings_helper.NATS_SCHEDULER_CRON}])

This is supposed to execute the task every 5 minutes, and while it works as expected initially, I’ve observed an unusual behavior:

• The task runs correctly every 5 minutes.
• However, at the 6th minute, multiple instances of the task are triggered again, even though they shouldn't.

While searching for a solution, I came across this PR.
Does this PR address the issue I’m experiencing? If so, has the fix been applied to taskiq-faststream as well?

Any insights would be greatly appreciated!