From f362c6da10f5914289043125be8b0dac203c3680 Mon Sep 17 00:00:00 2001 From: Louis Garman Date: Tue, 21 Jan 2025 21:12:02 +0000 Subject: [PATCH] fix: runner job capacity exceeded again --- internal/runner/allocator.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/internal/runner/allocator.go b/internal/runner/allocator.go index 721a1b998..feffc4b25 100644 --- a/internal/runner/allocator.go +++ b/internal/runner/allocator.go @@ -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 {