fix(job): ensure agenda is ready before calling save job

hokify · Oct 20, 2020 · be4c026 · be4c026
1 parent 7d69680
commit be4c026
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/Job.ts b/src/Job.ts
@@ -170,6 +170,8 @@ export class Job<DATA = any | void> {
 	}
 
 	async save(): Promise<Job> {
+		// ensure db connection is ready
+		await this.agenda.ready;
 		return this.agenda.db.saveJob(this);
 	}
 

diff --git a/src/index.ts b/src/index.ts
@@ -63,7 +63,7 @@ export class Agenda extends EventEmitter {
 
 	private jobProcessor?: JobProcessor;
 
-	private ready: Promise<void>;
+	readonly ready: Promise<void>;
 
 	async getRunningStats(fullDetails = false): Promise<IAgendaStatus> {
 		if (!this.jobProcessor) {