pass all parameters that _build_table_properties_exp might use

Author: themisvaltinos

sqlmesh_utils/materializations/non_idempotent_incremental_by_time_range.py

@@ -92,6 +92,11 @@ def insert(
             self.adapter.ctas(
                 table_name=table_name,
                 query_or_df=model.ctas_query(**render_kwargs),
+                table_format=model.table_format,
+                storage_format=model.storage_format,
+                partitioned_by=model.partitioned_by,
+                partition_interval_unit=model.partition_interval_unit,
+                clustered_by=model.clustered_by,
                 table_properties=kwargs.get("physical_properties", model.physical_properties),
             )
 

tests/materializations/integration/test_integration_non_idempotent_incremental_by_time_range.py

@@ -342,7 +342,7 @@ def mock_merge(**kwargs):
             render_kwargs={},
         )
 
-    # Assert that CTAS was called with table_properties
+    # Assert that CTAS was called with table_properties and partitioned_by
     assert len(ctas_calls) == 1
     ctas_kwargs = ctas_calls[0]
 
@@ -351,3 +351,10 @@ def mock_merge(**kwargs):
 
     assert table_props is not None
     assert "extra_props" in table_props
+
+    assert "partitioned_by" in ctas_kwargs
+    partitioned_by = ctas_kwargs["partitioned_by"]
+    assert partitioned_by == [
+        exp.Column(this=exp.Identifier(this="category", quoted=True)),
+        exp.Column(this=exp.Identifier(this="borrowed_at", quoted=True)),
+    ]