From c775fcf3279f4b9f3d54ac62eca19a47e77c39fd Mon Sep 17 00:00:00 2001
From: clabby <ben@clab.by>
Date: Thu, 10 Oct 2024 09:59:51 -0400
Subject: [PATCH] fix(derive): Retain L1 blocks (#683)

---
 crates/derive/src/stages/batch_queue.rs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/crates/derive/src/stages/batch_queue.rs b/crates/derive/src/stages/batch_queue.rs
index 0fa9d3b12..cf59b0eb0 100644
--- 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());
     }