Add retry opt for asynq (#1167)

filecoin-project · Mar 16, 2023 · 0b22a8b · 0b22a8b
1 parent 37a20f6
commit 0b22a8b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/chain/indexer/distributed/queue/client.go b/chain/indexer/distributed/queue/client.go
@@ -45,7 +45,7 @@ func (r *AsynQ) EnqueueTipSet(ctx context.Context, ts *types.TipSet, indexType i
 		span.SetAttributes(attribute.String("task_type", task.Type()), attribute.StringSlice("tasks", taskNames), attribute.String("index_type", indexType.String()))
 	}
 
-	_, err = r.c.EnqueueContext(ctx, task, asynq.Queue(indexType.String()))
+	_, err = r.c.EnqueueContext(ctx, task, asynq.Queue(indexType.String()), asynq.MaxRetry(3))
 	if err != nil {
 		return err
 	}