From c30f416912bd2cf1249860ae57eba02e08e5de9a Mon Sep 17 00:00:00 2001 From: martmull Date: Wed, 12 Feb 2025 16:01:34 +0100 Subject: [PATCH] Add log (#10162) add log to fix issue in staging --- .../workflow-status/jobs/workflow-statuses-update.job.ts | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/packages/twenty-server/src/modules/workflow/workflow-status/jobs/workflow-statuses-update.job.ts b/packages/twenty-server/src/modules/workflow/workflow-status/jobs/workflow-statuses-update.job.ts index 9083a8e5e..3bf3dc31b 100644 --- a/packages/twenty-server/src/modules/workflow/workflow-status/jobs/workflow-statuses-update.job.ts +++ b/packages/twenty-server/src/modules/workflow/workflow-status/jobs/workflow-statuses-update.job.ts @@ -1,4 +1,4 @@ -import { Scope } from '@nestjs/common'; +import { Logger, Scope } from '@nestjs/common'; import { isDefined } from 'twenty-shared'; @@ -60,6 +60,8 @@ export type WorkflowVersionBatchDelete = { @Processor({ queueName: MessageQueue.workflowQueue, scope: Scope.REQUEST }) export class WorkflowStatusesUpdateJob { + protected readonly logger = new Logger(WorkflowStatusesUpdateJob.name); + constructor( private readonly twentyORMManager: TwentyORMManager, private readonly serverlessFunctionService: ServerlessFunctionService, @@ -172,6 +174,9 @@ export class WorkflowStatusesUpdateJob { // applied between draft and lastPublished version. // If no change have been applied, we just use the same // serverless function version + this.logger.warn( + `Error while publishing serverless function '${step.settings.input.serverlessFunctionId}': ${e}`, + ); } const serverlessFunction = @@ -186,6 +191,8 @@ export class WorkflowStatusesUpdateJob { serverlessFunction.latestVersion; newStep.settings = newStepSettings; + + this.logger.log(`New step computed for code step -> ${newStep}`); } newSteps.push(newStep); }