在异步队列中的作业之间添加依赖关系

Question

我正在寻找一个执行异步任务(如 rabbitMQ(的队列，其中可以将新任务添加到队列中，并且只有在以前的任务(依赖于(完成后才会执行。

因此，我正在寻找的 API 是为插入队列的任何任务提供一组标识符，并且当有另一个具有匹配标识符的任务尚未执行时，该任务将不会执行。

有什么可能吗？

Answer 1

您可以使用 celery 的工作流在任务之间创建依赖关系。