fix(worker): throw error with invalid concurrency fixes #1723

Author: manast

src/classes/worker.ts

@@ -219,6 +219,8 @@ export class Worker<
  ...this.opts,
  };
 
+ this.concurrency = this.opts.concurrency;
+
  this.opts.lockRenewTime =
  this.opts.lockRenewTime || this.opts.lockDuration / 2;
 
@@ -339,6 +341,9 @@ export class Worker<
  }
 
  set concurrency(concurrency: number) {
+ if (typeof concurrency !== 'number' || concurrency < 1) {
+ throw new Error('concurrency must be a number greater than 0');
+ }
  this.opts.concurrency = concurrency;
  }
 

tests/test_worker.ts

@@ -1587,6 +1587,20 @@ describe('workers', function () {
  });
 
  describe('Concurrency process', () => {
+ it('should thrown an exception if I specify a concurrency of 0', () => {
+ try {
+ const worker = new Worker(queueName, async () => {}, {
+ connection,
+ concurrency: 0,
+ });
+ throw new Error('Should have thrown an exception');
+ } catch (err) {
+ expect(err.message).to.be.equal(
+ 'concurrency must be a number greater than 0',
+ );
+ }
+ });
+
  it('should run job in sequence if I specify a concurrency of 1', async () => {
  let processing = false;