admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-16 17:46:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(core): Extract setup logic, group variables and document potential dead code (#18868)

Browse Source
This commit is contained in:
Danny Martini
2025-08-27 17:31:10 +02:00
committed by GitHub
parent a6406b904f
commit bc9697d9ef
1 changed files with 23 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
packages/core/src/execution-engine/workflow-execute.ts
View File

@@ -64,6 +64,7 @@ import { WorkflowHasIssuesError } from '@/errors/workflow-has-issues.error';
import * as NodeExecuteFunctions from '@/node-execute-functions';
import { isJsonCompatible } from '@/utils/is-json-compatible';
import type { ExecutionLifecycleHooks } from './execution-lifecycle-hooks';
import { ExecuteContext, PollContext } from './node-execution-context';
import {
DirectedGraph,
@@ -1534,6 +1535,25 @@ export class WorkflowExecute {
}
}
private setupExecution(): {
startedAt: Date;
hooks: ExecutionLifecycleHooks;
} {
this.status = 'running';
const { hooks } = this.additionalData;
assert.ok(hooks, 'Failed to run workflow due to missing execution lifecycle hooks');
// NOTE: As far as I can tell this code is dead.
// FIXME: Fix the types to make sure startData is always set and remove the
// code.
if (this.runExecutionData.startData === undefined) {
this.runExecutionData.startData = {};
}
return { startedAt: new Date(), hooks };
}
/**
* Runs the given execution data.
*
@@ -1544,27 +1564,15 @@ export class WorkflowExecute {
// eslint-disable-next-line @typescript-eslint/promise-function-async
processRunExecutionData(workflow: Workflow): PCancelable<IRun> {
Logger.debug('Workflow execution started', { workflowId: workflow.id });
const startedAt = new Date();
this.status = 'running';
const { hooks } = this.additionalData;
assert.ok(hooks, 'Failed to run workflow due to missing execution lifecycle hooks');
const { startedAt, hooks } = this.setupExecution();
this.checkForWorkflowIssues(workflow);
this.handleWaitingState(workflow);
// Variables which hold temporary data for each node-execution
let executionData: IExecuteData;
let executionError: ExecutionBaseError | undefined;
let executionNode: INode;
let runIndex: number;
if (this.runExecutionData.startData === undefined) {
this.runExecutionData.startData = {};
}
this.checkForWorkflowIssues(workflow);
this.handleWaitingState(workflow);
let currentExecutionTry = '';
let lastExecutionTry = '';
let closeFunction: Promise<void> | undefined;