Merge pull request #158 from serv-c/drgroot-patch-1

fix: handle where predicate contains list

Author: drgroot

servc/svc/com/storage/delta.py

@@ -129,7 +129,14 @@ def overwrite(
         predicate: str | None = None
         filter = self._filters(partitions)
         if filter is not None:
-            predicate = operator.join([" ".join(x) for x in filter])
+            predicate_list: List[str] = []
+            for tuple_value in filter:
+                if isinstance(tuple_value[-1], list):
+                    in_list = ", ".join(tuple_value[-1])
+                    predicate_list.append(" ".join([tuple_value[0], tuple_value[1], f"({in_list})"]))
+                else:
+                    predicate_list.append(" ".join(tuple_value))
+            predicate = operator.join(predicate_list)
 
         write_deltalake(
             table,