JOJ/JOJ3
25
6
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

feat: check executor & parser name

Browse Source
This commit is contained in:
张泊明518370910136 2024-03-12 16:20:14 -04:00
parent 8e49684abe
commit a5643c1556
Signed by: 张泊明518370910136
GPG Key ID: D47306D7062CDA9D
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/stage/run.go
View File

@ -12,7 +12,11 @@ func Run(stages []Stage) []StageResult {
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 := executorMap[stage.ExecutorName] executor, ok := executorMap[stage.ExecutorName]
if !ok {
slog.Error("executor not found", "name", stage.ExecutorName)
break
}
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)
@ -20,7 +24,11 @@ func Run(stages []Stage) []StageResult {
} }
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 := parserMap[stage.ParserName] parser, ok := parserMap[stage.ParserName]
if !ok {
slog.Error("parser not found", "name", stage.ParserName)
break
}
parserResults, end, err := parser.Run(executorResults, stage.ParserConf) parserResults, end, 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.ExecutorName, "error", err)