Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 48d918c

Browse files
authored
always use model.alias for table path (#400)
1 parent 38a85c9 commit 48d918c

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

data_diff/dbt.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -113,12 +113,12 @@ def _get_diff_vars(
113113
prod_schema = config_prod_schema if config_prod_schema else dev_schema
114114

115115
if dbt_parser.requires_upper:
116-
dev_qualified_list = [x.upper() for x in [dev_database, dev_schema, model.name]]
117-
prod_qualified_list = [x.upper() for x in [prod_database, prod_schema, model.name]]
116+
dev_qualified_list = [x.upper() for x in [dev_database, dev_schema, model.alias]]
117+
prod_qualified_list = [x.upper() for x in [prod_database, prod_schema, model.alias]]
118118
primary_keys = [x.upper() for x in primary_keys]
119119
else:
120-
dev_qualified_list = [dev_database, dev_schema, model.name]
121-
prod_qualified_list = [prod_database, prod_schema, model.name]
120+
dev_qualified_list = [dev_database, dev_schema, model.alias]
121+
prod_qualified_list = [prod_database, prod_schema, model.alias]
122122

123123
return DiffVars(dev_qualified_list, prod_qualified_list, primary_keys, datasource_id, dbt_parser.connection)
124124

0 commit comments

Comments
 (0)