Fix: receiver retry

baking-bad · Jan 2, 2024 · 67d40ac · 67d40ac
1 parent f3900b4
commit 67d40ac
Showing 1 changed file with 12 additions and 8 deletions.
diff --git a/cmd/indexer/indexer/receiver.go b/cmd/indexer/indexer/receiver.go
@@ -93,14 +93,18 @@ func (r *Receiver) get(ctx context.Context, level int64) (Block, error) {
 }
 
 func (r *Receiver) job(ctx context.Context, level int64) {
-	block, err := r.get(ctx, level)
-	if err != nil {
-		if !errors.Is(err, context.Canceled) {
-			log.Err(err).Int64("block", level).Msg("Receiver.get")
-			r.pool.AddTask(level)
+	for {
+		block, err := r.get(ctx, level)
+		if err == nil {
+			r.blocks <- &block
+			r.inProcess.Delete(level)
+			break
 		}
-		return
+
+		if errors.Is(err, context.Canceled) {
+			return
+		}
+
+		log.Err(err).Int64("block", level).Msg("Receiver.get")
 	}
-	r.blocks <- &block
-	r.inProcess.Delete(level)
 }