From 2f21a2d50a51ed391576d0a1cb12eaee0a2abc6b Mon Sep 17 00:00:00 2001
From: Fokko Driesprong <fokko@apache.org>
Date: Thu, 7 Aug 2025 21:06:12 +0200
Subject: [PATCH] Minor cleanup

---
 pyiceberg/io/pyarrow.py | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py
index 2fdee17441..cde6d94709 100644
--- a/pyiceberg/io/pyarrow.py
+++ b/pyiceberg/io/pyarrow.py
@@ -1492,7 +1492,7 @@ def _task_to_record_batches(
 
                 current_batch = table.combine_chunks().to_batches()[0]
 
-            result_batch = _to_requested_schema(
+            yield _to_requested_schema(
                 projected_schema,
                 file_project_schema,
                 current_batch,
@@ -1500,8 +1500,6 @@ def _task_to_record_batches(
                 projected_missing_fields=projected_missing_fields,
             )
 
-            yield result_batch
-
 
 def _read_all_delete_files(io: FileIO, tasks: Iterable[FileScanTask]) -> Dict[str, List[ChunkedArray]]:
     deletes_per_file: Dict[str, List[ChunkedArray]] = {}