use stage error

op-rs · Sep 17, 2024 · 2234a5e · 2234a5e
1 parent a061543
commit 2234a5e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/crates/derive/src/stages/batch_queue.rs b/crates/derive/src/stages/batch_queue.rs
@@ -180,9 +180,9 @@ where
         // If the current epoch is too old compared to the L1 block we are at,
         // i.e. if the sequence window expired, we create empty batches for the current epoch
         let expiry_epoch = epoch.number + self.cfg.seq_window_size;
-        let bq_origin = self.origin.ok_or_else(|| anyhow!("missing origin"))?;
-        let force_empty_batches = (expiry_epoch == bq_origin.number && empty) ||
-            expiry_epoch < bq_origin.number;
+        let bq_origin = self.origin.ok_or(StageError::MissingOrigin)?;
+        let force_empty_batches =
+            (expiry_epoch == bq_origin.number && empty) || expiry_epoch < bq_origin.number;
         let first_of_epoch = epoch.number == parent.l1_origin.number + 1;
 
         // If the sequencer window did not expire,