feat(job): expose queueName

taskforcesh · Jun 11, 2021 · 8683bd4 · 8683bd4
1 parent d621359
commit 8683bd4
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/src/classes/job.ts b/src/classes/job.ts
@@ -524,6 +524,10 @@ export class Job<T = any, R = any, N extends string = string> {
     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
@@ -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
@@ -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;