From 024b7a09301d4fcf3c515280f03f2d8e0ab11ba7 Mon Sep 17 00:00:00 2001 From: Ben Beckford Date: Mon, 13 Jul 2026 04:34:29 -0700 Subject: [PATCH] chore(server): update sql and lint --- server/src/queries/workflow.repository.sql | 1 + server/src/services/workflow-execution.service.ts | 6 +++--- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/server/src/queries/workflow.repository.sql b/server/src/queries/workflow.repository.sql index c9129feeb8..260524e63d 100644 --- a/server/src/queries/workflow.repository.sql +++ b/server/src/queries/workflow.repository.sql @@ -101,6 +101,7 @@ where -- WorkflowRepository.getLogs select + "workflow_log"."id", "workflow_log"."createdAt", "workflow_log"."halted", "workflow_log"."error", diff --git a/server/src/services/workflow-execution.service.ts b/server/src/services/workflow-execution.service.ts index 75944f4eda..b3eef2a4ba 100644 --- a/server/src/services/workflow-execution.service.ts +++ b/server/src/services/workflow-execution.service.ts @@ -456,7 +456,7 @@ export class WorkflowExecutionService extends BaseService { const shouldContinue = result?.workflow?.continue ?? true; if (!shouldContinue) { if (workflow.logging) { - this.workflowRepository.log({ + await this.workflowRepository.log({ workflowId, error: false, halted: true, @@ -472,7 +472,7 @@ export class WorkflowExecutionService extends BaseService { this.logger.error(`Error executing workflow ${workflowId}:`, error); if (workflow.logging) { - this.workflowRepository.log({ + await this.workflowRepository.log({ workflowId, error: true, halted: false, @@ -486,7 +486,7 @@ export class WorkflowExecutionService extends BaseService { } if (workflow.logging) { - this.workflowRepository.log({ + await this.workflowRepository.log({ workflowId, error: false, halted: false,