From 8b61b9bf9b270d49bb86d09c56bf4fa4bc30e462 Mon Sep 17 00:00:00 2001 From: Alexey Shekhirin Date: Mon, 16 Sep 2024 21:20:34 +0100 Subject: [PATCH] fix(exex): do not advance backfill range twice (#10942) --- crates/exex/exex/src/backfill/stream.rs | 3 --- 1 file changed, 3 deletions(-) diff --git a/crates/exex/exex/src/backfill/stream.rs b/crates/exex/exex/src/backfill/stream.rs index 6b6b6f0f8e..95744d2eb1 100644 --- a/crates/exex/exex/src/backfill/stream.rs +++ b/crates/exex/exex/src/backfill/stream.rs @@ -114,9 +114,6 @@ where let start = range.next(); let range_bounds = start.zip(range.last().or(start)); - // Advance the range by `batch_size` blocks - this.range.nth(this.batch_size); - // If we have range bounds, then we can spawn a new task for that range if let Some((first, last)) = range_bounds { let range = first..=last;