tests.system.openlineage.example_openlineage_trigger_dag_deferrable

Simple DAG that triggers another simple DAG in deferrable mode.

It checks:

  • task’s trigger_dag_id, trigger_run_id, deferrable attribute

  • DAGRun START and COMPLETE events, for the triggered DAG

  • automatic injection of OL parent and root info to DAGRun conf

  • multiple levels of triggering

Attributes

DAG_ID

trigger_dagrun

trigger_dagrun2

do_nothing_task

test_run

Module Contents

tests.system.openlineage.example_openlineage_trigger_dag_deferrable.DAG_ID = 'openlineage_trigger_dag_deferrable'[source]
tests.system.openlineage.example_openlineage_trigger_dag_deferrable.trigger_dagrun[source]
tests.system.openlineage.example_openlineage_trigger_dag_deferrable.trigger_dagrun2[source]
tests.system.openlineage.example_openlineage_trigger_dag_deferrable.do_nothing_task[source]
tests.system.openlineage.example_openlineage_trigger_dag_deferrable.test_run[source]

Was this entry helpful?