From c7e57cd28fb4ae307e64c3b4ff40513a7efdc226 Mon Sep 17 00:00:00 2001 From: Henry Oswald Date: Mon, 15 Feb 2021 14:16:45 +0000 Subject: [PATCH] add Dispatchers running on old queue while we migrate revert once migrated --- services/document-updater/app/js/DispatchManager.js | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/services/document-updater/app/js/DispatchManager.js b/services/document-updater/app/js/DispatchManager.js index c600adec7b..19942b67cf 100644 --- a/services/document-updater/app/js/DispatchManager.js +++ b/services/document-updater/app/js/DispatchManager.js @@ -110,5 +110,10 @@ module.exports = DispatchManager = { _.times(number, function (shardNumber) { return DispatchManager.createDispatcher(RateLimiter, shardNumber).run() }) + + // run extra dispatchers on old queue while we migrate + _.times(number, function () { + return DispatchManager.createDispatcher(RateLimiter, 0).run() + }) } }