tests.system.openlineage.example_openlineage_trigger_dag

Simple DAG that triggers another simple DAG.

It checks:

  • task’s trigger_dag_id

  • DAGRun START and COMPLETE events, for the triggered DAG

  • propagation of OL parent and root info, including job types, from DAGRun conf

  • for a Dag triggered with parent and root information whose job types miss a field (a job type needs processingType, integration and jobType), the parent and root of its run and task come from the conf without a jobType facet, and in its task lineage_root_job_type(ti) is None, called directly and rendered through tojson, while lineage_job_type() is still the type of a task

Attributes

DAG_ID

PARTIAL_CHILD_DAG_ID

trigger_dagrun

do_nothing_task

test_run

Functions

check_partial_macros(root_job_type, ti)

Module Contents

tests.system.openlineage.example_openlineage_trigger_dag.DAG_ID = 'openlineage_trigger_dag'[source]
tests.system.openlineage.example_openlineage_trigger_dag.PARTIAL_CHILD_DAG_ID = 'openlineage_trigger_dag_partial_child__notrigger'[source]
tests.system.openlineage.example_openlineage_trigger_dag.check_partial_macros(root_job_type, ti)[source]
tests.system.openlineage.example_openlineage_trigger_dag.trigger_dagrun[source]
tests.system.openlineage.example_openlineage_trigger_dag.do_nothing_task[source]
tests.system.openlineage.example_openlineage_trigger_dag.test_run[source]

Was this entry helpful?