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() + }) } }