airflow.providers.openlineage.plugins.facets

Module Contents

Classes

AirflowMappedTaskRunFacet

Run facet containing information about mapped tasks.

AirflowRunFacet

Composite Airflow run facet.

UnknownOperatorInstance

Describes an unknown operator.

UnknownOperatorAttributeRunFacet

RunFacet that describes unknown operators in an Airflow DAG.
class airflow.providers.openlineage.plugins.facets.AirflowMappedTaskRunFacet[source]

Bases: openlineage.client.facet.BaseFacet

Run facet containing information about mapped tasks.

mapIndex: int[source]
operatorClass: str[source]
classmethod from_task_instance(task_instance)[source]
class airflow.providers.openlineage.plugins.facets.AirflowRunFacet[source]

Bases: openlineage.client.facet.BaseFacet

Composite Airflow run facet.

dag: dict[source]
dagRun: dict[source]
task: dict[source]
taskInstance: dict[source]
taskUuid: str[source]
class airflow.providers.openlineage.plugins.facets.UnknownOperatorInstance[source]

Bases: openlineage.client.utils.RedactMixin

Describes an unknown operator.

This specifies the (class) name of the operator and its properties.

name: str[source]
properties: dict[str, object][source]
type: str = 'operator'[source]
class airflow.providers.openlineage.plugins.facets.UnknownOperatorAttributeRunFacet[source]

Bases: openlineage.client.facet.BaseFacet

RunFacet that describes unknown operators in an Airflow DAG.

unknownItems: list[UnknownOperatorInstance][source]

Was this entry helpful?