diff --git a/crates/stages/src/pipeline/mod.rs b/crates/stages/src/pipeline/mod.rs index af99a4ba0f..67ed092c47 100644 --- a/crates/stages/src/pipeline/mod.rs +++ b/crates/stages/src/pipeline/mod.rs @@ -237,7 +237,7 @@ impl Pipeline { if stage_progress < to { debug!(target: "sync::pipeline", from = %stage_progress, %to, "Unwind point too far for stage"); self.listeners.notify(PipelineEvent::Skipped { stage_id }); - return Ok(()) + continue } debug!(target: "sync::pipeline", from = %stage_progress, %to, ?bad_block, "Starting unwind");