fix PoRep count

filecoin-project · Oct 7, 2024 · a54fa58 · a54fa58
1 parent 8d9b479
commit a54fa58
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/web/api/webrpc/pipeline_porep.go b/web/api/webrpc/pipeline_porep.go
@@ -244,8 +244,8 @@ func (a *WebRPC) PorepPipelineSummary(ctx context.Context) ([]PorepPipelineSumma
 		COUNT(*) FILTER (WHERE after_sdr = false) as CountSDR,
 		COUNT(*) FILTER (WHERE (after_tree_d = false OR after_tree_c = false OR after_tree_r = false) AND after_sdr = true) as CountTrees,
 		COUNT(*) FILTER (WHERE after_tree_r = true and after_precommit_msg = false) as CountPrecommitMsg,
-		COUNT(*) FILTER (WHERE after_precommit_msg_success = true AND seed_epoch > $1 AND after_porep = false AND task_id_porep IS NULL) as CountWaitSeed,
-		COUNT(*) FILTER (WHERE after_porep = false AND after_precommit_msg_success = true) as CountPoRep,
+		COUNT(*) FILTER (WHERE after_precommit_msg_success = true AND seed_epoch > $1) as CountWaitSeed,
+		COUNT(*) FILTER (WHERE after_porep = false AND after_precommit_msg_success = true AND seed_epoch < $1) as CountPoRep,
 		COUNT(*) FILTER (WHERE after_commit_msg_success = false AND after_porep = true) as CountCommitMsg,
 		COUNT(*) FILTER (WHERE after_commit_msg_success = true) as CountDone,
 		COUNT(*) FILTER (WHERE failed = true) as CountFailed