tests.system.openlineage.example_openlineage_trigger_failed_dag

Simple DAG that triggers another simple DAG that fails.

It checks:

  • task’s trigger_dag_id

  • DAGRun START and FAIL events, for the triggered DAG

  • propagation of OL parent and root info from DAGRun conf

  • error message run facet on DAG FAIL event

  • airflow state run facet on DAG FAIL event showing failed state

Attributes

DAG_ID

trigger_dagrun

failing_task

test_run

Module Contents

tests.system.openlineage.example_openlineage_trigger_failed_dag.DAG_ID = 'openlineage_trigger_failed_dag'[source]
tests.system.openlineage.example_openlineage_trigger_failed_dag.trigger_dagrun[source]
tests.system.openlineage.example_openlineage_trigger_failed_dag.failing_task[source]
tests.system.openlineage.example_openlineage_trigger_failed_dag.test_run[source]

Was this entry helpful?