feat(stage): log score map from parsers
This commit is contained in:
parent
7af18aebe8
commit
ac9dfffa4c
|
@ -64,6 +64,10 @@ func Run(stages []Stage) (
|
||||||
"summary", SummarizeExecutorResults(executorResults),
|
"summary", SummarizeExecutorResults(executorResults),
|
||||||
)
|
)
|
||||||
parserResults = []ParserResult{}
|
parserResults = []ParserResult{}
|
||||||
|
scoresMap := map[string][]int{}
|
||||||
|
for _, stageParser := range stage.Parsers {
|
||||||
|
scoresMap[stageParser.Name] = make([]int, len(executorResults))
|
||||||
|
}
|
||||||
for _, stageParser := range stage.Parsers {
|
for _, stageParser := range stage.Parsers {
|
||||||
slog.Info(
|
slog.Info(
|
||||||
"parser run start",
|
"parser run start",
|
||||||
|
@ -96,7 +100,11 @@ func Run(stages []Stage) (
|
||||||
"name", stageParser.Name,
|
"name", stageParser.Name,
|
||||||
"error", err,
|
"error", err,
|
||||||
)
|
)
|
||||||
return
|
forceQuitStageName = stage.Name
|
||||||
|
break
|
||||||
|
}
|
||||||
|
for i, parserResult := range tmpParserResults {
|
||||||
|
scoresMap[stageParser.Name][i] += parserResult.Score
|
||||||
}
|
}
|
||||||
if parserForceQuit {
|
if parserForceQuit {
|
||||||
slog.Error(
|
slog.Error(
|
||||||
|
@ -126,6 +134,7 @@ func Run(stages []Stage) (
|
||||||
Results: parserResults,
|
Results: parserResults,
|
||||||
ForceQuit: forceQuitStageName != "",
|
ForceQuit: forceQuitStageName != "",
|
||||||
})
|
})
|
||||||
|
slog.Info("stage done", "name", stage.Name, "parser scores", scoresMap)
|
||||||
if forceQuitStageName != "" {
|
if forceQuitStageName != "" {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user