Fix poll limit

jakeloo · jakeloo · commit aa8a6ee25da8 · 2025-08-29T09:32:35.000Z
diff --git a/internal/orchestrator/poller.go b/internal/orchestrator/poller.go
@@ -288,7 +288,13 @@ func (p *Poller) stageResults(blockData []common.BlockData) error {
 }
 
 func (p *Poller) reachedPollLimit(blockNumber *big.Int) bool {
-	return blockNumber == nil || (p.pollUntilBlock.Sign() > 0 && blockNumber.Cmp(p.pollUntilBlock) >= 0)
+	if blockNumber == nil {
+		return true
+	}
+	if p.pollUntilBlock == nil || p.pollUntilBlock.Sign() == 0 {
+		return false
+	}
+	return blockNumber.Cmp(p.pollUntilBlock) >= 0
 }
 
 func (p *Poller) getNextBlockRange(ctx context.Context) ([]*big.Int, error) {

Original file line number	Diff line number	Diff line change
`@@ -288,7 +288,13 @@ func (p *Poller) stageResults(blockData []common.BlockData) error {`
`288`	`288`	`}`
`289`	`289`
`290`	`290`	`func (p Poller) reachedPollLimit(blockNumber big.Int) bool {`
`291`		`- return blockNumber == nil \|\| (p.pollUntilBlock.Sign() > 0 && blockNumber.Cmp(p.pollUntilBlock) >= 0)`
	`291`	`+ if blockNumber == nil {`
	`292`	`+ return true`
	`293`	`+ }`
	`294`	`+ if p.pollUntilBlock == nil \|\| p.pollUntilBlock.Sign() == 0 {`
	`295`	`+ return false`
	`296`	`+ }`
	`297`	`+ return blockNumber.Cmp(p.pollUntilBlock) >= 0`
`292`	`298`	`}`
`293`	`299`
`294`	`300`	`func (p Poller) getNextBlockRange(ctx context.Context) ([]big.Int, error) {`