feat(derive): Holocene Frame Queue (#579)

* feat(derive): holocene frame queue changes * feat(derive): holocene frame queue * Update crates/derive/src/stages/frame_queue.rs Co-authored-by: clabby <ben@clab.by> * fix(derive): fq nits --------- Co-authored-by: clabby <ben@clab.by>
op-rs · Sep 27, 2024 · 7952058 · 7952058
1 parent 07d725a
commit 7952058
Show file tree

Hide file tree

Showing 3 changed files with 309 additions and 40 deletions.
diff --git a/crates/derive/src/pipeline/builder.rs b/crates/derive/src/pipeline/builder.rs
@@ -131,7 +131,7 @@ where
         let mut l1_traversal = L1Traversal::new(chain_provider, Arc::clone(&rollup_config));
         l1_traversal.block = Some(builder.origin.expect("origin must be set"));
         let l1_retrieval = L1Retrieval::new(l1_traversal, dap_source);
-        let frame_queue = FrameQueue::new(l1_retrieval);
+        let frame_queue = FrameQueue::new(l1_retrieval, Arc::clone(&rollup_config));
         let channel_bank = ChannelBank::new(Arc::clone(&rollup_config), frame_queue);
         let channel_reader = ChannelReader::new(channel_bank, Arc::clone(&rollup_config));
         let batch_stream = BatchStream::new(channel_reader, rollup_config.clone());