Airflow Summit 2025 is coming October 07-09. Register now to secure your spot!

tests.system.openlineage.example_openlineage_taskflow_simple_dag

Simple DAG to verify that DAG defined with taskflow API emits OL events.

It checks:

  • required keys

  • field formats and types

  • number of task events (one start, one complete)

Attributes

DAG_ID

test_run

Functions

openlineage_taskflow_simple_dag()

Module Contents

tests.system.openlineage.example_openlineage_taskflow_simple_dag.DAG_ID = 'openlineage_taskflow_simple_dag'[source]
tests.system.openlineage.example_openlineage_taskflow_simple_dag.openlineage_taskflow_simple_dag()[source]
tests.system.openlineage.example_openlineage_taskflow_simple_dag.test_run[source]

Was this entry helpful?