airflow.providers.openlineage.extractors.manager

Module Contents

Classes

ExtractorManager

Class abstracting management of custom extractors.

Functions

try_import_from_string(string)

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(obj)[source]
validate_task_metadata(task_metadata)[source]

Was this entry helpful?