From 91b293fd497a4ef14cefdd335211dda7d86a9d9a Mon Sep 17 00:00:00 2001 From: Adria Navarro Date: Thu, 30 Nov 2023 12:22:05 +0100 Subject: [PATCH] Use new autoextend --- packages/server/src/appMigrations/queue.ts | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/packages/server/src/appMigrations/queue.ts b/packages/server/src/appMigrations/queue.ts index eae354ff50..3a364fe0f9 100644 --- a/packages/server/src/appMigrations/queue.ts +++ b/packages/server/src/appMigrations/queue.ts @@ -11,10 +11,6 @@ import environment from "../environment" const appMigrationQueue = queue.createQueue(queue.JobQueue.APP_MIGRATION) appMigrationQueue.process(processMessage) -// TODO -export const PROCESS_MIGRATION_TIMEOUT = - environment.APP_MIGRATION_TIMEOUT || 60000 - async function processMessage(job: Job) { const { appId } = job.data console.log(`Processing app migration for "${appId}"`) @@ -22,9 +18,9 @@ async function processMessage(job: Job) { await locks.doWithLock( { name: LockName.APP_MIGRATION, - type: LockType.DEFAULT, + type: LockType.AUTO_EXTEND, resource: appId, - ttl: PROCESS_MIGRATION_TIMEOUT, + ttl: 60000, }, async () => { await context.doInAppContext(appId, async () => {