File tree 1 file changed +3
-1
lines changed
metadata-ingestion/src/datahub/ingestion/source/snowflake
1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -520,7 +520,7 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
520
520
521
521
schema_resolver = self .aggregator ._schema_resolver
522
522
523
- queries_extractor : SnowflakeQueriesExtractor = SnowflakeQueriesExtractor (
523
+ queries_extractor = SnowflakeQueriesExtractor (
524
524
connection = self .connection ,
525
525
config = SnowflakeQueriesExtractorConfig (
526
526
window = self .config ,
@@ -553,6 +553,8 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
553
553
discovered_views = discovered_views ,
554
554
)
555
555
556
+ # This would emit view and external table ddl lineage
557
+ # as well as query lineage via lineage_extractor
556
558
for mcp in self .aggregator .gen_metadata ():
557
559
yield mcp .as_workunit ()
558
560
You can’t perform that action at this time.
0 commit comments