From 6ed188fe9ecc10c31930fc33a6f0223da68df41b Mon Sep 17 00:00:00 2001 From: Yusuf Ali Date: Wed, 17 Sep 2025 11:30:33 -0400 Subject: [PATCH 1/2] fix(delta): specify operator for string comparisons --- servc/svc/com/storage/delta.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/servc/svc/com/storage/delta.py b/servc/svc/com/storage/delta.py index 76647d6..8be36a1 100644 --- a/servc/svc/com/storage/delta.py +++ b/servc/svc/com/storage/delta.py @@ -122,14 +122,14 @@ def _filters( return filters if len(filters) > 0 else None def overwrite( - self, data: List[Any], partitions: Dict[str, List[Any]] | None = None + self, data: List[Any], partitions: Dict[str, List[Any]] | None = None, operator:str = " & " ) -> bool: table = self.getConn() predicate: str | None = None filter = self._filters(partitions) if filter is not None: - predicate = " & ".join([" ".join(x) for x in filter]) + predicate = operator.join([" ".join(x) for x in filter]) write_deltalake( table, From bb89b3f8151757f1c6bb4a8b994cd84db8ef9bd0 Mon Sep 17 00:00:00 2001 From: Yusuf Ali Date: Wed, 17 Sep 2025 11:31:36 -0400 Subject: [PATCH 2/2] chore: fixed syntax issue for typing Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --- servc/svc/com/storage/delta.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/servc/svc/com/storage/delta.py b/servc/svc/com/storage/delta.py index 8be36a1..82ff92f 100644 --- a/servc/svc/com/storage/delta.py +++ b/servc/svc/com/storage/delta.py @@ -122,7 +122,7 @@ def _filters( return filters if len(filters) > 0 else None def overwrite( - self, data: List[Any], partitions: Dict[str, List[Any]] | None = None, operator:str = " & " + self, data: List[Any], partitions: Dict[str, List[Any]] | None = None, operator: str = " & " ) -> bool: table = self.getConn()