Skip to content

Commit 22edad4

Browse files
AniketsyFokko
andauthored
Update pyiceberg/expressions/__init__.py
Co-authored-by: Fokko Driesprong <fokko@apache.org>
1 parent 5ed46a8 commit 22edad4

1 file changed

Lines changed: 2 additions & 7 deletions

File tree

pyiceberg/expressions/__init__.py

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -567,13 +567,8 @@ class SetPredicate(UnboundPredicate[L], IcebergBaseModel, ABC):
567567
literals: Set[Literal[L]] = Field(alias="items")
568568

569569
def __init__(self, term: Union[str, UnboundTerm[Any]], literals: Union[Iterable[L], Iterable[Literal[L]]]):
570-
# Convert term to string for serialization
571-
term_str = term.name if isinstance(term, Reference) else str(term)
572-
literals_set = _to_literal_set(literals)
573-
value_list = [lit.value for lit in literals_set]
574-
super().__init__(term=term_str, value=value_list)
575-
self.literals = literals_set
576-
self.term_obj = term
570+
super().__init__(term)
571+
self.literals = _to_literal_set(literals)
577572

578573
def bind(self, schema: Schema, case_sensitive: bool = True) -> BoundSetPredicate[L]:
579574
bound_term = self.term.bind(schema, case_sensitive)

0 commit comments

Comments
 (0)