Skip to content

Commit

Permalink
fix(worker): high-memory-usage-when-providing-float-to-concurrency (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
abdeljalil09 authored Jul 6, 2023
1 parent 47722ed commit dcca1e8
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions lib/queue.js
Original file line number Diff line number Diff line change
Expand Up @@ -912,6 +912,9 @@ Queue.prototype.isPaused = async function(isLocal) {
};

Queue.prototype.run = function(concurrency, handlerName) {
if(!Number.isInteger(concurrency)) {
throw new Error('Cannot set Float as concurrency');
}
const promises = [];

return this.isReady()
Expand Down

0 comments on commit dcca1e8

Please sign in to comment.