Airflow Summit 2026 is coming August 31 - September 2 in Austin, TX. Register now to secure your spot!

tests.system.openlineage.example_openlineage_policy_source_code_dag

DAG exercising the OpenLineage emission policy authoring API.

Per-task include_source_code=False removes the source code job facet.

Also verifies precedence: extract_operator_metadata=False short-circuits the whole extraction pipeline, so include_source_code=True becomes inert (no source code job facet) on that task.

Attributes

DAG_ID

t_with_src

test_run

Module Contents

tests.system.openlineage.example_openlineage_policy_source_code_dag.DAG_ID = 'openlineage_policy_source_code_dag'[source]
tests.system.openlineage.example_openlineage_policy_source_code_dag.t_with_src[source]
tests.system.openlineage.example_openlineage_policy_source_code_dag.test_run[source]

Was this entry helpful?