File tree Expand file tree Collapse file tree 1 file changed +2
-9
lines changed
Expand file tree Collapse file tree 1 file changed +2
-9
lines changed Original file line number Diff line number Diff line change @@ -633,14 +633,7 @@ def _existing_manifests(self) -> list[ManifestFile]:
633633 continue
634634
635635 # We have to rewrite the manifest file without the deleted data files
636- with write_manifest (
637- format_version = self ._transaction .table_metadata .format_version ,
638- spec = self .spec (manifest_file .partition_spec_id ),
639- schema = self .schema (),
640- output_file = self .new_manifest_output (),
641- snapshot_id = self ._snapshot_id ,
642- avro_compression = self ._compression ,
643- ) as writer :
636+ with self .new_manifest_writer (self .spec (manifest_file .partition_spec_id )) as writer :
644637 for entry in entries_to_write :
645638 writer .add_entry (
646639 ManifestEntry .from_args (
@@ -651,7 +644,7 @@ def _existing_manifests(self) -> list[ManifestFile]:
651644 data_file = entry .data_file ,
652645 )
653646 )
654- existing_files .append (writer .to_manifest_file ())
647+ existing_files .append (writer .to_manifest_file ())
655648
656649 return existing_files
657650
You can’t perform that action at this time.
0 commit comments