Skip to content

Commit 03e3429

Browse files
authored
Fix: display_name should not exclude the default catalog when environment_suffix_target is set to CATALOG (#4821)
1 parent 3d0ab45 commit 03e3429

File tree

2 files changed

+27
-5
lines changed

2 files changed

+27
-5
lines changed

sqlmesh/core/snapshot/definition.py

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515

1616
from sqlmesh.core import constants as c
1717
from sqlmesh.core.audit import StandaloneAudit
18+
from sqlmesh.core.environment import EnvironmentSuffixTarget
1819
from sqlmesh.core.macros import call_macro
1920
from sqlmesh.core.model import Model, ModelKindMixin, ModelKindName, ViewKind, CustomKind
2021
from sqlmesh.core.model.definition import _Model
@@ -1589,12 +1590,18 @@ def display_name(
15891590
if snapshot_info_like.is_audit:
15901591
return snapshot_info_like.name
15911592
view_name = exp.to_table(snapshot_info_like.name)
1593+
1594+
catalog = (
1595+
None
1596+
if (
1597+
environment_naming_info.suffix_target != EnvironmentSuffixTarget.CATALOG
1598+
and view_name.catalog == default_catalog
1599+
)
1600+
else view_name.catalog
1601+
)
1602+
15921603
qvn = QualifiedViewName(
1593-
catalog=(
1594-
view_name.catalog
1595-
if view_name.catalog and view_name.catalog != default_catalog
1596-
else None
1597-
),
1604+
catalog=catalog,
15981605
schema_name=view_name.db or None,
15991606
table=view_name.name,
16001607
)

tests/core/test_snapshot.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2178,6 +2178,21 @@ def test_deployability_index_missing_parent(make_snapshot):
21782178
"snowflake",
21792179
"CATALOG_OVERRIDE.test_db.test_model__DEV",
21802180
),
2181+
# EnvironmentSuffixTarget.CATALOG
2182+
(
2183+
"test_db.test_model",
2184+
EnvironmentNamingInfo(name="dev", suffix_target=EnvironmentSuffixTarget.CATALOG),
2185+
"default_catalog",
2186+
"duckdb",
2187+
"default_catalog__dev.test_db.test_model",
2188+
),
2189+
(
2190+
"test_db.test_model",
2191+
EnvironmentNamingInfo(name="dev", suffix_target=EnvironmentSuffixTarget.CATALOG),
2192+
"default_catalog",
2193+
"snowflake",
2194+
"DEFAULT_CATALOG__DEV.test_db.test_model",
2195+
),
21812196
),
21822197
)
21832198
def test_display_name(

0 commit comments

Comments
 (0)