我想了解芹菜的工作原理
在我的Django应用程序的tasks.py
文件中,我创建了一个任务:
@celery.shared_task(default_retry_delay=2 * 60, max_retries=2)
def my_task(param1, param2):
# There are some operations
我通过使用以下代码调用此任务:
my_task.delay(param1, param2)
在此my_task
内部,有一种情况应再次启动此任务但经过一分钟的延迟
我发现任务有某种ETA and countdown,但它们的示例仅与apply_async
有关>
是否可以对delay
使用某种倒数计时?
我试图了解celery是如何工作的,在我的Django应用程序task.py文件中,我创建了一个任务:@ celery.shared_task(default_retry_delay = 2 * 60,max_retries = 2)def my_task(param1,param2)。 。