tests.system.openlineage.example_openlineage_defer_simple_dag

Simple DAG with deferrable operator.

It checks:

  • that at least two task START events (before and after deferral) are emitted and the try_num remains at 1

  • taskInstance’s start_date and duration after the resume: absent on Airflow 3.0 to 3.2.1, where the worker’s start date is the resume time, and present otherwise

Attributes

DAG_ID

wait

test_run

Module Contents

tests.system.openlineage.example_openlineage_defer_simple_dag.DAG_ID = 'openlineage_defer_simple_dag'[source]
tests.system.openlineage.example_openlineage_defer_simple_dag.wait[source]
tests.system.openlineage.example_openlineage_defer_simple_dag.test_run[source]

Was this entry helpful?