Skip to content

Commit d96f88c

Browse files
Jan KaulJanKaul
authored andcommitted
fix remaining selected manifest
1 parent 6761a61 commit d96f88c

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
@@ -988,10 +988,18 @@ impl<'schema, 'metadata> ManifestListWriter<'schema, 'metadata> {
988988
}
989989

990990
pub(crate) async fn finish(
991-
self,
991+
mut self,
992992
snapshot_id: i64,
993993
object_store: Arc<dyn ObjectStore>,
994994
) -> Result<String, Error> {
995+
if let Some(selected_data_manifest) = self.selected_data_manifest.take() {
996+
self.writer.append_ser(selected_data_manifest)?;
997+
}
998+
999+
if let Some(selected_delete_manifest) = self.selected_delete_manifest.take() {
1000+
self.writer.append_ser(selected_delete_manifest)?;
1001+
}
1002+
9951003
let new_manifest_list_location = new_manifest_list_location(
9961004
&self.table_metadata.location,
9971005
snapshot_id,

0 commit comments

Comments
 (0)