0

芹菜版本:v4.2.1 + rabbitMQ

当我使用它设置任务apply_asyc时,正在考虑不同的日期时间格式。

now = datetime.datetime.now() + datetime.timedelta(minutes=+5)
RunScheduledScrape.apply_async(args=[program.id,new_task.id],eta=now)

查看下图以了解 UTC 格式的日期时间。

在此处输入图像描述

当我在花中检查这个任务时,它有不同的时间并且任务永远不会执行。

T由于此任务从未执行,因此存在一个介于日期和时间之间的时间。

在此处输入图像描述

即使我尝试更改日期格式并尝试在 ETA 中给出它,但考虑相同的格式。

4

1 回答 1

1

您的 celery 应用程序实例将具有now您应该使用的功能,以便您在 datetime 上设置适当的时区,但为什么不直接调用它countdown呢?

RunScheduledScrape.apply_async(args=[program.id,new_task.id], countdown=300)  
# 300 seconds = 5 minutes
于 2019-01-10T00:36:55.017 回答