From f53ab1b9ef78e652f6da93023b177dd8cfbb6f92 Mon Sep 17 00:00:00 2001 From: Olivier Louvignes Date: Thu, 30 May 2024 15:08:57 +0200 Subject: [PATCH] feat(update): minor changes --- src/PrismaQueue.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/PrismaQueue.ts b/src/PrismaQueue.ts index bca5514..6cc9719 100644 --- a/src/PrismaQueue.ts +++ b/src/PrismaQueue.ts @@ -123,14 +123,14 @@ export class PrismaQueue< return this.#prisma[queueJobKey]; } - public start(): void { + public async start(): Promise { debug(`starting queue named="${this.name}"...`); if (!this.stopped) { debug(`queue named="${this.name}" is already running, skipping...`); return; } this.stopped = false; - this.poll(); + return this.poll(); } public async stop(): Promise {