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 @@ -269,8 +269,11 @@ impl<'a> SnapshotProducer<'a> {
269269 }
270270
271271 // Write manifest file for added data files and return the ManifestFile for ManifestList.
272- async fn write_added_manifest ( & mut self , content_type : ManifestContentType ) -> Result < ManifestFile > {
273- let added_data_files = match content_type {
272+ async fn write_added_manifest (
273+ & mut self ,
274+ content_type : ManifestContentType ,
275+ ) -> Result < ManifestFile > {
276+ let added_data_files = match content_type {
274277 ManifestContentType :: Data => std:: mem:: take ( & mut self . added_data_files ) ,
275278 ManifestContentType :: Deletes => std:: mem:: take ( & mut self . added_delete_files ) ,
276279 } ;
@@ -385,7 +388,9 @@ impl<'a> SnapshotProducer<'a> {
385388 manifest_files. push ( added_manifest) ;
386389 }
387390 if !self . added_delete_files . is_empty ( ) {
388- let added_manifest = self . write_added_manifest ( ManifestContentType :: Deletes ) . await ?;
391+ let added_manifest = self
392+ . write_added_manifest ( ManifestContentType :: Deletes )
393+ . await ?;
389394 manifest_files. push ( added_manifest) ;
390395 }
391396
You can’t perform that action at this time.
0 commit comments