如何在 Airflow 中组合多个 DAG

mat*_*c-7 1 python directed-acyclic-graphs python-3.x airflow

我真的需要知道如何使用 Airflow 让多个 DAG 相互调用(例如DAG_1 >> DAG_2),类似于它如何使用上游/下游运算符在 DAG 中运行任务。我需要知道如何设置这使气流运行DAG_1,然后将运行DAG_2一次,DAG_1已成功完成。

最好我希望在 Airflow dag文件夹中拥有DAG_1DAG_2单独的文件,然后要么在运行开始时将调用作为前一步,要么有一个单独的“主”DAG,它创建并运行每个任务所在的 DAG另一个 DAG 而不是任务操作符。DAG_2DAG_1

如果有人知道如何做到这一点,请告诉我,我真的需要一些帮助。如果有人知道如何做到这一点,我也将接受在同一个文件中制作和连接两个单独的 DAG,但最好将链接的 DAG 放在不同的文件中。

预先感谢您的帮助。