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 屬性的 payload "message"。

屬性

run_this

airflow.example_dags.example_trigger_target_dag.run_this_func(dag_run=None)[原始碼]

印出傳遞給 DagRun conf 屬性的 payload “message”。

參數

dag_run – DagRun 物件

airflow.example_dags.example_trigger_target_dag.run_this[原始碼]

這個條目有幫助嗎？