refactor(core): Report malformed execution data (#12525)

This commit is contained in:
Iván Ovejero 2025-01-09 11:51:07 +01:00
parent 858b86a284
commit 0c5b3097bb
No known key found for this signature in database

View file

@ -899,7 +899,27 @@ export class WorkflowExecute {
this.status = 'running';
const startNode = this.runExecutionData.executionData!.nodeExecutionStack[0].node.name;
if (!this.runExecutionData.executionData) {
throw new ApplicationError('Failed to run workflow due to missing execution data', {
extra: {
workflowId: workflow.id,
executionid: this.additionalData.executionId,
mode: this.mode,
},
});
}
const startNode = this.runExecutionData.executionData.nodeExecutionStack.at(0)?.node.name;
if (!startNode) {
throw new ApplicationError('Failed to run workflow due to empty node execution stack', {
extra: {
workflowId: workflow.id,
executionId: this.additionalData.executionId,
mode: this.mode,
},
});
}
let destinationNode: string | undefined;
if (this.runExecutionData.startData && this.runExecutionData.startData.destinationNode) {
@ -934,7 +954,7 @@ export class WorkflowExecute {
if (this.runExecutionData.waitTill) {
const lastNodeExecuted = this.runExecutionData.resultData.lastNodeExecuted as string;
this.runExecutionData.executionData!.nodeExecutionStack[0].node.disabled = true;
this.runExecutionData.executionData.nodeExecutionStack[0].node.disabled = true;
this.runExecutionData.waitTill = undefined;
this.runExecutionData.resultData.runData[lastNodeExecuted].pop();
}