diff --git a/seaweed-vector/crates/core/src/maintenance.rs b/seaweed-vector/crates/core/src/maintenance.rs index b75b521330..d3a95567b2 100644 --- a/seaweed-vector/crates/core/src/maintenance.rs +++ b/seaweed-vector/crates/core/src/maintenance.rs @@ -67,8 +67,7 @@ pub async fn pin(dataset: &Dataset) -> Result { dataset .tags() .create(&tag, Ref::Version(None, Some(version))) - .await - .map_err(anyhow::Error::msg)?; + .await?; // A cleanup that listed tags before this create can still reclaim the // version; fail the read now rather than mid-query. if dataset.checkout_version(version).await.is_err() { @@ -109,7 +108,7 @@ fn denied(err: &anyhow::Error) -> bool { } async fn release(dataset: &Dataset, tag: &str) -> Result<()> { - dataset.tags().delete(tag).await.map_err(anyhow::Error::msg) + Ok(dataset.tags().delete(tag).await?) } fn untrack(tag: &str) {