From 1d3cf5a86c25c391ea1795ec74001bbaa32ffff5 Mon Sep 17 00:00:00 2001 From: Roman Krasiuk Date: Thu, 23 Mar 2023 19:17:05 +0200 Subject: [PATCH] fix(pipeline): ensure unwind across stages (#1934) --- crates/stages/src/pipeline/mod.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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");