Celery, calling delay with countdown

Question

I'm trying to understand how celery works

In my django application in tasks.py file I have created one task:

@celery.shared_task(default_retry_delay=2 * 60, max_retries=2)
def my_task(param1, param2):
    # There are some operations

I call this task by using this code:

my_task.delay(param1, param2)

Inside of this my_task there is one condition where this task should be started again but after one minute delay

I have found that there are some kind of ETA and countdown for tasks, but their examples are only with apply_async

Is it possible to use some kind countdown for delay?

Answer 1

From basic part of celery Calling documentation

delay(*args, **kwargs)

Shortcut to send a task message, but doesn’t support execution options.

So delay is clearly convenient, but if you want to set additional execution options you have to use apply_async.

As documentation states delay cannot be used with additional options set so you should just convert your call into apply_async

If you want to add execution options, the docs suggest you use a signature. e.g:

my_task.s(arg1, arg2).apply_async(countdown=60)