diff options
Diffstat (limited to 'internal/executor/executor.go')
| -rw-r--r-- | internal/executor/executor.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/internal/executor/executor.go b/internal/executor/executor.go index 68ebdf3..d25d3b4 100644 --- a/internal/executor/executor.go +++ b/internal/executor/executor.go @@ -149,8 +149,13 @@ func (p *Pool) execute(ctx context.Context, t *task.Task) { p.store.UpdateTaskState(t.ID, task.StateFailed) } } else { - exec.Status = "COMPLETED" - p.store.UpdateTaskState(t.ID, task.StateCompleted) + if t.ParentTaskID == "" { + exec.Status = "READY" + p.store.UpdateTaskState(t.ID, task.StateReady) + } else { + exec.Status = "COMPLETED" + p.store.UpdateTaskState(t.ID, task.StateCompleted) + } } if updateErr := p.store.UpdateExecution(exec); updateErr != nil { |