Airflow find DAG Runs with specific conf

Question

我正在使用 apache-airflow 1.10.10。

我的用例是：我有 4 个 DAG，经过一些工作后，它们都使用 BashOperator 触发了一个名为 "dag_common" 的通用 DAG，具有不同的 conf 参数。

airflow trigger_dag -c {"id":"1"} dag_common

airflow trigger_dag -c {"id":"2"} dag_common

airflow trigger_dag -c {"id":"3"} dag_common

airflow trigger_dag -c {"id":"4"} dag_common

在这些 DAG 中，我必须等待触发的 DAG 完成，我该如何完成？

Dag1 必须等到使用 conf id=1 完成 dag_common。 有什么方法可以找到所有具有特定 conf 的 dag 运行？

Answer 1

这看起来像是SubDAGs 的用例：将dag_common 实现为子DAG，并在这四个DAG 中使用SubDagOperator() 来运行dag_common。