diff --git a/pkg/cannon/iterator/checkpoint_iterator.go b/pkg/cannon/iterator/checkpoint_iterator.go
index 231ec83e..c775275f 100644
--- 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()