airflow.example_dags.example_trigger_target_dag

Example usage of the TriggerDagRunOperator. This example holds 2 DAGs: 1. 1st DAG (example_trigger_controller_dag) holds a TriggerDagRunOperator, which will trigger the 2nd DAG 2. 2nd DAG (example_trigger_target_dag) which will be triggered by the TriggerDagRunOperator in the 1st DAG

Attributes

run_this

Functions

run_this_func([dag_run])

Print the payload "message" passed to the DagRun conf attribute.

Module Contents

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

Print the payload “message” passed to the DagRun conf attribute.

Parameters:: dag_run – The DagRun object

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