diff --git a/packages/twenty-server/src/engine/integrations/message-queue/drivers/bullmq.driver.ts b/packages/twenty-server/src/engine/integrations/message-queue/drivers/bullmq.driver.ts
index be282e726..fc78eaabb 100644
--- a/packages/twenty-server/src/engine/integrations/message-queue/drivers/bullmq.driver.ts
+++ b/packages/twenty-server/src/engine/integrations/message-queue/drivers/bullmq.driver.ts
@@ -1,4 +1,4 @@
-import { Queue, QueueOptions, Worker } from 'bullmq';
+import { JobsOptions, Queue, QueueOptions, Worker } from 'bullmq';
 
 import {
   QueueCronJobOptions,
@@ -63,10 +63,12 @@ export class BullMQDriver implements MessageQueueDriver {
         `Queue ${queueName} is not registered, make sure you have added it as a queue provider`,
       );
     }
-    const queueOptions = {
+    const queueOptions: JobsOptions = {
       jobId: options?.id,
       priority: options?.priority,
       repeat: options?.repeat,
+      removeOnComplete: 100,
+      removeOnFail: 500,
     };
 
     await this.queueMap[queueName].add(jobName, data, queueOptions);
@@ -93,10 +95,12 @@ export class BullMQDriver implements MessageQueueDriver {
         `Queue ${queueName} is not registered, make sure you have added it as a queue provider`,
       );
     }
-    const queueOptions = {
+    const queueOptions: JobsOptions = {
       jobId: options?.id,
       priority: options?.priority,
       attempts: 1 + (options?.retryLimit || 0),
+      removeOnComplete: 100,
+      removeOnFail: 500,
     };
 
     await this.queueMap[queueName].add(jobName, data, queueOptions);