`astronomer.providers.snowflake.extractors.snowflake`¶

Module Contents¶

Classes¶

SnowflakeAsyncExtractor

This extractor provides visibility on the metadata of a snowflake async operator

class astronomer.providers.snowflake.extractors.snowflake.SnowflakeAsyncExtractor(operator)[source]¶

Bases: openlineage.airflow.extractors.base.BaseExtractor

This extractor provides visibility on the metadata of a snowflake async operator

source_type = 'SNOWFLAKE'¶

default_schema = 'PUBLIC'¶

classmethod get_operator_classnames()[source]¶

Returns the list of operators this extractors works on.

extract()[source]¶

Extract the Metadata from the task returns the TaskMetadata class instance type