`airflow.providers.openlineage.extractors.manager`¶

Module Contents¶

Class abstracting management of custom extractors.

airflow.providers.openlineage.extractors.manager.try_import_from_string(string)[source]¶

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

Bases: airflow.utils.log.logging_mixin.LoggingMixin

Class abstracting management of custom extractors.

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]¶

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]¶