We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1545dcb commit 9f0fd15Copy full SHA for 9f0fd15
1 file changed
crates/batcher/src/types/batch_queue.rs
@@ -160,7 +160,7 @@ pub(crate) fn extract_batch_directly(
160
let mut batch_size = calculate_batch_size(batch_queue)?;
161
let mut rejected_entries = Vec::new();
162
163
- // Remove entries that won't pay enough (same logic as try_build_batch)
+ // Remove entries that won't pay enough, or that makes a queue that is too big
164
loop {
165
let should_remove = if let Some((entry, _)) = batch_queue.peek() {
166
let batch_len = batch_queue.len();
0 commit comments