Skip to content

Commit 25a9f75

Browse files
feat(ingestion): implement new snowflake config options
1 parent 7a6cd88 commit 25a9f75

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_v2.py

+4-1
Original file line numberDiff line numberDiff line change
@@ -550,10 +550,11 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
550550
len(discovered_tables) == 0
551551
and len(discovered_views) == 0
552552
and len(discovered_streams) == 0
553+
and not self.config.allow_empty_schemas
553554
):
554555
self.structured_reporter.failure(
555556
GENERIC_PERMISSION_ERROR_KEY,
556-
"No tables/views/streams found. Please check permissions.",
557+
"No tables/views found and allow_empty_schemas is false. Please check permissions.",
557558
)
558559
return
559560

@@ -732,6 +733,8 @@ def get_snowsight_url_builder(self) -> Optional[SnowsightUrlBuilder]:
732733
return None
733734

734735
def is_standard_edition(self) -> bool:
736+
if self.config.skip_standard_edition_check:
737+
return False
735738
try:
736739
self.connection.query(SnowflakeQuery.show_tags())
737740
return False

0 commit comments

Comments
 (0)