Remove useless columns (#13312)

packages/twenty-server/src/modules/workflow/common/standard-objects/workflow-run.workspace-entity.ts

@@ -161,27 +161,6 @@ export class WorkflowRunWorkspaceEntity extends BaseWorkspaceEntity {
   })
   createdBy: ActorMetadata;
 
-  @WorkspaceField({
-    standardId: WORKFLOW_RUN_STANDARD_FIELD_IDS.output,
-    type: FieldMetadataType.RAW_JSON,
-    label: msg`Output`,
-    description: msg`Json object to provide output of the workflow run`,
-    icon: 'IconText',
-  })
-  @WorkspaceIsNullable()
-  output: WorkflowRunOutput | null;
-
-  @WorkspaceField({
-    standardId: WORKFLOW_RUN_STANDARD_FIELD_IDS.context,
-    type: FieldMetadataType.RAW_JSON,
-    label: msg`Context`,
-    description: msg`Context`,
-    icon: 'IconHierarchy2',
-  })
-  @WorkspaceIsNullable()
-  // eslint-disable-next-line @typescript-eslint/no-explicit-any
-  context: Record<string, any> | null;
-
   @WorkspaceField({
     standardId: WORKFLOW_RUN_STANDARD_FIELD_IDS.state,
     type: FieldMetadataType.RAW_JSON,
@@ -189,8 +168,7 @@ export class WorkflowRunWorkspaceEntity extends BaseWorkspaceEntity {
     description: msg`State of the workflow run`,
     icon: 'IconHierarchy2',
   })
-  @WorkspaceIsNullable()
-  state: WorkflowRunState | null;
+  state: WorkflowRunState;
 
   @WorkspaceField({
     standardId: WORKFLOW_RUN_STANDARD_FIELD_IDS.position,

packages/twenty-server/src/modules/workflow/workflow-runner/jobs/run-workflow.job.ts

@@ -103,12 +103,9 @@ export class RunWorkflowJob {
       triggerType: workflowVersion.trigger.type,
     });
 
-    const triggerPayload = workflowRun.context?.trigger ?? {};
-
     await this.workflowRunWorkspaceService.startWorkflowRun({
       workflowRunId,
       workspaceId,
-      payload: triggerPayload,
     });
 
     await this.throttleExecution(workflowVersion.workflowId);

packages/twenty-server/src/modules/workflow/workflow-runner/workflow-run/workflow-run.workspace-service.ts

@@ -40,15 +40,14 @@ export class WorkflowRunWorkspaceService {
     workflowVersionId,
     createdBy,
     workflowRunId,
-    context,
     status,
+    triggerPayload,
   }: {
     workflowVersionId: string;
     createdBy: ActorMetadata;
     workflowRunId?: string;
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    context: Record<string, any>;
     status: WorkflowRunStatus.NOT_STARTED | WorkflowRunStatus.ENQUEUED;
+    triggerPayload: object;
   }) {
     const workspaceId =
       this.scopedWorkspaceContextFactory.create()?.workspaceId;
@@ -108,7 +107,7 @@ export class WorkflowRunWorkspaceService {
       workspaceId,
     });
 
-    const initState = this.getInitState(workflowVersion);
+    const initState = this.getInitState(workflowVersion, triggerPayload);
 
     const workflowRun = workflowRunRepository.create({
       id: workflowRunId ?? v4(),
@@ -119,11 +118,6 @@ export class WorkflowRunWorkspaceService {
       status,
       position,
       state: initState,
-      output: {
-        ...initState,
-        stepsOutput: {},
-      },
-      context,
     });
 
     await workflowRunRepository.insert(workflowRun);
@@ -135,11 +129,9 @@ export class WorkflowRunWorkspaceService {
   async startWorkflowRun({
     workflowRunId,
     workspaceId,
-    payload,
   }: {
     workflowRunId: string;
     workspaceId: string;
-    payload: object;
   }) {
     const workflowRunToUpdate = await this.getWorkflowRunOrFail({
       workflowRunId,
@@ -159,29 +151,17 @@ export class WorkflowRunWorkspaceService {
     const partialUpdate = {
       status: WorkflowRunStatus.RUNNING,
       startedAt: new Date().toISOString(),
-      output: {
-        ...workflowRunToUpdate.output,
-        stepsOutput: {
-          trigger: {
-            result: payload,
-          },
-        },
-      },
       state: {
         ...workflowRunToUpdate.state,
         stepInfos: {
           ...workflowRunToUpdate.state?.stepInfos,
           trigger: {
+            result: {},
+            ...workflowRunToUpdate.state?.stepInfos.trigger,
             status: StepStatus.SUCCESS,
-            result: payload,
           },
         },
       },
-      context: payload
-        ? {
-            trigger: payload,
-          }
-        : (workflowRunToUpdate.context ?? {}),
     };
 
     await this.updateWorkflowRun({ workflowRunId, workspaceId, partialUpdate });
@@ -207,10 +187,6 @@ export class WorkflowRunWorkspaceService {
     const partialUpdate = {
       status,
       endedAt: new Date().toISOString(),
-      output: {
-        ...workflowRunToUpdate.output,
-        error,
-      },
       state: {
         ...workflowRunToUpdate.state,
         workflowRunError: error,
@@ -279,16 +255,6 @@ export class WorkflowRunWorkspaceService {
     });
 
     const partialUpdate = {
-      output: {
-        flow: workflowRunToUpdate.output?.flow ?? {
-          trigger: undefined,
-          steps: [],
-        },
-        stepsOutput: {
-          ...(workflowRunToUpdate.output?.stepsOutput ?? {}),
-          [stepOutput.id]: stepOutput.output,
-        },
-      },
       state: {
         ...workflowRunToUpdate.state,
         stepInfos: {
@@ -301,14 +267,6 @@ export class WorkflowRunWorkspaceService {
           },
         },
       },
-      ...(stepStatus === StepStatus.SUCCESS
-        ? {
-            context: {
-              ...workflowRunToUpdate.context,
-              [stepOutput.id]: stepOutput.output.result,
-            },
-          }
-        : {}),
     };
 
     await this.updateWorkflowRun({ workflowRunId, workspaceId, partialUpdate });
@@ -339,18 +297,11 @@ export class WorkflowRunWorkspaceService {
       );
     }
 
-    const updatedSteps = workflowRunToUpdate.output?.flow?.steps?.map(
+    const updatedSteps = workflowRunToUpdate.state?.flow?.steps?.map(
       (existingStep) => (step.id === existingStep.id ? step : existingStep),
     );
 
     const partialUpdate = {
-      output: {
-        ...(workflowRunToUpdate.output ?? {}),
-        flow: {
-          ...(workflowRunToUpdate.output?.flow ?? {}),
-          steps: updatedSteps,
-        },
-      },
       state: {
         ...workflowRunToUpdate.state,
         flow: {
@@ -406,6 +357,7 @@ export class WorkflowRunWorkspaceService {
 
   private getInitState(
     workflowVersion: WorkflowVersionWorkspaceEntity,
+    triggerPayload: object,
   ): WorkflowRunState | undefined {
     if (
       !isDefined(workflowVersion.trigger) ||
@@ -420,7 +372,7 @@ export class WorkflowRunWorkspaceService {
         steps: workflowVersion.steps,
       },
       stepInfos: {
-        trigger: { status: StepStatus.NOT_STARTED },
+        trigger: { status: StepStatus.NOT_STARTED, result: triggerPayload },
         ...Object.fromEntries(
           workflowVersion.steps.map((step) => [
             step.id,

packages/twenty-server/src/modules/workflow/workflow-runner/workspace-services/workflow-runner.workspace-service.ts

@@ -75,9 +75,7 @@ export class WorkflowRunnerWorkspaceService {
         status: shouldEnqueueWorkflowRun
           ? WorkflowRunStatus.ENQUEUED
           : WorkflowRunStatus.NOT_STARTED,
-        context: {
-          trigger: payload,
-        },
+        triggerPayload: payload,
       });
 
     if (shouldEnqueueWorkflowRun) {