芹菜任务成功后的动作

Question

我正在使用 flask 和 celery 以便在后台执行长时间的 ML 任务。任务完成后，他们 return JSON。我需要一种在任务成功后触发另一个功能的方法...我查看了 Celery 文档，但要么我错过了一些东西，要么没有内置功能来执行此操作。提前致谢！

P.S。我正在使用 apply_async 函数来启动任务。

Answer 1

您需要的可以使用 Chord 原语完成。