Update metadata-ingestion/src/datahub/ingestion/source/snowflake/snow…

…flake_schema_gen.py Co-authored-by: Mayuri Nehate <[email protected]>
datahub-project · Jan 24, 2025 · f46a418 · f46a418
1 parent 13bb2ec
commit f46a418
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_schema_gen.py b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_schema_gen.py
@@ -531,7 +531,7 @@ def _process_streams(
         for stream in streams:
             yield from self._process_stream(stream, snowflake_schema, db_name)
 
-    def _process_tags_in_schema(self, snowflake_schema):
+    def _process_tags_in_schema(self, snowflake_schema:SnowflakeSchema) -> Iterable[MetadataWorkUnit]:
         for tag in snowflake_schema.tags:
             yield from self._process_tag(tag)