tests.system.openlineage.example_openlineage_hitl_dag

DAG with all four HITL operator variants (requires Airflow 3.1+).

It checks:

  • AirflowJobFacet.tasks[task_id] includes hitl_summary with subject, options, defaults

  • task START event airflow run facet includes hitl_summary attribute

  • task COMPLETE event is emitted after response_timeout auto-applies defaults

  • ApprovalOperator COMPLETE event has hitl_summary.approved

  • HITLBranchOperator COMPLETE event has hitl_summary.branches_to_execute

  • HITLEntryOperator and base HITLOperator emit correct events

Attributes

DAG_ID

base_hitl

test_run

Module Contents

tests.system.openlineage.example_openlineage_hitl_dag.DAG_ID = 'openlineage_hitl_dag'[source]
tests.system.openlineage.example_openlineage_hitl_dag.base_hitl[source]
tests.system.openlineage.example_openlineage_hitl_dag.test_run[source]

Was this entry helpful?