diff options
Diffstat (limited to 'internal/executor/executor.go')
| -rw-r--r-- | internal/executor/executor.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/executor/executor.go b/internal/executor/executor.go index 9c4aac1..d2b476a 100644 --- a/internal/executor/executor.go +++ b/internal/executor/executor.go @@ -379,7 +379,7 @@ func (p *Pool) handleRunResult(ctx context.Context, t *task.Task, exec *storage. p.consecutiveFailures[agentType]++ failures := p.consecutiveFailures[agentType] p.mu.Unlock() - if failures >= 2 { + if failures >= 3 { p.mu.Lock() p.drained[agentType] = true p.mu.Unlock() |