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

tests.system.openlineage.example_openlineage_versioned_dag

Simple DAG to verify version attributes for AF3. This DAG should only be run when versioned DagBundle is present.

It checks:
  • DagRun version related attributes

  • TaskInstance version related attributes

Attributes

DAG_ID

do_nothing_task

test_run

Functions

do_nothing()

Module Contents

tests.system.openlineage.example_openlineage_versioned_dag.do_nothing()[source]
tests.system.openlineage.example_openlineage_versioned_dag.DAG_ID = 'openlineage_versioned_dag'[source]
tests.system.openlineage.example_openlineage_versioned_dag.do_nothing_task[source]
tests.system.openlineage.example_openlineage_versioned_dag.test_run[source]

Was this entry helpful?