From 55a8d2d7247270e3b03757ae5923b6ffeb7d87bf Mon Sep 17 00:00:00 2001 From: Lysssyo <11906167+lysssyo@user.noreply.gitee.com> Date: Thu, 22 Jan 2026 13:46:16 +0800 Subject: [PATCH] fix(worker): restore FailRetry logic to skip completed evaluators --- backend/modules/evaluation/domain/service/expt_result_impl.go | 2 +- backend/modules/evaluation/domain/service/expt_run_item_impl.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/backend/modules/evaluation/domain/service/expt_result_impl.go b/backend/modules/evaluation/domain/service/expt_result_impl.go index e9150b7e5..ff9888901 100644 --- 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 index da0aed996..94cdfb115 100644 --- 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 }