Airflow Summit 2025 将于 10 月 07-09 日举行。立即注册以获取早鸟票!

airflow.example_dags.example_trigger_target_dag

TriggerDagRunOperator 的使用示例。此示例包含 2 个 DAG:1. 第一个 DAG (example_trigger_controller_dag) 包含一个 TriggerDagRunOperator,它将触发第二个 DAG。2. 第二个 DAG (example_trigger_target_dag),将由第一个 DAG 中的 TriggerDagRunOperator 触发。

属性

run_this

函数

run_this_func([dag_run])

打印传递给 DagRun conf 属性的负载“message”。

模块内容

airflow.example_dags.example_trigger_target_dag.run_this_func(dag_run=None)[source]

打印传递给 DagRun conf 属性的负载“message”。

参数:

dag_run – DagRun 对象

airflow.example_dags.example_trigger_target_dag.run_this = None[source]

此条目有帮助吗?