我想了解芹菜的工作原理
在我的 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有一个条件需要重新开始该任务但延迟一分钟后
我发现有一些预计到达时间和倒计时 http://docs.celeryproject.org/en/latest/userguide/calling.html#eta-and-countdown对于任务，但他们的例子只是apply_async
是否可以使用某种倒计时delay?
From celery 基本部分调用文档 http://docs.celeryproject.org/en/latest/userguide/calling.html#basics
delay(*args, **kwargs)
发送任务消息的快捷方式，但是不支持执行
选项.
所以延迟显然是方便的，但是如果你想设置额外的
您必须使用的执行选项应用异步.
正如文档所述delay不能与其他选项集一起使用，因此您应该将您的呼叫转换为apply_async
如果您想添加执行选项，文档建议您使用签名。例如：
my_task.s(arg1, arg2).apply_async(countdown=60)
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
