airflow.providers.openlineage.plugins.macros

Module Contents

Functions

lineage_run_id(task_instance)

Macro function which returns the generated run id for a given task.

lineage_parent_id(run_id, task_instance)

Macro function which returns the generated job and run id for a given task.
airflow.providers.openlineage.plugins.macros.lineage_run_id(task_instance)[source]

Macro function which returns the generated run id for a given task.

This can be used to forward the run id from a task to a child run so the job hierarchy is preserved.

See also

For more information on how to use this operator, take a look at the guide: OpenLineage Macros

airflow.providers.openlineage.plugins.macros.lineage_parent_id(run_id, task_instance)[source]

Macro function which returns the generated job and run id for a given task.

This can be used to forward the ids from a task to a child run so the job hierarchy is preserved. Child run can create ParentRunFacet from those ids.

See also

For more information on how to use this macro, take a look at the guide: OpenLineage Macros

Was this entry helpful?