cluster names containing dash characters (#198)

ClickHouse · Oct 16, 2023 · 84ca861 · 84ca861
1 parent 80cba25
commit 84ca861
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dbt/adapters/clickhouse/dbclient.py b/dbt/adapters/clickhouse/dbclient.py
@@ -150,7 +150,7 @@ def _ensure_database(self, database_engine, cluster_name) -> None:
             db_exists = self.command(check_db)
             if not db_exists:
                 engine_clause = f' ENGINE {database_engine} ' if database_engine else ''
-                cluster_clause = f' ON CLUSTER {cluster_name} ' if cluster_name is not None else ''
+                cluster_clause = f' ON CLUSTER "{cluster_name}" ' if cluster_name is not None else ''
                 self.command(f'CREATE DATABASE {self.database}{cluster_clause}{engine_clause}')
                 db_exists = self.command(check_db)
                 if not db_exists: