diff --git a/cmd/substreams-sink-noop/head_tracker.go b/cmd/substreams-sink-noop/head_tracker.go index b9fb266..34ca269 100644 --- a/cmd/substreams-sink-noop/head_tracker.go +++ b/cmd/substreams-sink-noop/head_tracker.go @@ -53,7 +53,9 @@ func (s *HeadTracker) Start() { go func() { activeCursor := "" - backOff := backoff.WithContext(backoff.NewExponentialBackOff(), ctx) + bo := backoff.NewExponentialBackOff() + bo.MaxElapsedTime = 0 + backOff := backoff.WithContext(bo, ctx) receivedMessage := false for {