Skip to content

Commit 8b31d51

Browse files
committed
remove async block inside spawn_blocking in create_storage_for_shards_in_background
1 parent 71d65c2 commit 8b31d51

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

crates/walrus-service/src/node.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3334,12 +3334,12 @@ impl StorageNodeInner {
33343334
shard_map_lock: StorageShardLock,
33353335
) -> Result<(), anyhow::Error> {
33363336
let this = self.clone();
3337-
tokio::task::spawn_blocking(move || async move {
3337+
tokio::task::spawn_blocking(move || {
33383338
this.storage
33393339
.create_storage_for_shards_locked(shard_map_lock, &new_shards)
33403340
})
33413341
.in_current_span()
3342-
.await?
3342+
.map(unwrap_or_resume_unwind)
33433343
.await?;
33443344
Ok(())
33453345
}

0 commit comments

Comments
 (0)