Skip to content

Commit b435c1b

Browse files
authored
Minor cleanup (#2298)
# Rationale for this change Missed this in another PR # Are these changes tested? # Are there any user-facing changes? <!-- In the case of user-facing changes, please add the changelog label. -->
1 parent 5902602 commit b435c1b

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

pyiceberg/io/pyarrow.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1492,16 +1492,14 @@ def _task_to_record_batches(
14921492

14931493
current_batch = table.combine_chunks().to_batches()[0]
14941494

1495-
result_batch = _to_requested_schema(
1495+
yield _to_requested_schema(
14961496
projected_schema,
14971497
file_project_schema,
14981498
current_batch,
14991499
downcast_ns_timestamp_to_us=True,
15001500
projected_missing_fields=projected_missing_fields,
15011501
)
15021502

1503-
yield result_batch
1504-
15051503

15061504
def _read_all_delete_files(io: FileIO, tasks: Iterable[FileScanTask]) -> Dict[str, List[ChunkedArray]]:
15071505
deletes_per_file: Dict[str, List[ChunkedArray]] = {}

0 commit comments

Comments
 (0)