drop provider rw on error

paradigmxyz · Nov 17, 2023 · 1cc5a4c · 1cc5a4c
1 parent 0a456c8
commit 1cc5a4c
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)