Skip to content

Commit 53534a5

Browse files
Jan KaulJanKaul
authored andcommitted
fix remaining selected manifest
1 parent ff37d73 commit 53534a5

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

iceberg-rust/src/table/manifest_list.rs

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1064,10 +1064,18 @@ impl<'schema, 'metadata> ManifestListWriter<'schema, 'metadata> {
10641064
}
10651065

10661066
pub(crate) async fn finish(
1067-
self,
1067+
mut self,
10681068
snapshot_id: i64,
10691069
object_store: Arc<dyn ObjectStore>,
10701070
) -> Result<String, Error> {
1071+
if let Some(selected_data_manifest) = self.selected_data_manifest.take() {
1072+
self.writer.append_ser(selected_data_manifest)?;
1073+
}
1074+
1075+
if let Some(selected_delete_manifest) = self.selected_delete_manifest.take() {
1076+
self.writer.append_ser(selected_delete_manifest)?;
1077+
}
1078+
10711079
let new_manifest_list_location = new_manifest_list_location(
10721080
&self.table_metadata.location,
10731081
snapshot_id,

0 commit comments

Comments
 (0)