fix: check if lockedAt has been resetted in the meantime

hokify · May 23, 2022 · aa5323b · aa5323b
1 parent 8e3b827
commit aa5323b
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/JobProcessor.ts b/src/JobProcessor.ts
@@ -525,6 +525,15 @@ export class JobProcessor {
 								return;
 							}
 
+							if (!job.attrs.lockedAt) {
+								reject(
+									new Error(
+										`execution of '${job.attrs.name}' canceled, no lockedAt date found. Ensure to call touch() for long running jobs to keep them alive.`
+									)
+								);
+								return;
+							}
+
 							resolve(checkIfJobIsStillAlive());
 						}, Math.max(this.processEvery / 2, this.agenda.definitions[job.attrs.name].lockLifetime / 2));
 					});