From 346e3a55f84caca59e090d7355e2b577d9f8955e Mon Sep 17 00:00:00 2001 From: devaraj Date: Mon, 11 Apr 2022 12:22:13 +0100 Subject: [PATCH 1/4] chore(config_update): update bull config --- src/worker/index.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/worker/index.js b/src/worker/index.js index 689b859a..b11489b7 100644 --- a/src/worker/index.js +++ b/src/worker/index.js @@ -46,13 +46,13 @@ const opts = { }, redis: { maxRetriesPerRequest: null, enableReadyCheck: false }, settings: { - lockDuration: 45000, - lockRenewTime: 22500, - stalledInterval: 30000, + lockDuration: 60000, + lockRenewTime: 30000, + stalledInterval: 15000, maxStalledCount: 1 }, defaultJobOptions: { - stackTraceLimit: 20 + stackTraceLimit: 10 }, createClient: function (type, redisOpts) { switch (type) { From 0565e0b95e515c95ba5fdff829ca5df32dde94bf Mon Sep 17 00:00:00 2001 From: devaraj Date: Mon, 11 Apr 2022 12:32:01 +0100 Subject: [PATCH 2/4] chore(config_update): added new retry error --- src/worker/index.js | 1 + 1 file changed, 1 insertion(+) diff --git a/src/worker/index.js b/src/worker/index.js index b11489b7..53d49172 100644 --- a/src/worker/index.js +++ b/src/worker/index.js @@ -30,6 +30,7 @@ const checkJobForRetry = (err, job) => { (err.message.includes('timeout of 30000ms exceeded') || err.message.includes('Request failed with status code 400') || err.message.includes('Request failed with status code 502') || + err.message.includes('Server selection timed out after 30000 ms') || err.message.includes('connection timed out')) ) { return true From 99891681f895430ba2abf17281e96c510795b4f5 Mon Sep 17 00:00:00 2001 From: devaraj Date: Mon, 11 Apr 2022 12:36:25 +0100 Subject: [PATCH 3/4] chore(config_update): updated priority to 1 for updatemarketData --- src/worker/index.js | 1 + 1 file changed, 1 insertion(+) diff --git a/src/worker/index.js b/src/worker/index.js index 53d49172..e5194364 100644 --- a/src/worker/index.js +++ b/src/worker/index.js @@ -85,6 +85,7 @@ const addUniqueJob = (q, name, data = {}, opts = {}) => { groupBy: 'market-data' }, { + priority: 1, removeOnComplete: true, jobId: 'update-market-data-job' } From 71cb8406fed51316a6f8feb2fa8303dd4d638731 Mon Sep 17 00:00:00 2001 From: devaraj Date: Mon, 11 Apr 2022 14:09:38 +0100 Subject: [PATCH 4/4] chore(config_update): updated priority to 1 for updatemarketData --- src/worker/index.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/worker/index.js b/src/worker/index.js index e5194364..9042b496 100644 --- a/src/worker/index.js +++ b/src/worker/index.js @@ -49,7 +49,7 @@ const opts = { settings: { lockDuration: 60000, lockRenewTime: 30000, - stalledInterval: 15000, + stalledInterval: 45000, maxStalledCount: 1 }, defaultJobOptions: {