Skip to content
Snippets Groups Projects
Commit 46943a9a authored by Yordan Kinkov's avatar Yordan Kinkov
Browse files

#13 task list executor function fix

parent 5bddb39d
No related branches found
No related tags found
1 merge request!8Sequential Task List executor
Pipeline #51139 failed with stage
in 29 seconds
{
"name": "example",
"cacheNamespace": "login",
"cacheScope": "user",
"groups": [
{
"execution": "sequential",
"tasks": [
"task1",
"task2"
]
},
{
"execution": "parallel",
"tasks": [
"task3",
"task4",
"task5"
]
}
]
}
\ No newline at end of file
......@@ -123,13 +123,12 @@ func (l *ListExecutor) Execute(ctx context.Context, list *tasklist.TaskList) {
list.StartTime = time.Now()
// execute groups sequentially
for i, group := range list.Groups {
if err := l.executeGroup(ctx, &group); err != nil {
for i, _ := range list.Groups {
if err := l.executeGroup(ctx, &list.Groups[i]); err != nil {
logger.Error("error executing group", zap.Error(err))
group.State = taskpkg.Failed
list.Groups[i].State = taskpkg.Failed
list.State = taskpkg.Failed
}
list.Groups[i] = group
}
if list.State != taskpkg.Failed {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment