辅助函数，用于根据一些参数生成 DAG 和操作符。
模块内容
函数
subdag(parent_dag_name, child_dag_name, args)
|
生成一个用作子 DAG 的 DAG。 |
-
airflow.example_dags.subdags.subdag.subdag(parent_dag_name, child_dag_name, args)[源代码]
生成一个用作子 DAG 的 DAG。
- 参数
parent_dag_name (str) – 父 DAG 的 ID
child_dag_name (str) – 子 DAG 的 ID
args (dict) – 提供给子 DAG 的默认参数
- 返回
用作子 DAG 的 DAG
- 返回类型
airflow.models.dag.DAG