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

simllll · simllll · commit eff80aa60de3 · 2020-10-23T18:00:48.000+02:00
diff --git a/src/JobProcessor.ts b/src/JobProcessor.ts
@@ -339,6 +339,7 @@ export class JobProcessor {
 			}
 		} catch (error) {
 			log.extend('jobQueueFilling')('[%s] job lock failed while filling queue', name, error);
+			this.agenda.emit('error', error);
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -339,6 +339,7 @@ export class JobProcessor {`
`339`	`339`	`}`
`340`	`340`	`} catch (error) {`
`341`	`341`	`log.extend('jobQueueFilling')('[%s] job lock failed while filling queue', name, error);`
	`342`	`+ this.agenda.emit('error', error);`
`342`	`343`	`}`
`343`	`344`	`}`
`344`	`345`