Increase batch trigger processing job visibility timeout (#2234)

Author: ericallam

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),

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,
         },