diff --git a/packages/twenty-server/src/engine/metadata-modules/cron-trigger/crons/jobs/cron-trigger.cron.job.ts b/packages/twenty-server/src/engine/metadata-modules/cron-trigger/crons/jobs/cron-trigger.cron.job.ts
index 153b7ea9c6..65527931a1 100644
--- a/packages/twenty-server/src/engine/metadata-modules/cron-trigger/crons/jobs/cron-trigger.cron.job.ts
+++ b/packages/twenty-server/src/engine/metadata-modules/cron-trigger/crons/jobs/cron-trigger.cron.job.ts
@@ -10,8 +10,8 @@ import { Process } from 'src/engine/core-modules/message-queue/decorators/proces
 import { Processor } from 'src/engine/core-modules/message-queue/decorators/processor.decorator';
 import { MessageQueue } from 'src/engine/core-modules/message-queue/message-queue.constants';
 import { MessageQueueService } from 'src/engine/core-modules/message-queue/services/message-queue.service';
-import { CronTriggerEntity } from 'src/engine/metadata-modules/cron-trigger/entities/cron-trigger.entity';
 import { WorkspaceEntity } from 'src/engine/core-modules/workspace/workspace.entity';
+import { CronTriggerEntity } from 'src/engine/metadata-modules/cron-trigger/entities/cron-trigger.entity';
 import {
   ServerlessFunctionTriggerJob,
   ServerlessFunctionTriggerJobData,
@@ -63,13 +63,15 @@ export class CronTriggerCronJob {
           continue;
         }
 
-        await this.messageQueueService.add<ServerlessFunctionTriggerJobData>(
+        await this.messageQueueService.add<ServerlessFunctionTriggerJobData[]>(
           ServerlessFunctionTriggerJob.name,
-          {
-            serverlessFunctionId: cronTrigger.serverlessFunction.id,
-            workspaceId: cronTrigger.workspaceId,
-            payload: {},
-          },
+          [
+            {
+              serverlessFunctionId: cronTrigger.serverlessFunction.id,
+              workspaceId: cronTrigger.workspaceId,
+              payload: {},
+            },
+          ],
           { retryLimit: 3 },
         );
       }