check if queue initialized before attempting to get job counts

nickbradley · Feb 15, 2017 · 6235fde · 6235fde
1 parent fbb953d
commit 6235fde
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/model/JobQueue.ts b/src/model/JobQueue.ts
@@ -114,6 +114,9 @@ export class JobQueue {
   }
 
   public async getJob(id: string): Promise<Job> {
+    if (!this.initialized) {
+      await this.init();
+    }
     return <Promise<Job>>this.queue.getJob(id);
   }
 
@@ -126,6 +129,9 @@ export class JobQueue {
 
   // WARNING: using private methods from bull!
   public async stats() {
+    if (!this.initialized) {
+      await this.init();
+    }
     let promises: Promise<number>[] = [];
     return new Promise((fulfill, reject) => {
       promises.push(this.queue.getCompletedCount());