芹菜倒计时设置了过去



我有一个芹菜任务,我用倒计时关键字调用它。

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]

如您所见,预计到达时间是在当前时间之前设置的!

我使用芹菜 3.1。

我实际上并没有使用芹菜,但从 API 来看,countdown 是Task.apply_async或 Task.retry 的关键字参数。 它不是仅用@task装饰的函数的关键字

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

相关内容

  • 没有找到相关文章

最新更新