Skip to content

Commit 61772f5

Browse files
committed
use num_rows for len
1 parent 081e75b commit 61772f5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pyiceberg/io/pyarrow.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1360,7 +1360,7 @@ def _task_to_record_batches(
13601360
# Apply the user filter
13611361
if pyarrow_filter is not None:
13621362
filtered_batch = batch.filter(pyarrow_filter)
1363-
if len(filtered_batch) == 0:
1363+
if filtered_batch.num_rows == 0:
13641364
continue
13651365
output_batches = filtered_batch
13661366
for output_batch in output_batches:

0 commit comments

Comments
 (0)