airflow.providers.openlineage.extractors.python¶

Classes¶

PythonExtractor

Extract executed source code and put it into SourceCodeJobFacet.

Module Contents¶

class airflow.providers.openlineage.extractors.python.PythonExtractor(operator)[source]¶

Bases: airflow.providers.openlineage.extractors.base.BaseExtractor

Extract executed source code and put it into SourceCodeJobFacet.

This extractor provides visibility on what particular task does by extracting executed source code and putting it into SourceCodeJobFacet. It does not extract datasets yet.

classmethod get_operator_classnames()[source]¶

Get a list of operators that extractor works for.

This is an abstract method that subclasses should implement. There are operators that work very similarly and one extractor can cover.

get_source_code(callable)[source]¶

extract()[source]¶