drop provider rw on error

paradigmxyz · Nov 17, 2023 · 9bb2e44 · 9bb2e44
1 parent 2a60aaf
commit 9bb2e44
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/crates/stages/src/pipeline/mod.rs b/crates/stages/src/pipeline/mod.rs
@@ -443,6 +443,7 @@ where
                     }
                 }
                 Err(err) => {
+                    drop(provider_rw);
                     self.listeners.notify(PipelineEvent::Error { stage_id });
                     if let Some(ctrl) = on_stage_error(&factory, stage_id, prev_checkpoint, err)? {
                         return Ok(ctrl)