Skip to content

Commit c062c91

Browse files
authored
Fix: normalize default schema name when targeting prod too (#2792)
1 parent 1e7bc19 commit c062c91

File tree

1 file changed

+10
-5
lines changed

1 file changed

+10
-5
lines changed

sqlmesh/core/snapshot/definition.py

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -228,17 +228,22 @@ def catalog_for_environment(
228228
def schema_for_environment(
229229
self, environment_naming_info: EnvironmentNamingInfo, dialect: DialectType = None
230230
) -> str:
231-
schema = self.schema_name or c.DEFAULT_SCHEMA
231+
normalize = environment_naming_info.normalize_name
232+
233+
if self.schema_name:
234+
schema = self.schema_name
235+
else:
236+
schema = c.DEFAULT_SCHEMA
237+
if normalize:
238+
schema = normalize_identifiers(schema, dialect=dialect).name
239+
232240
if (
233241
environment_naming_info.name.lower() != c.PROD
234242
and environment_naming_info.suffix_target.is_schema
235243
):
236244
env_name = environment_naming_info.name
237-
if environment_naming_info.normalize_name:
245+
if normalize:
238246
env_name = normalize_identifiers(env_name, dialect=dialect).name
239-
if not self.schema_name:
240-
# We also normalize the schema if it's the default one
241-
schema = normalize_identifiers(schema, dialect=dialect).name
242247

243248
schema = f"{schema}__{env_name}"
244249

0 commit comments

Comments
 (0)