feat(medusa): Allow configuring of staged job polling batch size (#6333)

medusajs · Feb 7, 2024 · 82c728b · 82c728b
1 parent 44470bf
commit 82c728b
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 2 deletions.
diff --git a/.changeset/odd-keys-retire.md b/.changeset/odd-keys-retire.md
@@ -0,0 +1,6 @@
+---
+"@medusajs/medusa": patch
+"@medusajs/types": patch
+---
+
+feat(medusa): Allow configuring of staged job polling batch size
diff --git a/packages/medusa/src/services/event-bus.ts b/packages/medusa/src/services/event-bus.ts
@@ -38,7 +38,7 @@ export default class EventBusService
 
   constructor(
     { stagedJobService, logger }: InjectedDependencies,
-    config,
+    config: ConfigModule,
     isSingleton = true
   ) {
     // eslint-disable-next-line prefer-rest-params
@@ -201,7 +201,7 @@ export default class EventBusService
     const listConfig = {
       relations: [],
       skip: 0,
-      take: 1000,
+      take: this.config_.projectConfig.jobs_batch_size ?? 1000,
     }
 
     while (this.shouldEnqueuerRun) {

diff --git a/packages/types/src/common/config-module.ts b/packages/types/src/common/config-module.ts
@@ -467,6 +467,22 @@ export type ProjectConfigOptions = {
    * ```
    */
   http_compression?: HttpCompressionOptions
+
+  /**
+   * Configure the number of staged jobs that are polled from the database. Default is 1000.
+   * 
+   * @example
+   * ```js title="medusa-config.js"
+   * module.exports = {
+   *   projectConfig: {
+   *     jobs_batch_size: 100
+   *     // ...
+   *   },
+   *   // ...
+   * }
+   * ```
+   */
+  jobs_batch_size?: number
 }
 
 /**