We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6564b4e commit 53184b6Copy full SHA for 53184b6
1 file changed
sqlmesh/core/engine_adapter/fabric.py
@@ -60,7 +60,7 @@ def _insert_overwrite_by_condition(
60
self,
61
table_name: TableName,
62
source_queries: t.List[SourceQuery],
63
- columns_to_types: t.Optional[t.Dict[str, exp.DataType]] = None,
+ target_columns_to_types: t.Optional[t.Dict[str, exp.DataType]] = None,
64
where: t.Optional[exp.Condition] = None,
65
insert_overwrite_strategy_override: t.Optional[InsertOverwriteStrategy] = None,
66
**kwargs: t.Any,
@@ -70,7 +70,7 @@ def _insert_overwrite_by_condition(
70
71
table_name=table_name,
72
source_queries=source_queries,
73
- columns_to_types=columns_to_types,
+ columns_to_types=target_columns_to_types,
74
where=where,
75
insert_overwrite_strategy_override=InsertOverwriteStrategy.DELETE_INSERT,
76
**kwargs,
0 commit comments