Skip to content

Commit b0112fd

Browse files
committed
Set the marqs maximumQueuePerEnvCount
1 parent b674ba9 commit b0112fd

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

apps/webapp/app/env.server.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff 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),

apps/webapp/app/v3/marqs/index.server.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff 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,

0 commit comments

Comments
 (0)