houseassassin/twenty
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix "Level: Error serverlessFunctionPayloads.map is not a function" error (#17474)

Browse Source 
Fixes
[sentry](https://twenty-v7.sentry.io/issues/7123326406/?environment=prod&environment=prod-eu&project=4507072499810304&query=is%3Aunresolved%20%21issue.type%3A%5Bperformance_consecutive_db_queries%2Cperformance_consecutive_http%2Cperformance_file_io_main_thread%2Cperformance_db_main_thread%2Cperformance_n_plus_one_db_queries%2Cperformance_n_plus_one_api_calls%2Cperformance_p95_endpoint_regression%2Cperformance_slow_db_query%2Cperformance_render_blocking_asset_span%2Cperformance_uncompressed_assets%2Cperformance_http_overhead%2Cperformance_large_http_payload%5D%20timesSeen%3A%3E10&referrer=issue-stream&sort=date)

<img width="840" height="540" alt="image"
src="https://github.com/user-attachments/assets/40b70edf-48b0-4b49-a3eb-d4c7f726245e"
/>
This commit is contained in:
Marie
2026-01-27 14:03:46 +01:00
committed by GitHub
parent f06caae098
commit c5953c9d50
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/twenty-server/src/engine/metadata-modules/cron-trigger/crons/jobs/cron-trigger.cron.job.ts
+9 -7
View File
@@ -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 },
);
}