mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2024-12-25 12:44:07 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

🐛 Fix retry issue #365

Browse source
This commit is contained in:
Jan Oberhauser 2020-03-17 09:07:12 +01:00
parent 2af5c2148a
commit 3bf0a9ab10
1 changed files with 18 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
packages/cli/src/Server.ts
View file

@ -973,6 +973,12 @@ class App {
workflowData: fullExecutionData.workflowData, workflowData: fullExecutionData.workflowData,
}; };
const lastNodeExecuted = data!.executionData!.resultData.lastNodeExecuted as string;
// Remove the old error and the data of the last run of the node that it can be replaced
delete data!.executionData!.resultData.error;
data!.executionData!.resultData.runData[lastNodeExecuted].pop();
if (req.body.loadWorkflow === true) { if (req.body.loadWorkflow === true) {
// Loads the currently saved workflow to execute instead of the // Loads the currently saved workflow to execute instead of the
// one saved at the time of the execution. // one saved at the time of the execution.
@ -982,6 +988,18 @@ class App {
if (data.workflowData === undefined) { if (data.workflowData === undefined) {
throw new Error(`The workflow with the ID "${workflowId}" could not be found and so the data not be loaded for the retry.`); throw new Error(`The workflow with the ID "${workflowId}" could not be found and so the data not be loaded for the retry.`);
} }
// Replace all of the nodes in the execution stack with the ones of the new workflow
for (const stack of data!.executionData!.executionData!.nodeExecutionStack) {
// Find the data of the last executed node in the new workflow
const node = data.workflowData.nodes.find(node => node.name === stack.node.name);
if (node === undefined) {
throw new Error(`Could not find the node "${stack.node.name}" in workflow. It probably got deleted or renamed. Without it the workflow can sadly not be retried.`);
}
// Replace the node data in the stack that it really uses the current data
stack.node = node;
}
} }
const workflowRunner = new WorkflowRunner(); const workflowRunner = new WorkflowRunner();