Skip to content

Commit

Permalink
[Fix] Update dynamic table metadata queryies to take into account new…
Browse files Browse the repository at this point in the history
… object type. (#937)

* initial push to fix dynamic tables now that they have BASE TABLE as object type
* update to is_dnyamic expected value
* take into account uppercase
  • Loading branch information
McKnight-42 authored Mar 20, 2024
1 parent cd1e873 commit 95ca3bf
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 2 deletions.
7 changes: 7 additions & 0 deletions .changes/unreleased/Fixes-20240320-154054.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
kind: Fixes
body: modify metadata queries to take into account object type of BASE TABLE being
assigned to dynamic tables when was null previously
time: 2024-03-20T15:40:54.074292-05:00
custom:
Author: McKnight-42
Issue: "934"
5 changes: 4 additions & 1 deletion dbt/include/snowflake/macros/catalog.sql
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,10 @@
table_catalog as "table_database",
table_schema as "table_schema",
table_name as "table_name",
coalesce(table_type, 'DYNAMIC TABLE') as "table_type",
case
when is_dynamic = 'YES' and table_type = 'BASE TABLE' THEN 'DYNAMIC TABLE'
else table_type
end as "table_type",
comment as "table_comment",

-- note: this is the _role_ that owns the table
Expand Down
2 changes: 1 addition & 1 deletion tests/functional/adapter/dynamic_table_tests/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,10 +11,10 @@ def query_relation_type(project, relation: SnowflakeRelation) -> Optional[str]:
sql = f"""
select
case
when table_type = 'BASE TABLE' and is_dynamic = 'YES' then 'dynamic_table'
when table_type = 'BASE TABLE' then 'table'
when table_type = 'VIEW' then 'view'
when table_type = 'EXTERNAL TABLE' then 'external_table'
when table_type is null then 'dynamic_table'
end as relation_type
from information_schema.tables
where table_name like '{relation.identifier.upper()}'
Expand Down

0 comments on commit 95ca3bf

Please sign in to comment.