astronomer.providers.snowflake.extractors.snowflake

Classes

SnowflakeAsyncExtractor

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

Module Contents

class astronomer.providers.snowflake.extractors.snowflake.SnowflakeAsyncExtractor(operator)

Bases: openlineage.airflow.extractors.base.BaseExtractor

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

source_type = 'SNOWFLAKE'

default_schema = 'PUBLIC'

conn: airflow.models.Connection

hook = None

classmethod get_operator_classnames()

Returns the list of operators this extractors works on.

extract()

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