diff --git a/apps/webapp/app/env.server.ts b/apps/webapp/app/env.server.ts index 543f13ddb8..e20292277e 100644 --- a/apps/webapp/app/env.server.ts +++ b/apps/webapp/app/env.server.ts @@ -717,6 +717,11 @@ const EnvironmentSchema = z.object({ COMMON_WORKER_REDIS_TLS_DISABLED: z.string().default(process.env.REDIS_TLS_DISABLED ?? "false"), COMMON_WORKER_REDIS_CLUSTER_MODE_ENABLED: z.string().default("0"), + BATCH_TRIGGER_PROCESS_JOB_VISIBILITY_TIMEOUT_MS: z.coerce + .number() + .int() + .default(60_000 * 5), // 5 minutes + BATCH_TRIGGER_WORKER_ENABLED: z.string().default(process.env.WORKER_ENABLED ?? "true"), BATCH_TRIGGER_WORKER_CONCURRENCY_WORKERS: z.coerce.number().int().default(2), BATCH_TRIGGER_WORKER_CONCURRENCY_TASKS_PER_WORKER: z.coerce.number().int().default(10), diff --git a/apps/webapp/app/v3/batchTriggerWorker.server.ts b/apps/webapp/app/v3/batchTriggerWorker.server.ts index cd00a9c4c1..e199329389 100644 --- a/apps/webapp/app/v3/batchTriggerWorker.server.ts +++ b/apps/webapp/app/v3/batchTriggerWorker.server.ts @@ -34,7 +34,7 @@ function initializeWorker() { attemptCount: z.number().int(), strategy: z.enum(["sequential", "parallel"]), }), - visibilityTimeoutMs: 60_000, + visibilityTimeoutMs: env.BATCH_TRIGGER_PROCESS_JOB_VISIBILITY_TIMEOUT_MS, retry: { maxAttempts: 5, }, @@ -49,7 +49,7 @@ function initializeWorker() { parentRunId: z.string().optional(), resumeParentOnCompletion: z.boolean().optional(), }), - visibilityTimeoutMs: 60_000, + visibilityTimeoutMs: env.BATCH_TRIGGER_PROCESS_JOB_VISIBILITY_TIMEOUT_MS, retry: { maxAttempts: 5, },