Skip to content
This repository has been archived by the owner on Jan 27, 2025. It is now read-only.

Commit

Permalink
fix(ingest/snowflake): support domains for snowflake schema containers (
Browse files Browse the repository at this point in the history
  • Loading branch information
hsheth2 authored and cccs-Dustin committed Feb 1, 2023
1 parent f3935b4 commit f9e0d82
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -922,6 +922,8 @@ def gen_database_containers(
def gen_schema_containers(
self, schema: SnowflakeSchema, db_name: str
) -> Iterable[MetadataWorkUnit]:
domain_urn = self._gen_domain_urn(f"{db_name}.{schema.name}")

schema_container_key = self.gen_schema_key(
self.snowflake_identifier(db_name),
self.snowflake_identifier(schema.name),
Expand All @@ -939,6 +941,7 @@ def gen_schema_containers(
description=schema.comment,
sub_types=[SqlContainerSubTypes.SCHEMA],
parent_container_key=database_container_key,
domain_urn=domain_urn,
external_url=self.get_external_url_for_schema(schema.name, db_name)
if self.config.include_external_url
else None,
Expand Down

0 comments on commit f9e0d82

Please sign in to comment.