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_func([dag_run])

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

属性

run_this

airflow.example_dags.example_trigger_target_dag.run_this_func(dag_run=None)[源代码]

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

参数

dag_run – DagRun 对象

airflow.example_dags.example_trigger_target_dag.run_this[源代码]

此条目是否有帮助？