mirror of
https://github.com/simstudioai/sim.git
synced 2026-09-01 14:59:19 +08:00
fix(bullmq): disable temporarily (#3841)
This commit is contained in:
committed by
GitHub
parent
1728c370de
commit
c4f4e6b48c
@@ -1,8 +1,8 @@
|
||||
import type { ConnectionOptions } from 'bullmq'
|
||||
import { env } from '@/lib/core/config/env'
|
||||
import { env, isTruthy } from '@/lib/core/config/env'
|
||||
|
||||
export function isBullMQEnabled(): boolean {
|
||||
return Boolean(env.REDIS_URL)
|
||||
return isTruthy(env.CONCURRENCY_CONTROL_ENABLED) && Boolean(env.REDIS_URL)
|
||||
}
|
||||
|
||||
export function getBullMQConnectionOptions(): ConnectionOptions {
|
||||
|
||||
@@ -186,6 +186,7 @@ export const env = createEnv({
|
||||
FREE_PLAN_LOG_RETENTION_DAYS: z.string().optional(), // Log retention days for free plan users
|
||||
|
||||
// Admission & Burst Protection
|
||||
CONCURRENCY_CONTROL_ENABLED: z.string().optional().default('false'), // Set to 'true' to enable BullMQ-based concurrency control (default: inline execution)
|
||||
ADMISSION_GATE_MAX_INFLIGHT: z.string().optional().default('500'), // Max concurrent in-flight execution requests per pod
|
||||
DISPATCH_MAX_QUEUE_PER_WORKSPACE: z.string().optional().default('1000'), // Max queued dispatch jobs per workspace
|
||||
DISPATCH_MAX_QUEUE_GLOBAL: z.string().optional().default('50000'), // Max queued dispatch jobs globally
|
||||
|
||||
Reference in New Issue
Block a user