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

…216)
ethpandaops · Sep 29, 2023 · f7abb76 · f7abb76
1 parent 6210659
commit f7abb76
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()