diff --git a/packages/core/src/job-queue/job-queue.ts b/packages/core/src/job-queue/job-queue.ts index 44fefaf548..0683985eef 100644 --- a/packages/core/src/job-queue/job-queue.ts +++ b/packages/core/src/job-queue/job-queue.ts @@ -99,7 +99,7 @@ export class JobQueue = object> { const isBuffered = await this.jobBufferService.add(job); if (!isBuffered) { - const addedJob = await this.jobQueueStrategy.add(job); + const addedJob = await this.jobQueueStrategy.add(job, options); return new SubscribableJob(addedJob, this.jobQueueStrategy); } else { const bufferedJob = new Job({