我真的需要知道如何使用 Airflow 让多个 DAG 相互调用(例如 DAG_1 >> DAG_2
),类似于它如何使用上游/下游运算符在 DAG 中运行任务。我需要知道如何进行设置,以便 Airflow 运行 DAG_1
,然后在 DAG_1
成功完成后运行 DAG_2
。
我最好将 DAG_1
和 DAG_2
放在 Airflow dag 文件夹中的单独文件中,然后将 DAG_2
调用 DAG_1
作为其运行开始时的前置步骤,或者有一个单独的“主”DAG,它创建并运行一个 DAG,其中每个任务都是另一个 DAG 而不是任务运算符。
如果有人知道怎么做,请告诉我,我真的需要一些帮助。如果有人知道如何做到这一点,我也将接受在同一文件中制作和连接两个单独的 DAG,但最好将链接的 DAG 放在不同的文件中。
预先感谢您的协助。
最佳答案
你可以使用TriggerDagRunOperator它以 DAG id 作为参数并触发它
看官方例子here
关于python - 如何在 Airflow 中组合多个 DAG,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58065649/