From 7fde4944d8dedc1286d7bc408eb8d0fbc79928d7 Mon Sep 17 00:00:00 2001 From: martmull Date: Wed, 16 Jul 2025 17:23:21 +0200 Subject: [PATCH] Stop requesting all workflowRun columns to fix out of memory issue (#13241) Querying only useful columns in enqueue cron job --- .../cron/jobs/workflow-run-enqueue.cron.job.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/twenty-server/src/modules/workflow/workflow-runner/workflow-run-queue/cron/jobs/workflow-run-enqueue.cron.job.ts b/packages/twenty-server/src/modules/workflow/workflow-runner/workflow-run-queue/cron/jobs/workflow-run-enqueue.cron.job.ts index 3577d8dbb..8a8f440a0 100644 --- a/packages/twenty-server/src/modules/workflow/workflow-runner/workflow-run-queue/cron/jobs/workflow-run-enqueue.cron.job.ts +++ b/packages/twenty-server/src/modules/workflow/workflow-runner/workflow-run-queue/cron/jobs/workflow-run-enqueue.cron.job.ts @@ -76,7 +76,7 @@ export class WorkflowRunEnqueueJob { // Using raw query to avoid storing repository in cache const workflowRuns = await mainDataSource.query( - `SELECT * FROM ${schemaName}."workflowRun" WHERE status = '${WorkflowRunStatus.NOT_STARTED}' ORDER BY "createdAt" ASC`, + `SELECT id FROM ${schemaName}."workflowRun" WHERE status = '${WorkflowRunStatus.NOT_STARTED}' ORDER BY "createdAt" ASC`, ); const workflowRunsToEnqueueCount = Math.min(