diff --git a/packages/twenty-server/src/engine/core-modules/twenty-config/config-variables.ts b/packages/twenty-server/src/engine/core-modules/twenty-config/config-variables.ts index 6a2437d95..8ae97de52 100644 --- a/packages/twenty-server/src/engine/core-modules/twenty-config/config-variables.ts +++ b/packages/twenty-server/src/engine/core-modules/twenty-config/config-variables.ts @@ -987,7 +987,7 @@ export class ConfigVariables { type: ConfigVariableType.NUMBER, }) @CastToPositiveNumber() - WORKFLOW_EXEC_THROTTLE_LIMIT = 500; + WORKFLOW_EXEC_THROTTLE_LIMIT = 100; @ConfigVariablesMetadata({ group: ConfigVariablesGroup.RateLimiting, diff --git a/packages/twenty-server/src/modules/workflow/workflow-executor/workflow-actions/record-crud/create-record.workflow-action.ts b/packages/twenty-server/src/modules/workflow/workflow-executor/workflow-actions/record-crud/create-record.workflow-action.ts index d14bab433..1f18a2bc5 100644 --- a/packages/twenty-server/src/modules/workflow/workflow-executor/workflow-actions/record-crud/create-record.workflow-action.ts +++ b/packages/twenty-server/src/modules/workflow/workflow-executor/workflow-actions/record-crud/create-record.workflow-action.ts @@ -105,9 +105,15 @@ export class CreateRecordWorkflowAction implements WorkflowExecutor { workspaceId, ); + const validObjectRecord = Object.fromEntries( + Object.entries(workflowActionInput.objectRecord).filter( + ([key]) => objectMetadataItemWithFieldsMaps.fieldsByName[key], + ), + ); + const transformedObjectRecord = await this.recordInputTransformerService.process({ - recordInput: workflowActionInput.objectRecord, + recordInput: validObjectRecord, objectMetadataMapItem: objectMetadataItemWithFieldsMaps, });