We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7d47b04 commit 953ca06Copy full SHA for 953ca06
src/slots_processor/mod.rs
@@ -4,7 +4,7 @@ use alloy::{
4
use anyhow::{anyhow, Context as AnyhowContext, Result};
5
6
use crate::clients::beacon::types::BlockHeader;
7
-use tracing::{debug, info};
+use tracing::{debug, info, Instrument};
8
9
use crate::{
10
clients::{
@@ -308,7 +308,13 @@ impl SlotsProcessor<ReqwestTransport> {
308
// they were skipped and must be processed.
309
for block in canonical_block_headers.iter() {
310
if block.slot != new_head_header.slot {
311
+ let reorg_span = tracing::info_span!(
312
+ parent: &tracing::Span::current(),
313
+ "forwarded_block",
314
+ );
315
+
316
self.process_block(block)
317
+ .instrument(reorg_span)
318
.await
319
.with_context(|| format!("Failed to sync forwarded block"))?;
320
}
0 commit comments