Schedule a function to run at a specific time with taskiq-faststream

[Atanusaha143]

Can I do something like below?

@taskiq_broker.task(
    schedule=[{"cron": "* * * * *"}],  # Runs every minute
)
async def my_scheduled_task():
    print("do something")

Or any other way to run a function at a specific time?

NOTE: I don't want to use any broker

[Lancetnik]

You should check the taskiq documentation to watch all its' features and API. FastStream is just a publisher in this integration, no more