我有两个任务- a 和 b 。
任务 a 在完成上一个任务 a 后的5分钟内运行。
Task a running in 5 minutes after finish previous task a.
任务 b 在完成上一个任务 b 后的3分钟内运行。
Task b running in 3 minutes after finish previous task b.
如何实施?我正在使用 python 3.6.8 , Django 2.2.6 和 celery 4.3.0 ?
How can I implement it? I'm use python 3.6.8, Django 2.2.6 and celery 4.3.0?
推荐答案简短的答案是您不能用芹菜拍子做这件事,因为芹菜拍子将触发任务开始而不是任务结束。如果绝对需要在上一个任务结束后三分钟执行此操作,建议您在两个<$ c $的末尾添加对 .apply_async 的调用c> a 和 b 并启动每个任务一次。
The short answer is that you can't do this with celery beat because celery beat will trigger off of task start and not at task end. If you absolutely need to do it three minutes after the previous task ends, you'd be advised to just adding a call to .apply_async at the end of both a and b and kicking off each task once.
更多推荐
使用celery
发布评论