taskiq icon indicating copy to clipboard operation
taskiq copied to clipboard

Will intervals be added?

Open kanewi11 opened this issue 1 year ago • 0 comments

How can I implement launching tasks with an interval of less than one minute, for example 10 seconds?

This is necessary in order not to create:

while True:
    await asyncio.sleep(10)
    ...

And do not wrap it in try: ... except ExampleException: ..., so that the task does not crash and does not process the code anymore.

OR:

@broker.task(
    task_name="my_task",
    timeout=10,
)
async def my_task() -> None:
    await async_card_check_payments()


@broker.task(
    task_name="infinity my task",
)
async def infinity_my_task() -> None:
    while True:
        await my_task.kiq()
        await asyncio.sleep(5)

kanewi11 avatar Aug 17 '24 18:08 kanewi11