延迟执行芹菜任务

Question

我想把一个任务放在芹菜上，但我希望任务在30秒后执行，而不是立即执行。

例如：

@celery.task
def task():
    # waiting 30 seconds
    do something....

我可以用它来制作：sleep(30)，但有更好的解决方案吗？

Answer 1

该任务的最佳方式是在30秒内安排实际任务。类似的东西：

@celery.task
def task():
    RealTask.apply_async(countdown=30)