Skip to content

Commit f53ab1b

Browse files
committed
feat(update): minor changes
1 parent 6c10318 commit f53ab1b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/PrismaQueue.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -123,14 +123,14 @@ export class PrismaQueue<
123123
return this.#prisma[queueJobKey];
124124
}
125125

126-
public start(): void {
126+
public async start(): Promise<void> {
127127
debug(`starting queue named="${this.name}"...`);
128128
if (!this.stopped) {
129129
debug(`queue named="${this.name}" is already running, skipping...`);
130130
return;
131131
}
132132
this.stopped = false;
133-
this.poll();
133+
return this.poll();
134134
}
135135

136136
public async stop(): Promise<void> {

0 commit comments

Comments
 (0)