fix(job-processor): emit error when db query fails

hokify · Oct 23, 2020 · 9bfabd3 · 9bfabd3
1 parent 88caf6a
commit 9bfabd3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/JobProcessor.ts b/src/JobProcessor.ts
@@ -510,7 +510,7 @@ export class JobProcessor {
 					job.attrs._id,
 					err
 				);
-				job.agenda.emit('error', err);
+				this.agenda.emit('error', err);
 			} finally {
 				// Remove the job from the running queue
 				let runningJobIndex = this.runningJobs.indexOf(job);