在特定时间运行Chained Celery任务

Question

如何使用芹菜链式任务，以便第二个任务在特定时间运行，即下午10:04任务1 - >任务2（定于明天上午9点）

Answer 1

找到解决方案以防其他人遇到类似问题

为了在特定时间运行链式任务，您可以使用ETA或倒计时。

e.g tsountdovn

chain(
    task_1.s().set(countdown=10),
    task_2.s().set(countdown=10)
).apply_async()

A.G. Ita

from datetime import datetime 

chain(
  task_1.s(),
  task_2.s().set(eta=datetime.today().replace(hour=9, minute=00))
).apply_async()