fix: cluster_by as single string with multiple columns

Author: geooo109

sqlmesh/dbt/model.py

@@ -157,14 +157,20 @@ class ModelConfig(BaseModelConfig):
 
     @field_validator(
         "unique_key",
-        "cluster_by",
         "tags",
         mode="before",
     )
     @classmethod
     def _validate_list(cls, v: t.Union[str, t.List[str]]) -> t.List[str]:
         return ensure_list(v)
 
+    @field_validator("cluster_by", mode="before")
+    @classmethod
+    def _validate_cluster_by(cls, v: t.Union[str, t.List[str]]) -> t.Union[str, t.List[str]]:
+        if isinstance(v, str):
+            return [c.strip() for c in v.split(",")]
+        return ensure_list(v)
+
     @field_validator("check_cols", mode="before")
     @classmethod
     def _validate_check_cols(cls, v: t.Union[str, t.List[str]]) -> t.Union[str, t.List[str]]:

tests/dbt/test_transformation.py

@@ -2254,6 +2254,20 @@ def test_model_cluster_by():
     )
     assert model.to_sqlmesh(context).clustered_by == []
 
+    model = ModelConfig(
+        name="model",
+        alias="model",
+        package_name="package",
+        target_schema="test",
+        cluster_by="Bar, qux",
+        sql="SELECT * FROM baz",
+        materialized=Materialization.TABLE.value,
+    )
+    assert model.to_sqlmesh(context).clustered_by == [
+        exp.to_column('"BAR"'),
+        exp.to_column('"QUX"'),
+    ]
+
 
 def test_snowflake_dynamic_table():
     context = DbtContext()