0

我有一个芹菜任务，我使用 countdown 关键字调用它。

def plan_my_task():
    countdown = some_computation_function()     #result is a positive integer
    res = my_task.apply_async(args=[some_arg], countdown=countdown)

@task
def my_task(some_arg):
    do_something()

在我的登录中看到类似

[2013-11-14 01:22:31,516: INFO/MainProcess] Received task: my_module.my_task[d5d36a59-b88a-43cb-b7ac-bf0737cdab2c] eta:[2013-11-14 01:16:17.513310+01:00]

如您所见，eta 设置在当前时间之前！

我使用芹菜 3.1。

4

1 回答 1

0

我实际上并没有使用 celery，但从API来看，它看起来像是countdownTask.apply_async 或 Task.retry 的关键字参数。它不是刚刚装饰的函数的关键字@task

编辑： 根据这个答案，可能是日志时间是本地时间，而 ETA 时间是 UTC 时间。如果倒计时数以千计，这可能是可能的（给我们几个小时的休息时间，而不是几分钟，它看起来像是直接比较时间）

于 2013-11-13T22:43:13.380 回答