From e11584b14c674560b909c86ae62fb09fa5f66b49 Mon Sep 17 00:00:00 2001 From: George Sittas Date: Wed, 8 Apr 2026 22:20:35 +0300 Subject: [PATCH] Chore!: bump sqlglot v30.4.2 Signed-off-by: George Sittas --- pyproject.toml | 2 +- sqlmesh/core/engine_adapter/base.py | 6 +++++- sqlmesh/core/engine_adapter/clickhouse.py | 6 +++++- sqlmesh/core/model/kind.py | 2 +- 4 files changed, 12 insertions(+), 4 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index c9d5fd4447..bcc69c667e 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -24,7 +24,7 @@ dependencies = [ "requests", "rich[jupyter]", "ruamel.yaml", - "sqlglot~=30.2.1", + "sqlglot~=30.4.2", "tenacity", "time-machine", "json-stream" diff --git a/sqlmesh/core/engine_adapter/base.py b/sqlmesh/core/engine_adapter/base.py index 8de7b79398..5465ea1197 100644 --- a/sqlmesh/core/engine_adapter/base.py +++ b/sqlmesh/core/engine_adapter/base.py @@ -2920,7 +2920,11 @@ def _replace_by_key( target_columns_to_types = self.columns(target_table) temp_table = self._get_temp_table(target_table) - key_exp = exp.func("CONCAT_WS", "'__SQLMESH_DELIM__'", *key) if len(key) > 1 else key[0] + key_exp = ( + exp.func("CONCAT_WS", "'__SQLMESH_DELIM__'", *key, dialect=self.dialect) + if len(key) > 1 + else key[0] + ) column_names = list(target_columns_to_types or []) with self.transaction(): diff --git a/sqlmesh/core/engine_adapter/clickhouse.py b/sqlmesh/core/engine_adapter/clickhouse.py index 71a834ecfc..698b2f4128 100644 --- a/sqlmesh/core/engine_adapter/clickhouse.py +++ b/sqlmesh/core/engine_adapter/clickhouse.py @@ -423,7 +423,11 @@ def _replace_by_key( source_columns=source_columns, ) - key_exp = exp.func("CONCAT_WS", "'__SQLMESH_DELIM__'", *key) if len(key) > 1 else key[0] + key_exp = ( + exp.func("CONCAT_WS", "'__SQLMESH_DELIM__'", *key, dialect=self.dialect) + if len(key) > 1 + else key[0] + ) self._insert_overwrite_by_condition( target_table, diff --git a/sqlmesh/core/model/kind.py b/sqlmesh/core/model/kind.py index d7a7bb9579..7ae1ef8c0d 100644 --- a/sqlmesh/core/model/kind.py +++ b/sqlmesh/core/model/kind.py @@ -786,7 +786,7 @@ def data_hash_values(self) -> t.List[t.Optional[str]]: gen(self.valid_to_name), str(self.invalidate_hard_deletes), self.time_data_type.sql(self.dialect), - gen(self.batch_size) if self.batch_size is not None else None, + str(self.batch_size) if self.batch_size is not None else None, ] @property