Skip to content

Commit 6ed188f

Browse files
authored
fix(delta): specify operator for string comparisons
1 parent 28ef34c commit 6ed188f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

servc/svc/com/storage/delta.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,14 +122,14 @@ def _filters(
122122
return filters if len(filters) > 0 else None
123123

124124
def overwrite(
125-
self, data: List[Any], partitions: Dict[str, List[Any]] | None = None
125+
self, data: List[Any], partitions: Dict[str, List[Any]] | None = None, operator:str = " & "
126126
) -> bool:
127127
table = self.getConn()
128128

129129
predicate: str | None = None
130130
filter = self._filters(partitions)
131131
if filter is not None:
132-
predicate = " & ".join([" ".join(x) for x in filter])
132+
predicate = operator.join([" ".join(x) for x in filter])
133133

134134
write_deltalake(
135135
table,

0 commit comments

Comments
 (0)