We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 569d1b1 commit fafdb68Copy full SHA for fafdb68
1 file changed
pyiceberg/io/pyarrow.py
@@ -1342,7 +1342,6 @@ def _get_column_projection_values(
1342
def _task_to_record_batches(
1343
fs: FileSystem,
1344
task: FileScanTask,
1345
- schema: Schema,
1346
projected_schema: Schema,
1347
positional_deletes: Optional[List[ChunkedArray]],
1348
case_sensitive: bool,
@@ -1620,7 +1619,6 @@ def _record_batches_from_scan_tasks_and_deletes(
1620
1619
batches = _task_to_record_batches(
1621
_fs_from_file_path(self._io, task.file.file_path),
1622
task,
1623
- self._table_metadata.schema(),
1624
self._projected_schema,
1625
deletes_per_file.get(task.file.file_path),
1626
self._case_sensitive,
0 commit comments