From f0871b4e43ac900ff8812ebdcf176b86ace835e4 Mon Sep 17 00:00:00 2001 From: stanley2058 Date: Thu, 9 Jan 2025 19:42:43 +0800 Subject: [PATCH 1/2] fix: lower timeout & use as interval --- src/api.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/api.js b/src/api.js index 35b36e0..08690f8 100644 --- a/src/api.js +++ b/src/api.js @@ -109,7 +109,7 @@ export class Api { * After this timeout, a new worker will pick up the task * @todo rename this variable */ - this.redisWorkerTimeout = number.parseInt(env.getConf('redis-task-timeout') || '600000') + this.redisWorkerTimeout = number.parseInt(env.getConf('redis-task-timeout') || '1000') /** * Minimum lifetime of y* update messages in redis streams. */ @@ -357,7 +357,7 @@ export class Worker { try { const tasks = await client.consumeWorkerQueue(opts) if (tasks.length === 0 || (client.redisMinMessageLifetime > time.getUnixTime() + timeDiff - number.parseInt(tasks[0].id.split('-')[0]))) { - await promise.wait(client.redisMinMessageLifetime / 2) + await promise.wait(client.redisWorkerTimeout); } } catch (e) { console.error(e) From 02b476ba5d220f479eb92b041dc677ea4c26a486 Mon Sep 17 00:00:00 2001 From: stanley2058 Date: Thu, 9 Jan 2025 19:46:24 +0800 Subject: [PATCH 2/2] fix: lint --- src/api.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/api.js b/src/api.js index 08690f8..c629b41 100644 --- a/src/api.js +++ b/src/api.js @@ -357,7 +357,7 @@ export class Worker { try { const tasks = await client.consumeWorkerQueue(opts) if (tasks.length === 0 || (client.redisMinMessageLifetime > time.getUnixTime() + timeDiff - number.parseInt(tasks[0].id.split('-')[0]))) { - await promise.wait(client.redisWorkerTimeout); + await promise.wait(client.redisWorkerTimeout) } } catch (e) { console.error(e)