File tree Expand file tree Collapse file tree 2 files changed +2
-0
lines changed Expand file tree Collapse file tree 2 files changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -384,6 +384,7 @@ const EnvironmentSchema = z.object({
384384 . int ( )
385385 . default ( 60 * 1000 * 15 ) ,
386386 MARQS_SHARED_QUEUE_LIMIT : z . coerce . number ( ) . int ( ) . default ( 1000 ) ,
387+ MARQS_MAXIMUM_QUEUE_PER_ENV_COUNT : z . coerce . number ( ) . int ( ) . default ( 50 ) ,
387388 MARQS_DEV_QUEUE_LIMIT : z . coerce . number ( ) . int ( ) . default ( 1000 ) ,
388389 MARQS_MAXIMUM_NACK_COUNT : z . coerce . number ( ) . int ( ) . default ( 64 ) ,
389390 MARQS_CONCURRENCY_LIMIT_BIAS : z . coerce . number ( ) . default ( 0.75 ) ,
Original file line number Diff line number Diff line change @@ -2189,6 +2189,7 @@ function getMarQSClient() {
21892189 } ,
21902190 reuseSnapshotCount : env . MARQS_REUSE_SNAPSHOT_COUNT ,
21912191 maximumEnvCount : env . MARQS_MAXIMUM_ENV_COUNT ,
2192+ maximumQueuePerEnvCount : env . MARQS_MAXIMUM_QUEUE_PER_ENV_COUNT ,
21922193 } ) ,
21932194 envQueuePriorityStrategy : new FairDequeuingStrategy ( {
21942195 tracer : tracer ,
You can’t perform that action at this time.
0 commit comments