Skip to content

Commit b3b5cdf

Browse files
committed
feat(ingest/snowflake): speed up snowflake usage query
1 parent ef3a814 commit b3b5cdf

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

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

+1
Original file line numberDiff line numberDiff line change
@@ -594,6 +594,7 @@ def usage_per_object_per_time_bucket_for_time_window(
594594
snowflake.account_usage.access_history
595595
LEFT JOIN
596596
snowflake.account_usage.users USERS
597+
ON access_history.user_name = users.name
597598
WHERE
598599
query_start_time >= to_timestamp_ltz({start_time_millis}, 3)
599600
AND query_start_time < to_timestamp_ltz({end_time_millis}, 3)

0 commit comments

Comments
 (0)