fix: cluster name escaping

canbekley · canbekley · commit d2cf724c6629 · 2025-06-13T17:41:25.000+02:00
diff --git a/dbt/adapters/clickhouse/dbclient.py b/dbt/adapters/clickhouse/dbclient.py
@@ -206,7 +206,7 @@ def _ensure_database(self, database_engine, cluster_name) -> None:
             if not db_exists:
                 engine_clause = f' ENGINE {database_engine} ' if database_engine else ''
                 cluster_clause = (
-                    f' ON CLUSTER {cluster_name} '
+                    f' ON CLUSTER "{cluster_name}" '
                     if cluster_name is not None and cluster_name.strip() != ''
                     else ''
                 )

Original file line number	Diff line number	Diff line change
`@@ -206,7 +206,7 @@ def _ensure_database(self, database_engine, cluster_name) -> None:`
`206`	`206`	`if not db_exists:`
`207`	`207`	`engine_clause = f' ENGINE {database_engine} ' if database_engine else ''`
`208`	`208`	`cluster_clause = (`
`209`		`- f' ON CLUSTER {cluster_name} '`
	`209`	`+ f' ON CLUSTER "{cluster_name}" '`
`210`	`210`	`if cluster_name is not None and cluster_name.strip() != ''`
`211`	`211`	`else ''`
`212`	`212`	`)`