问题说明

我正在尝试了解 celery 是如何工作的

在tasks.py文件中的Django应用程序中，我创建了一个任务：

@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使用某种倒计时？

正确答案

发件人basic part of celery Calling documentation

delay(*args, **kwargs)

发送任务消息的快捷方式，但不支持执行 选项。 因此延迟显然很方便，但是如果您想要设置其他 您必须使用的执行选项Apply_Async。

AS文档声明delay不能在设置其他选项的情况下使用，因此您只需将您的呼叫转换为apply_async

如果要添加执行选项，文档建议您使用签名。例如：

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