fixup! [pipeline] fixes

aptos-labs · Dec 5, 2024 · 10faa3e · 10faa3e
1 parent 0f5999f
commit 10faa3e
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/consensus/consensus-types/src/pipelined_block.rs b/consensus/consensus-types/src/pipelined_block.rs
@@ -479,12 +479,11 @@ impl PipelinedBlock {
     }
 
     pub async fn wait_for_commit_ledger(&self) {
-        // this may be cancelled
-        let _ = self
-            .pipeline_futs()
-            .expect("Pipeline needs to be enabled")
-            .commit_ledger_fut
-            .await;
+        // may be aborted (e.g. by reset)
+        if let Some(fut) = self.pipeline_futs() {
+            // this may be cancelled
+            let _ = fut.commit_ledger_fut.await;
+        }
     }
 }