File tree Expand file tree Collapse file tree 2 files changed +8
-4
lines changed
crates/iceberg/src/transaction Expand file tree Collapse file tree 2 files changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -165,7 +165,6 @@ fn copy_with_deleted_status(entry: &ManifestEntryRef) -> Result<ManifestEntry> {
165165 )
166166 } ) ?)
167167 // todo copy file seq no as well
168-
169168 . data_file ( entry. data_file ( ) . clone ( ) ) ;
170169
171170 Ok ( builder. build ( ) )
Original file line number Diff line number Diff line change @@ -266,8 +266,11 @@ impl<'a> SnapshotProducer<'a> {
266266 }
267267
268268 // Write manifest file for added data files and return the ManifestFile for ManifestList.
269- async fn write_added_manifest ( & mut self , content_type : ManifestContentType ) -> Result < ManifestFile > {
270- let added_data_files = match content_type {
269+ async fn write_added_manifest (
270+ & mut self ,
271+ content_type : ManifestContentType ,
272+ ) -> Result < ManifestFile > {
273+ let added_data_files = match content_type {
271274 ManifestContentType :: Data => std:: mem:: take ( & mut self . added_data_files ) ,
272275 ManifestContentType :: Deletes => std:: mem:: take ( & mut self . added_delete_files ) ,
273276 } ;
@@ -382,7 +385,9 @@ impl<'a> SnapshotProducer<'a> {
382385 manifest_files. push ( added_manifest) ;
383386 }
384387 if !self . added_delete_files . is_empty ( ) {
385- let added_manifest = self . write_added_manifest ( ManifestContentType :: Deletes ) . await ?;
388+ let added_manifest = self
389+ . write_added_manifest ( ManifestContentType :: Deletes )
390+ . await ?;
386391 manifest_files. push ( added_manifest) ;
387392 }
388393
You can’t perform that action at this time.
0 commit comments