Merge pull request activepieces#4063 from activepieces/fix/timeout

fix: increase update flow timeout to 30 seconds
alan-eu · Feb 29, 2024 · 4cfc515 · 4cfc515
2 parents 793c2d1 + 8c86b6b
commit 4cfc515
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/packages/server/api/src/app/ee/helper/redis-system-job.ts b/packages/server/api/src/app/ee/helper/redis-system-job.ts
@@ -13,6 +13,7 @@ const useRedis = system.get(SystemProp.QUEUE_MODE) === QueueMode.REDIS
 type SystemJobHandler = (data: Job<SystemJobData, unknown>) => Promise<void>
 
 let systemJobsQueue: Queue<SystemJobData, unknown>
+let systemJobWorker: Worker<SystemJobData, unknown>
 const SYSTEM_JOB_QUEUE = 'system-job-queue'
 
 const handlers: Record<string, SystemJobHandler> = {}
@@ -37,7 +38,7 @@ export const redisSystemJob = {
         )
         await systemJobsQueue.waitUntilReady()
 
-        const systemJobWorker = new Worker<SystemJobData, unknown, ApId>(
+        systemJobWorker = new Worker<SystemJobData, unknown, ApId>(
             SYSTEM_JOB_QUEUE,
             async (job) => {
                 const handlerFn = handlers[job.name]
@@ -75,6 +76,7 @@ export const redisSystemJob = {
         if (isNil(systemJobsQueue)) {
             return
         }
+        await systemJobWorker.close()
         await systemJobsQueue.close()
     },
 }
diff --git a/packages/server/api/src/app/flows/flow/flow.service.ts b/packages/server/api/src/app/flows/flow/flow.service.ts
@@ -185,7 +185,7 @@ export const flowService = {
         const flowLock = lock
             ? await acquireLock({
                 key: id,
-                timeout: 10000,
+                timeout: 30000,
             })
             : null