diff --git a/lib/queue.js b/lib/queue.js index 8d72bc543..195e442ed 100755 --- a/lib/queue.js +++ b/lib/queue.js @@ -945,6 +945,10 @@ Queue.prototype.run = function(concurrency, handlerName) { at the next known delayed job. */ Queue.prototype.updateDelayTimer = function() { + if (this.closing) { + return Promise.resolve(); + } + return scripts .updateDelaySet(this, Date.now()) .then(nextTimestamp => {