fix(cannon): Prevent checkpoint iterators going beyond head of chain

ethpandaops · Sep 29, 2023 · d118020 · d118020
1 parent 6210659
commit d118020
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/cannon/iterator/checkpoint_iterator.go b/pkg/cannon/iterator/checkpoint_iterator.go
@@ -82,7 +82,7 @@ func (c *CheckpointIterator) Next(ctx context.Context) (next *xatu.CannonLocatio
 
 		c.metrics.SetTrailingEpochs(c.cannonType.String(), c.networkName, c.checkpointName, float64(checkpoint.Epoch-locationEpoch))
 
-		if locationEpoch == checkpoint.Epoch {
+		if locationEpoch >= checkpoint.Epoch {
 			// Sleep until the next epoch
 			epoch := c.wallclock.Epochs().Current()