[fix][backend] restore FailRetry logic to skip completed evaluators (#402)

Lysssyo · Lysssyo · web-flow · commit 9866134ff3db · 2026-01-23T11:46:20.000+08:00
fix(worker): restore FailRetry logic to skip completed evaluators

Co-authored-by: Lysssyo &lt;11906167+lysssyo@user.noreply.gitee.com&gt;
diff --git a/backend/modules/evaluation/domain/service/expt_result_impl.go b/backend/modules/evaluation/domain/service/expt_result_impl.go
@@ -120,7 +120,7 @@ func (e ExptResultServiceImpl) GetExptItemTurnResults(ctx context.Context, exptI
 		if turnEvaluatorVerIDToResultID[ref.ExptTurnResultID] == nil {
 			turnEvaluatorVerIDToResultID[ref.ExptTurnResultID] = make(map[int64]int64)
 		}
-		turnEvaluatorVerIDToResultID[ref.ExptTurnResultID][ref.EvaluatorVersionID] = ref.EvaluatorVersionID
+		turnEvaluatorVerIDToResultID[ref.ExptTurnResultID][ref.EvaluatorVersionID] = ref.EvaluatorResultID
 	}
 
 	res := make([]*entity.ExptTurnResult, 0, len(turnResults))
diff --git a/backend/modules/evaluation/domain/service/expt_run_item_impl.go b/backend/modules/evaluation/domain/service/expt_run_item_impl.go
@@ -260,7 +260,7 @@ func (e *ExptItemEvalCtxExecutor) buildExptTurnEvalCtx(ctx context.Context, turn
 		}
 		recordMap := make(map[int64]*entity.EvaluatorRecord)
 		for _, record := range evaluatorRecords {
-			recordMap[record.ID] = record
+			recordMap[record.EvaluatorVersionID] = record
 		}
 		etec.ExptTurnRunResult.EvaluatorResults = recordMap
 	}

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ func (e ExptResultServiceImpl) GetExptItemTurnResults(ctx context.Context, exptI`
`120`	`120`	`if turnEvaluatorVerIDToResultID[ref.ExptTurnResultID] == nil {`
`121`	`121`	`turnEvaluatorVerIDToResultID[ref.ExptTurnResultID] = make(map[int64]int64)`
`122`	`122`	`}`
`123`		`- turnEvaluatorVerIDToResultID[ref.ExptTurnResultID][ref.EvaluatorVersionID] = ref.EvaluatorVersionID`
	`123`	`+ turnEvaluatorVerIDToResultID[ref.ExptTurnResultID][ref.EvaluatorVersionID] = ref.EvaluatorResultID`
`124`	`124`	`}`
`125`	`125`
`126`	`126`	`res := make([]*entity.ExptTurnResult, 0, len(turnResults))`
Original file line number	Diff line number	Diff line change
`@@ -260,7 +260,7 @@ func (e *ExptItemEvalCtxExecutor) buildExptTurnEvalCtx(ctx context.Context, turn`
`260`	`260`	`}`
`261`	`261`	`recordMap := make(map[int64]*entity.EvaluatorRecord)`
`262`	`262`	`for _, record := range evaluatorRecords {`
`263`		`- recordMap[record.ID] = record`
	`263`	`+ recordMap[record.EvaluatorVersionID] = record`
`264`	`264`	`}`
`265`	`265`	`etec.ExptTurnRunResult.EvaluatorResults = recordMap`
`266`	`266`	`}`