diff --git a/sqlmesh/core/snapshot/definition.py b/sqlmesh/core/snapshot/definition.py index 573d3bc75d..6e000764c6 100644 --- a/sqlmesh/core/snapshot/definition.py +++ b/sqlmesh/core/snapshot/definition.py @@ -15,6 +15,7 @@ from sqlmesh.core import constants as c from sqlmesh.core.audit import StandaloneAudit +from sqlmesh.core.environment import EnvironmentSuffixTarget from sqlmesh.core.macros import call_macro from sqlmesh.core.model import Model, ModelKindMixin, ModelKindName, ViewKind, CustomKind from sqlmesh.core.model.definition import _Model @@ -1589,12 +1590,18 @@ def display_name( if snapshot_info_like.is_audit: return snapshot_info_like.name view_name = exp.to_table(snapshot_info_like.name) + + catalog = ( + None + if ( + environment_naming_info.suffix_target != EnvironmentSuffixTarget.CATALOG + and view_name.catalog == default_catalog + ) + else view_name.catalog + ) + qvn = QualifiedViewName( - catalog=( - view_name.catalog - if view_name.catalog and view_name.catalog != default_catalog - else None - ), + catalog=catalog, schema_name=view_name.db or None, table=view_name.name, ) diff --git a/tests/core/test_snapshot.py b/tests/core/test_snapshot.py index e4eb12c522..f09083f500 100644 --- a/tests/core/test_snapshot.py +++ b/tests/core/test_snapshot.py @@ -2178,6 +2178,21 @@ def test_deployability_index_missing_parent(make_snapshot): "snowflake", "CATALOG_OVERRIDE.test_db.test_model__DEV", ), + # EnvironmentSuffixTarget.CATALOG + ( + "test_db.test_model", + EnvironmentNamingInfo(name="dev", suffix_target=EnvironmentSuffixTarget.CATALOG), + "default_catalog", + "duckdb", + "default_catalog__dev.test_db.test_model", + ), + ( + "test_db.test_model", + EnvironmentNamingInfo(name="dev", suffix_target=EnvironmentSuffixTarget.CATALOG), + "default_catalog", + "snowflake", + "DEFAULT_CATALOG__DEV.test_db.test_model", + ), ), ) def test_display_name(