fix: correct setting of worker options defaults

vendure-ecommerce · Nov 20, 2024 · b3d32f6 · b3d32f6
1 parent 40d4e9b
commit b3d32f6
Showing 1 changed file with 1 addition and 13 deletions.
diff --git a/packages/job-queue-plugin/src/bullmq/bullmq-job-queue-strategy.ts b/packages/job-queue-plugin/src/bullmq/bullmq-job-queue-strategy.ts
@@ -70,19 +70,7 @@ export class BullMQJobQueueStrategy implements InspectableJobQueueStrategy {
 
     async init(injector: Injector): Promise<void> {
         const options = this.initOptions(injector);
-        this.options = {
-            ...options,
-            workerOptions: {
-                removeOnComplete: options.workerOptions?.removeOnComplete ?? {
-                    age: 60 * 60 * 24 * 30,
-                    count: 5000,
-                },
-                removeOnFail: options.workerOptions?.removeOnFail ?? {
-                    age: 60 * 60 * 24 * 30,
-                    count: 5000,
-                },
-            },
-        };
+        this.options = options;
         this.connectionOptions =
             options.connection ??
             ({