directed-acyclic-graphs - 执行完气流中的所有任务后如何执行任务

Question

我有一个 Airflow DAG，里面有大约 10 个任务。

所以现在，只有在之前执行完所有这 10 个任务之后，我才有另外两个任务要执行。

你能帮我处理这个案子吗？

标签： directed-acyclic-graphsairflow

Answer 1

您可以在 dag 中使用右移运算符指定任务之间的所有依赖关系。

3 个任务的示例（最多 10 个任务）：

[task1, task2, task3] >> final_task

有关更多信息，请参阅此帖子。