diff --git a/bin/reth/src/commands/stage/run.rs b/bin/reth/src/commands/stage/run.rs index a055f5a4e0..8887a7ae02 100644 --- a/bin/reth/src/commands/stage/run.rs +++ b/bin/reth/src/commands/stage/run.rs @@ -157,7 +157,7 @@ impl Command { .await?; } - let batch_size = self.batch_size.unwrap_or(self.to - self.from + 1); + let batch_size = self.batch_size.unwrap_or(self.to.saturating_sub(self.from) + 1); let etl_config = EtlConfig::new( Some(