airflow.providers.openlineage.extractors.base
¶
Module Contents¶
Classes¶
Structure returned from lineage extraction. |
|
Abstract base extractor class. |
|
Extractor that uses get_openlineage_facets_on_start/complete/failure methods. |
Attributes¶
- class airflow.providers.openlineage.extractors.base.OperatorLineage[source]¶
Bases:
Generic
[DatasetSubclass
,BaseFacetSubclass
]Structure returned from lineage extraction.
- class airflow.providers.openlineage.extractors.base.BaseExtractor(operator)[source]¶
Bases:
abc.ABC
,airflow.utils.log.logging_mixin.LoggingMixin
Abstract base extractor class.
This is used mostly to maintain support for custom extractors.
- class airflow.providers.openlineage.extractors.base.DefaultExtractor(operator)[source]¶
Bases:
BaseExtractor
Extractor that uses get_openlineage_facets_on_start/complete/failure methods.