Skip to content

Commit 71d65c2

Browse files
committed
use .map(unwrap_or_resume_unwind) consistently in blob_sync
1 parent 3edf60c commit 71d65c2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

crates/walrus-service/src/node/blob_sync.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -798,9 +798,9 @@ impl BlobSynchronizer {
798798
let existing = {
799799
let storage = self.storage().clone();
800800
let blob_id = self.blob_id;
801-
utils::unwrap_or_resume_unwind(
802-
tokio::task::spawn_blocking(move || storage.get_metadata(&blob_id)).await,
803-
)?
801+
tokio::task::spawn_blocking(move || storage.get_metadata(&blob_id))
802+
.map(utils::unwrap_or_resume_unwind)
803+
.await?
804804
};
805805
if let Some(metadata) = existing {
806806
tracing::debug!("not syncing metadata: already stored");

0 commit comments

Comments
 (0)