Skip to content

Commit 77121d9

Browse files
committed
fix
1 parent b955e94 commit 77121d9

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

pyiceberg/table/__init__.py

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2002,11 +2002,13 @@ def _build_residual_evaluator(self, spec_id: int) -> Callable[[DataFile], Residu
20022002
# The lambda created here is run in multiple threads.
20032003
# So we avoid creating _EvaluatorExpression methods bound to a single
20042004
# shared instance across multiple threads.
2005-
return lambda datafile: residual_evaluator_of(
2006-
spec=spec,
2007-
expr=self.row_filter,
2008-
case_sensitive=self.case_sensitive,
2009-
schema=self.table_metadata.schema(),
2005+
return lambda datafile: (
2006+
residual_evaluator_of(
2007+
spec=spec,
2008+
expr=self.row_filter,
2009+
case_sensitive=self.case_sensitive,
2010+
schema=self.table_metadata.schema(),
2011+
)
20102012
)
20112013

20122014
@staticmethod

0 commit comments

Comments
 (0)