3

我有这些 Dags DAG_A(每天运行)、DAG_B(周一至周五运行)和 DAG_C(周六和周日运行),其中 DAG_A 依赖于 DAG_B 和 DAG_C。我尝试使用外部任务传感器设置依赖关系,但每次我的调度程序停止运行并且任何 Dags 都没有成功

4

1 回答 1

0

您可以尝试使用 TriggerDagRunOperator 从另一个 DAG 调用一个 DAG。

详细信息可以在 operator TriggerDagRunOperator Airflow 文档中找到。

https://airflow.apache.org/docs/stable/_api/airflow/operators/dagrun_operator/index.html#airflow.operators.dagrun_operator.TriggerDagRunOperator

当他们完成运行时,从 DAG_B 和 DAG_C 调用 DAG_A。

于 2020-05-31T11:50:09.813 回答