fix(coordinator): fix the error in the incorrect call during database modification

xiaoranlu · xiaoranlu · commit 4ae46453d111 · 2024-12-17T14:41:48.000+08:00
diff --git a/coordinator/internal/logic/provertask/batch_prover_task.go b/coordinator/internal/logic/provertask/batch_prover_task.go
@@ -232,7 +232,7 @@ func (bp *BatchProverTask) formatProverTask(ctx context.Context, task *orm.Prove
 }
 
 func (bp *BatchProverTask) recoverActiveAttempts(ctx *gin.Context, batchTask *orm.Batch) {
-	if err := bp.chunkOrm.DecreaseActiveAttemptsByHash(ctx.Copy(), batchTask.Hash); err != nil {
+	if err := bp.batchOrm.DecreaseActiveAttemptsByHash(ctx.Copy(), batchTask.Hash); err != nil {
 		log.Error("failed to recover batch active attempts", "hash", batchTask.Hash, "error", err)
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -232,7 +232,7 @@ func (bp BatchProverTask) formatProverTask(ctx context.Context, task orm.Prove`
`232`	`232`	`}`
`233`	`233`
`234`	`234`	`func (bp BatchProverTask) recoverActiveAttempts(ctx gin.Context, batchTask *orm.Batch) {`
`235`		`- if err := bp.chunkOrm.DecreaseActiveAttemptsByHash(ctx.Copy(), batchTask.Hash); err != nil {`
	`235`	`+ if err := bp.batchOrm.DecreaseActiveAttemptsByHash(ctx.Copy(), batchTask.Hash); err != nil {`
`236`	`236`	`log.Error("failed to recover batch active attempts", "hash", batchTask.Hash, "error", err)`
`237`	`237`	`}`
`238`	`238`	`}`