Skip to content

Commit 8bb1f16

Browse files
committed
ignore partition_by config if dialect is snowflake
1 parent 5435ff8 commit 8bb1f16

File tree

2 files changed

+12
-1
lines changed

2 files changed

+12
-1
lines changed

sqlmesh/dbt/model.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -569,7 +569,13 @@ def to_sqlmesh(
569569
)
570570
else:
571571
partitioned_by = []
572-
if isinstance(self.partition_by, list):
572+
if context.target.dialect == "snowflake":
573+
logger.warning(
574+
"Ignoring partition_by config for model '%s' targeting %s. The partition_by config is not supported for Snowflake.",
575+
self.name,
576+
context.target.dialect,
577+
)
578+
elif isinstance(self.partition_by, list):
573579
for p in self.partition_by:
574580
try:
575581
partitioned_by.append(d.parse_one(p, dialect=model_dialect))

tests/dbt/test_transformation.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1880,6 +1880,11 @@ def test_partition_by(sushi_test_project: Project):
18801880
context.target = DuckDbConfig(name="target", schema="foo")
18811881
assert model_config.to_sqlmesh(context).partitioned_by == []
18821882

1883+
context.target = SnowflakeConfig(
1884+
name="target", schema="test", database="test", account="foo", user="bar", password="baz"
1885+
)
1886+
assert model_config.to_sqlmesh(context).partitioned_by == []
1887+
18831888
model_config = ModelConfig(
18841889
name="model",
18851890
alias="model",

0 commit comments

Comments
 (0)