Skip to content

Commit 5c8eafd

Browse files
committed
ignore partition_by config if dialect is snowflake
1 parent 15dac12 commit 5c8eafd

2 files changed

Lines changed: 12 additions & 1 deletion

File tree

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
@@ -1928,6 +1928,11 @@ def test_partition_by(sushi_test_project: Project):
19281928
context.target = DuckDbConfig(name="target", schema="foo")
19291929
assert model_config.to_sqlmesh(context).partitioned_by == []
19301930

1931+
context.target = SnowflakeConfig(
1932+
name="target", schema="test", database="test", account="foo", user="bar", password="baz"
1933+
)
1934+
assert model_config.to_sqlmesh(context).partitioned_by == []
1935+
19311936
model_config = ModelConfig(
19321937
name="model",
19331938
alias="model",

0 commit comments

Comments
 (0)