From ccaa3354cf93d8be125903f4026e0689d5ef6920 Mon Sep 17 00:00:00 2001 From: Mayuri N Date: Mon, 23 Dec 2024 13:12:18 +0530 Subject: [PATCH] add comment --- .../src/datahub/ingestion/source/snowflake/snowflake_v2.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_v2.py b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_v2.py index 7b5f8c32d40c5..954e8a29c1a1b 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_v2.py +++ b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_v2.py @@ -520,7 +520,7 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]: schema_resolver = self.aggregator._schema_resolver - queries_extractor: SnowflakeQueriesExtractor = SnowflakeQueriesExtractor( + queries_extractor = SnowflakeQueriesExtractor( connection=self.connection, config=SnowflakeQueriesExtractorConfig( window=self.config, @@ -553,6 +553,8 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]: discovered_views=discovered_views, ) + # This would emit view and external table ddl lineage + # as well as query lineage via lineage_extractor for mcp in self.aggregator.gen_metadata(): yield mcp.as_workunit()