From a08f7eb9931f63fe2e35e365e452a40813b09211 Mon Sep 17 00:00:00 2001 From: Nicolas Patry Date: Thu, 12 Sep 2024 17:26:53 +0200 Subject: [PATCH] Fixing flashdecoding (empty batch doesn't work). --- backends/v3/src/queue.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/backends/v3/src/queue.rs b/backends/v3/src/queue.rs index 2bbb6753..fc6c5390 100644 --- a/backends/v3/src/queue.rs +++ b/backends/v3/src/queue.rs @@ -436,6 +436,12 @@ impl State { batch_entries.insert(id, entry); } + // Empty batch + if batch_requests.is_empty() { + tracing::debug!("Filterered out all entries"); + return None; + } + // Final batch size let size = batch_requests.len() as u32; next_batch_span.record("batch_size", size);