mirror of
https://github.com/paradigmxyz/reth.git
synced 2026-01-29 09:08:05 -05:00
chore: add some traces (#2127)
This commit is contained in:
@@ -153,7 +153,6 @@ where
|
||||
if pipeline_min_progress < head_block_number {
|
||||
self.require_pipeline_run(PipelineTarget::Head);
|
||||
}
|
||||
|
||||
PayloadStatus::from_status(PayloadStatusEnum::Valid)
|
||||
}
|
||||
Err(error) => {
|
||||
@@ -178,8 +177,10 @@ where
|
||||
}
|
||||
}
|
||||
} else {
|
||||
trace!(target: "consensus::engine", "Pipeline is syncing, skipping forkchoice update");
|
||||
PayloadStatus::from_status(PayloadStatusEnum::Syncing)
|
||||
};
|
||||
|
||||
trace!(target: "consensus::engine", ?state, ?status, "Returning forkchoice status");
|
||||
Ok(ForkchoiceUpdated::new(status))
|
||||
}
|
||||
|
||||
@@ -222,6 +222,8 @@ where
|
||||
.instrument(info_span!("execute", stage = %stage_id))
|
||||
.await?;
|
||||
|
||||
trace!(target: "sync::pipeline", stage = %stage_id, ?next, "Completed stage");
|
||||
|
||||
match next {
|
||||
ControlFlow::NoProgress { stage_progress } => {
|
||||
if let Some(progress) = stage_progress {
|
||||
|
||||
Reference in New Issue
Block a user