Skip to content

Commit 617a30d

Browse files
authored
Merge pull request #129 from serv-c/drgroot-patch-1
fix(delta): specify operator for string comparisons
2 parents 28ef34c + bb89b3f commit 617a30d

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)