JOJ/JOJ3
24
5
Fork 0
Code Issues 5 Pull Requests Actions Packages Projects Releases Wiki Activity

fix: log typo

Browse Source
This commit is contained in:
张泊明518370910136 2024-09-12 18:47:16 -04:00
parent 967a859c9f
commit 5922d795b3
Signed by: 张泊明518370910136
GPG Key ID: D47306D7062CDA9D
1 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
internal/stage/run.go
View File

@ -5,32 +5,36 @@ import (
"log/slog" "log/slog"
) )
func Run(stages []Stage) ([]StageResult, error) { func Run(stages []Stage) (stageResults []StageResult, err error) {
stageResults := []StageResult{} var executorResults []ExecutorResult
var parserResults []ParserResult
var forceQuit bool
for _, stage := range stages { for _, stage := range stages {
slog.Debug("stage start", "name", stage.Name) slog.Debug("stage start", "name", stage.Name)
slog.Debug("executor run start", "cmds", stage.ExecutorCmds) slog.Debug("executor run start", "cmds", stage.ExecutorCmds)
executor, ok := executorMap[stage.ExecutorName] executor, ok := executorMap[stage.ExecutorName]
if !ok { if !ok {
slog.Error("executor not found", "name", stage.ExecutorName) slog.Error("executor not found", "name", stage.ExecutorName)
return stageResults, fmt.Errorf("executor not found: %s", stage.ExecutorName) err = fmt.Errorf("executor not found: %s", stage.ExecutorName)
return
} }
executorResults, err := executor.Run(stage.ExecutorCmds) executorResults, err = executor.Run(stage.ExecutorCmds)
if err != nil { if err != nil {
slog.Error("executor run error", "name", stage.ExecutorName, "error", err) slog.Error("executor run error", "name", stage.ExecutorName, "error", err)
return stageResults, err return
} }
slog.Debug("executor run done", "results", executorResults) slog.Debug("executor run done", "results", executorResults)
slog.Debug("parser run start", "conf", stage.ParserConf) slog.Debug("parser run start", "conf", stage.ParserConf)
parser, ok := parserMap[stage.ParserName] parser, ok := parserMap[stage.ParserName]
if !ok { if !ok {
slog.Error("parser not found", "name", stage.ParserName) slog.Error("parser not found", "name", stage.ParserName)
return stageResults, err err = fmt.Errorf("parser not found: %s", stage.ParserName)
return
} }
parserResults, forceQuit, err := parser.Run(executorResults, stage.ParserConf) parserResults, forceQuit, err = parser.Run(executorResults, stage.ParserConf)
if err != nil { if err != nil {
slog.Error("parser run error", "name", stage.ExecutorName, "error", err) slog.Error("parser run error", "name", stage.ParserName, "error", err)
return stageResults, err return
} }
slog.Debug("parser run done", "results", parserResults) slog.Debug("parser run done", "results", parserResults)
stageResults = append(stageResults, StageResult{ stageResults = append(stageResults, StageResult{
@ -39,11 +43,11 @@ func Run(stages []Stage) ([]StageResult, error) {
ForceQuit: forceQuit, ForceQuit: forceQuit,
}) })
if forceQuit { if forceQuit {
slog.Error("parser force quit", "name", stage.ExecutorName) slog.Error("parser force quit", "name", stage.ParserName)
break return
} }
} }
return stageResults, nil return
} }
func Cleanup() { func Cleanup() {