fix(pipeline): ensure unwind across stages (#1934)

This commit is contained in:
Roman Krasiuk
2023-03-23 19:17:05 +02:00
committed by GitHub
parent c29d733f5c
commit 1d3cf5a86c

View File

@@ -237,7 +237,7 @@ impl<DB: Database, U: SyncStateUpdater> Pipeline<DB, U> {
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");