sync: unindent fetch task
@@ -320,8 +320,7 @@ where
let mut retry_peer_set = self.block_network.clone();
let mut verifier = self.verifier.clone();
let span = tracing::info_span!("block_fetch_verify", ?hash);
- self.pending_blocks.push(
- tokio::spawn(async move {
+ let task = tokio::spawn(async move {
let block = match retry_peer_set
.ready_and()
.await?
@@ -338,8 +337,8 @@ where
verifier.ready_and().await?.call(block).await
})
- .instrument(span),
- );
+ .instrument(span);
+ self.pending_blocks.push(task);
}
Ok(())
