Skip to content

Commit

Permalink
fix: runner job capacity exceeded again
Browse files Browse the repository at this point in the history
  • Loading branch information
leg100 committed Jan 21, 2025
1 parent 6ffab31 commit f362c6d
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions internal/runner/allocator.go
Original file line number Diff line number Diff line change
Expand Up @@ -72,12 +72,11 @@ func (a *allocator) Start(ctx context.Context) error {
case RunnerExited, RunnerErrored:
// Delete runners in terminal state.
a.deleteRunner(event.Payload)
default:
a.runners[event.Payload.ID] = event.Payload
}
a.addRunner(event.Payload)
case pubsub.DeletedEvent:
a.deleteRunner(event.Payload)
default:
a.runners[event.Payload.ID] = event.Payload
}
case event, open := <-jobsSub:
if !open {
Expand Down

0 comments on commit f362c6d

Please sign in to comment.