File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -182,16 +182,12 @@ def _execute_task(task: FileScanTask) -> list[pa.RecordBatch]:
182182 # require different handling that's not yet implemented - they will be silently
183183 # skipped, which may return a superset of correct results.
184184 pos_deletes = [
185- d
186- for d in task .delete_files
187- if d .content == DataFileContent .POSITION_DELETES and d .file_format == FileFormat .PARQUET
185+ d for d in task .delete_files if d .content == DataFileContent .POSITION_DELETES and d .file_format == FileFormat .PARQUET
188186 ]
189187
190188 # Warn if there are unsupported delete file formats (e.g., Puffin DVs)
191189 unsupported_deletes = [
192- d
193- for d in task .delete_files
194- if d .content == DataFileContent .POSITION_DELETES and d .file_format != FileFormat .PARQUET
190+ d for d in task .delete_files if d .content == DataFileContent .POSITION_DELETES and d .file_format != FileFormat .PARQUET
195191 ]
196192 if unsupported_deletes :
197193 import warnings
You can’t perform that action at this time.
0 commit comments