diff --git a/apps/api/internal/runner/admission.go b/apps/api/internal/runner/admission.go index 23b68d3..2c1660b 100644 --- a/apps/api/internal/runner/admission.go +++ b/apps/api/internal/runner/admission.go @@ -33,6 +33,7 @@ const ( asyncWorkerCapacityScopeKey = "global" asyncWorkerQueueLimit = 10000 asyncWorkerMaxWaitSeconds = 24 * 60 * 60 + asyncAdmissionBatchMax = 8 acceptanceQueueLimit = 10000 acceptanceQueueMaxWait = 15 * 60 synchronousAdmissionWakeMax = 256 @@ -707,8 +708,8 @@ func (s *Service) dispatchWaitingAsyncAdmissions(ctx context.Context) { if batchLimit <= 0 { batchLimit = 64 } - if batchLimit > 128 { - batchLimit = 128 + if batchLimit > asyncAdmissionBatchMax { + batchLimit = asyncAdmissionBatchMax } taskIDs, err := s.store.ListWaitingAsyncAdmissionTaskIDs(ctx, batchLimit) if err != nil {