From 0d4b5c89b00f5321deb03fe3e8747d5bb94c8846 Mon Sep 17 00:00:00 2001 From: Adil Date: Wed, 4 Sep 2024 17:51:53 +0200 Subject: [PATCH] fix: Renamed the `JobSchedulerService` queue's name - Renamed from `scheduled-jobs:queue` to `scheduled-jobs-queue`, this is due to the BullMQ [v5.12.12](https://github.com/taskforcesh/bullmq/compare/v5.12.11...v5.12.12) update that throws an error whenever a Queue has a semicolon in its name --- packages/medusa/src/services/__tests__/job-scheduler.js | 2 +- packages/medusa/src/services/job-scheduler.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/medusa/src/services/__tests__/job-scheduler.js b/packages/medusa/src/services/__tests__/job-scheduler.js index cb0375b49aec4..b51953fdc95bb 100644 --- a/packages/medusa/src/services/__tests__/job-scheduler.js +++ b/packages/medusa/src/services/__tests__/job-scheduler.js @@ -32,7 +32,7 @@ describe("JobSchedulerService", () => { it("creates bull queue", () => { expect(Queue).toHaveBeenCalledTimes(1) - expect(Queue).toHaveBeenCalledWith("scheduled-jobs:queue", { + expect(Queue).toHaveBeenCalledWith("scheduled-jobs-queue", { connection: expect.any(Object), prefix: "JobSchedulerService", }) diff --git a/packages/medusa/src/services/job-scheduler.ts b/packages/medusa/src/services/job-scheduler.ts index 62f89b709f7eb..df42497db4e43 100644 --- a/packages/medusa/src/services/job-scheduler.ts +++ b/packages/medusa/src/services/job-scheduler.ts @@ -45,14 +45,14 @@ export default class JobSchedulerService { ...(config.projectConfig.redis_options ?? {}), }) - this.queue_ = new Queue(`scheduled-jobs:queue`, { + this.queue_ = new Queue(`scheduled-jobs-queue`, { connection, prefix, }) // Register scheduled job worker this.worker_ = new Worker( - "scheduled-jobs:queue", + "scheduled-jobs-queue", this.scheduledJobsWorker, { connection,