airflow.providers.openlineage.extractors.bash¶

Classes¶

BashExtractor

Extract executed bash command and put it into SourceCodeJobFacet.

Module Contents¶

class airflow.providers.openlineage.extractors.bash.BashExtractor(operator)[source]¶

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

Extract executed bash command and put it into SourceCodeJobFacet.

This extractor provides visibility on what bash task does by extracting executed bash command and putting it into SourceCodeJobFacet. It does not extract datasets.

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.

extract()[source]¶