diff --git a/icechunk/src/repository.rs b/icechunk/src/repository.rs index 8f065b1f..648c618e 100644 --- a/icechunk/src/repository.rs +++ b/icechunk/src/repository.rs @@ -1043,7 +1043,7 @@ async fn flush( .await?; let all_nodes = - updated_nodes(storage, &change_set, parent_id, &new_manifest_id).await?; + updated_nodes(storage, change_set, parent_id, &new_manifest_id).await?; let mut new_snapshot = Snapshot::from_iter( old_snapshot.as_ref(), diff --git a/icechunk/src/zarr.rs b/icechunk/src/zarr.rs index aaa909c1..b5ba0f06 100644 --- a/icechunk/src/zarr.rs +++ b/icechunk/src/zarr.rs @@ -456,8 +456,8 @@ impl Store { }) .collect::, StoreError>>()?; - let result = self.repository.write().await.merge(repositories).await?; - Ok(result) + self.repository.write().await.merge(repositories).await?; + Ok(()) } /// Commit the current changes to the current branch. If the store is not currently