airflow.providers.openlineage.extractors.manager¶

Classes¶

Class abstracting management of custom extractors.

class airflow.providers.openlineage.extractors.manager.ExtractorManager[source]¶

Bases: airflow.utils.log.logging_mixin.LoggingMixin

Class abstracting management of custom extractors.

extractors: dict[str, type[airflow.providers.openlineage.extractors.BaseExtractor]][source]¶

add_extractor(operator_class, extractor)[source]¶

extract_metadata(dagrun, task, complete=False, task_instance=None)[source]¶

get_extractor_class(task)[source]¶

extract_inlets_and_outlets(task_metadata, inlets, outlets)[source]¶

get_hook_lineage()[source]¶

static convert_to_ol_dataset_from_object_storage_uri(uri)[source]¶

static convert_to_ol_dataset_from_table(table)[source]¶

static convert_to_ol_dataset(obj)[source]¶

validate_task_metadata(task_metadata)[source]¶