Handle not ready error gracefully in participator

Back off and get a fresh token if F3 is not ready.
filecoin-project · Oct 8, 2024 · 73359d6 · 73359d6
1 parent f1e21bf
commit 73359d6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/api/api_errors.go b/api/api_errors.go
@@ -36,7 +36,7 @@ var (
 	// ErrF3ParticipationTicketStartBeforeExisting signals that participation ticket
 	// is before the start instance of an existing lease held by the miner.
 	ErrF3ParticipationTicketStartBeforeExisting = errF3ParticipationTicketStartBeforeExisting{}
-	// ErrF3NotREady signals that the F3 instance isn't ready for participation yet. The caller
+	// ErrF3NotReady signals that the F3 instance isn't ready for participation yet. The caller
 	// should back off and try again later.
 	ErrF3NotReady = errF3NotReady{}
 

diff --git a/node/modules/storageminer.go b/node/modules/storageminer.go
@@ -440,6 +440,10 @@ func (p *f3Participator) tryF3Participate(ctx context.Context, ticket api.F3Part
 			p.backOff(ctx)
 			log.Debugw("Reattempting F3 participation with the same ticket.", "attempts", p.backoff.Attempt())
 			continue
+		case errors.Is(err, api.ErrF3NotReady):
+			log.Warnw("F3 is not ready. Retrying F3 participation after backoff.", "backoff", p.backoff.Duration(), "err", err)
+			p.backOff(ctx)
+			continue
 		case err != nil:
 			log.Errorw("Unexpected error while attempting F3 participation. Retrying after backoff", "backoff", p.backoff.Duration(), "attempts", p.backoff.Attempt(), "err", err)
 			p.backOff(ctx)