Skip to content

Commit 88b3893

Browse files
feat(ingest/snowflake): allow iceberg tables in lineage and access metadata (datahub-project#10961)
1 parent 0927c63 commit 88b3893

File tree

3 files changed

+3
-1
lines changed

3 files changed

+3
-1
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ class SnowflakeObjectDomain(str, Enum):
5252
DATABASE = "database"
5353
SCHEMA = "schema"
5454
COLUMN = "column"
55+
ICEBERG_TABLE = "iceberg table"
5556

5657

5758
GENERIC_PERMISSION_ERROR_KEY = "permission-error"

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@ class SnowflakeQuery:
3535
SnowflakeObjectDomain.EXTERNAL_TABLE.capitalize(),
3636
SnowflakeObjectDomain.VIEW.capitalize(),
3737
SnowflakeObjectDomain.MATERIALIZED_VIEW.capitalize(),
38+
SnowflakeObjectDomain.ICEBERG_TABLE.capitalize(),
3839
}
3940

4041
ACCESS_HISTORY_TABLE_VIEW_DOMAINS_FILTER = "({})".format(

metadata-ingestion/tests/integration/snowflake/common.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@
156156
on basic_usage_counts.bucket_start_time = user_usage_counts.bucket_start_time
157157
and basic_usage_counts.object_name = user_usage_counts.object_name
158158
where
159-
basic_usage_counts.object_domain in ('Table','External table','View','Materialized view')
159+
basic_usage_counts.object_domain in ('Table','External table','View','Materialized view','Iceberg table')
160160
and basic_usage_counts.object_name is not null
161161
group by
162162
basic_usage_counts.object_name,

0 commit comments

Comments
 (0)