diff --git a/.changeset/dirty-pears-smell.md b/.changeset/dirty-pears-smell.md new file mode 100644 index 0000000000..33363e291e --- /dev/null +++ b/.changeset/dirty-pears-smell.md @@ -0,0 +1,5 @@ +--- +"@medusajs/utils": patch +--- + +feat(config): Default event worker concurrency to 3 on cloud diff --git a/packages/core/utils/src/common/__tests__/define-config.spec.ts b/packages/core/utils/src/common/__tests__/define-config.spec.ts index 452d106bfa..c17593d919 100644 --- a/packages/core/utils/src/common/__tests__/define-config.spec.ts +++ b/packages/core/utils/src/common/__tests__/define-config.spec.ts @@ -1114,6 +1114,9 @@ describe("defineConfig", function () { "event_bus": { "options": { "redisUrl": "redis://localhost:6379", + "workerOptions": { + "concurrency": 3, + }, }, "resolve": "@medusajs/medusa/event-bus-redis", }, @@ -1338,6 +1341,9 @@ describe("defineConfig", function () { "event_bus": { "options": { "redisUrl": "redis://localhost:6379", + "workerOptions": { + "concurrency": 3, + }, }, "resolve": "@medusajs/medusa/event-bus-redis", }, @@ -1578,6 +1584,9 @@ describe("defineConfig", function () { "event_bus": { "options": { "redisUrl": "redis://localhost:6379", + "workerOptions": { + "concurrency": 3, + }, }, "resolve": "@medusajs/medusa/event-bus-redis", }, diff --git a/packages/core/utils/src/common/define-config.ts b/packages/core/utils/src/common/define-config.ts index 9cbff63bfe..26e88f36a8 100644 --- a/packages/core/utils/src/common/define-config.ts +++ b/packages/core/utils/src/common/define-config.ts @@ -271,7 +271,10 @@ function resolveModules( }, { resolve: TEMPORARY_REDIS_MODULE_PACKAGE_NAMES[Modules.EVENT_BUS], - options: { redisUrl: process.env.REDIS_URL }, + options: { + redisUrl: process.env.REDIS_URL, + workerOptions: { concurrency: 3 }, + }, }, { resolve: MODULE_PACKAGE_NAMES[Modules.LOCKING],