Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

tests.system.openlineage.example_openlineage_trigger_dag

Simple DAG that triggers another simple DAG.

It checks:
  • task’s trigger_dag_id

  • DAGRun START and COMPLETE events, for the triggered DAG

Attributes

DAG_ID

trigger_dagrun

do_nothing_task

test_run

Module Contents

tests.system.openlineage.example_openlineage_trigger_dag.DAG_ID = 'openlineage_trigger_dag'[source]
tests.system.openlineage.example_openlineage_trigger_dag.trigger_dagrun[source]
tests.system.openlineage.example_openlineage_trigger_dag.do_nothing_task[source]
tests.system.openlineage.example_openlineage_trigger_dag.test_run[source]

Was this entry helpful?