diff --git a/crates/node/events/src/node.rs b/crates/node/events/src/node.rs index 201aaeac44..872fcb1940 100644 --- a/crates/node/events/src/node.rs +++ b/crates/node/events/src/node.rs @@ -206,6 +206,10 @@ impl NodeState { self.current_stage = Some(current_stage); } + PipelineEvent::Unwound { stage_id, result } => { + info!(stage = %stage_id, checkpoint = %result.checkpoint.block_number, "Unwound stage"); + self.current_stage = None; + } _ => (), } }