Update coordinator/internal/logic/provertask/chunk_prover_task.go

yiweichi · colinlyguo · web-flow · commit dd3c9e19c935 · 2025-01-09T17:23:16.000+08:00
Co-authored-by: colin &lt;102356659+colinlyguo@users.noreply.github.com&gt;
diff --git a/coordinator/internal/logic/provertask/chunk_prover_task.go b/coordinator/internal/logic/provertask/chunk_prover_task.go
@@ -65,7 +65,7 @@ func (cp *ChunkProverTask) Assign(ctx *gin.Context, getTaskParameter *coordinato
 	if strings.HasPrefix(taskCtx.ProverName, ExternalProverNamePrefix) {
 		unassignedChunkCount, getCountError := cp.chunkOrm.GetUnassignedChunkCount(ctx.Copy(), maxActiveAttempts, maxTotalAttempts, getTaskParameter.ProverHeight)
 		if getCountError != nil {
-			log.Error("failed to get unassigned chunk proving tasks count", "height", getTaskParameter.ProverHeight, "err", err)
+			log.Error("failed to get unassigned chunk proving tasks count", "height", getTaskParameter.ProverHeight, "err", getCountError)
 			return nil, ErrCoordinatorInternalFailure
 		}
 		// Assign external prover if unassigned task number exceeds threshold

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ func (cp ChunkProverTask) Assign(ctx gin.Context, getTaskParameter *coordinato`
`65`	`65`	`if strings.HasPrefix(taskCtx.ProverName, ExternalProverNamePrefix) {`
`66`	`66`	`unassignedChunkCount, getCountError := cp.chunkOrm.GetUnassignedChunkCount(ctx.Copy(), maxActiveAttempts, maxTotalAttempts, getTaskParameter.ProverHeight)`
`67`	`67`	`if getCountError != nil {`
`68`		`- log.Error("failed to get unassigned chunk proving tasks count", "height", getTaskParameter.ProverHeight, "err", err)`
	`68`	`+ log.Error("failed to get unassigned chunk proving tasks count", "height", getTaskParameter.ProverHeight, "err", getCountError)`
`69`	`69`	`return nil, ErrCoordinatorInternalFailure`
`70`	`70`	`}`
`71`	`71`	`// Assign external prover if unassigned task number exceeds threshold`