diff --git a/src/classes/job.ts b/src/classes/job.ts index b31b1dce07..6ee105e79e 100644 --- a/src/classes/job.ts +++ b/src/classes/job.ts @@ -524,6 +524,10 @@ export class Job { return (await this.isInList('wait')) || (await this.isInList('paused')); } + get queueName(): string { + return this.queue.name; + } + /** * @method getState * Get current state. diff --git a/src/classes/scripts.ts b/src/classes/scripts.ts index b98a6f035d..04d105f5ec 100644 --- a/src/classes/scripts.ts +++ b/src/classes/scripts.ts @@ -22,6 +22,7 @@ import { RedisClient } from './redis-connection'; export type MinimalQueue = Pick< QueueBase, + | 'name' | 'client' | 'toKey' | 'keys' diff --git a/src/test/test_flow.ts b/src/test/test_flow.ts index f1384d1a74..b7d3191f39 100644 --- a/src/test/test_flow.ts +++ b/src/test/test_flow.ts @@ -243,9 +243,11 @@ describe('flows', () => { expect(children[0].job.id).to.be.ok; expect(children[0].job.data.foo).to.be.eql('bar'); + expect(children[0].job.queueName).to.be.eql(queueName); expect(children[0].children).to.have.length(1); expect(children[0].children[0].job.id).to.be.ok; + expect(children[0].children[0].job.queueName).to.be.eql(queueName); expect(children[0].children[0].job.data.foo).to.be.eql('baz'); expect(children[0].children[0].children[0].job.id).to.be.ok;