fix(derive): Retain L1 blocks (#683)

op-rs · Oct 10, 2024 · c775fcf · c775fcf
1 parent cd2fe99
commit c775fcf
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/crates/derive/src/stages/batch_queue.rs b/crates/derive/src/stages/batch_queue.rs
@@ -481,7 +481,6 @@ where
 {
     async fn flush_channel(&mut self) -> PipelineResult<()> {
         self.batches.clear();
-        self.l1_blocks.clear();
         self.next_spans.clear();
         self.prev.flush_channel().await
     }
@@ -567,7 +566,7 @@ mod tests {
         bq.flush_channel().await.unwrap();
         assert!(bq.prev.flushed);
         assert!(bq.batches.is_empty());
-        assert!(bq.l1_blocks.is_empty());
+        assert!(!bq.l1_blocks.is_empty());
         assert!(bq.next_spans.is_empty());
     }