diff options
| -rw-r--r-- | internal/executor/executor.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/internal/executor/executor.go b/internal/executor/executor.go index 0ad9da9..fbe29a8 100644 --- a/internal/executor/executor.go +++ b/internal/executor/executor.go @@ -518,8 +518,10 @@ func (p *Pool) handleRunResult(ctx context.Context, t *task.Task, exec *storage. if err := p.store.UpdateTaskState(t.ID, task.StateReady); err != nil { p.logger.Error("failed to update task state", "taskID", t.ID, "state", task.StateReady, "error", err) } + if agentType != "local" { go p.spawnCheckerTask(context.Background(), t, exec) } + } } else { exec.Status = "COMPLETED" if err := p.store.UpdateTaskState(t.ID, task.StateCompleted); err != nil { |