pdp: An actually working poller this time

filecoin-project · Oct 12, 2024 · 3691403 · 3691403
1 parent ae5089b
commit 3691403
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/tasks/pdp/proofset_challenge_watch.go b/tasks/pdp/proofset_challenge_watch.go
@@ -115,7 +115,7 @@ func updateNextChallengeEpoch(
 	_, err = db.Exec(ctx, `
         UPDATE pdp_proof_sets
         SET next_challenge_epoch = $1, next_challenge_possible = TRUE
-        WHERE id = $2 AND next_challenge_epoch IS NULL
+        WHERE id = $2 AND next_challenge_possible = FALSE
     `, nextChallengeEpochBigInt.Int64(), ps.ID)
 	if err != nil {
 		return xerrors.Errorf("failed to update next_challenge_epoch for proof set %d: %w", ps.ID, err)

diff --git a/tasks/pdp/prove_task.go b/tasks/pdp/prove_task.go
@@ -172,7 +172,7 @@ func (p *ProveTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done
 	}
 
 	// Number of challenges to generate
-	numChallenges := 1 // Application / pdp will specify this later
+	numChallenges := 5 // Application / pdp will specify this later
 
 	proofs, err := p.GenerateProofs(ctx, pdpService, proofSetID, challengeEpoch, numChallenges)
 	if err != nil {