Skip to content

Commit fa1db22

Browse files
committed
fix normalization test
1 parent 46b811b commit fa1db22

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

tests/dbt/test_adapter.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -126,26 +126,30 @@ def test_bigquery_get_columns_in_relation(
126126
def test_normalization(
127127
sushi_test_project: Project, runtime_renderer: t.Callable, mocker: MockerFixture
128128
):
129+
from sqlmesh.core.engine_adapter.base import DataObject, DataObjectType
130+
129131
context = sushi_test_project.context
130132
assert context.target
133+
data_object = DataObject(catalog="test", schema="bla", name="bob", type=DataObjectType.TABLE)
131134

132135
# bla and bob will be normalized to lowercase since the target is duckdb
133136
adapter_mock = mocker.MagicMock()
134137
adapter_mock.default_catalog = "test"
135138
adapter_mock.dialect = "duckdb"
136-
139+
adapter_mock.get_data_object.return_value = data_object
137140
duckdb_renderer = runtime_renderer(context, engine_adapter=adapter_mock)
138141

139142
schema_bla = schema_("bla", "test", quoted=True)
140143
relation_bla_bob = exp.table_("bob", db="bla", catalog="test", quoted=True)
141144

142145
duckdb_renderer("{{ adapter.get_relation(database=None, schema='bla', identifier='bob') }}")
143-
adapter_mock.table_exists.assert_has_calls([call(relation_bla_bob)])
146+
adapter_mock.get_data_object.assert_has_calls([call(relation_bla_bob)])
144147

145148
# bla and bob will be normalized to uppercase since the target is Snowflake, even though the default dialect is duckdb
146149
adapter_mock = mocker.MagicMock()
147150
adapter_mock.default_catalog = "test"
148151
adapter_mock.dialect = "snowflake"
152+
adapter_mock.get_data_object.return_value = data_object
149153
context.target = SnowflakeConfig(
150154
account="test",
151155
user="test",
@@ -160,10 +164,10 @@ def test_normalization(
160164
relation_bla_bob = exp.table_("bob", db="bla", catalog="test", quoted=True)
161165

162166
renderer("{{ adapter.get_relation(database=None, schema='bla', identifier='bob') }}")
163-
adapter_mock.table_exists.assert_has_calls([call(relation_bla_bob)])
167+
adapter_mock.get_data_object.assert_has_calls([call(relation_bla_bob)])
164168

165169
renderer("{{ adapter.get_relation(database='custom_db', schema='bla', identifier='bob') }}")
166-
adapter_mock.table_exists.assert_has_calls(
170+
adapter_mock.get_data_object.assert_has_calls(
167171
[call(exp.table_("bob", db="bla", catalog="custom_db", quoted=True))]
168172
)
169173

0 commit comments

Comments
 (0)