fix retry panic

streamingfast · May 9, 2024 · d18b708 · d18b708
1 parent 1914572
commit d18b708
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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 {