n8n-core - npm Package Compare versions

Comparing version 0.4.0 to 0.5.0

dist/src/WorkflowExecute.js

@@ -205,15 +205,36 @@ "use strict";
                 startTime = new Date().getTime();
-                try {
-                    runExecutionData.resultData.lastNodeExecuted = executionData.node.name;
-                    nodeSuccessData = await workflow.runNode(executionData.node, JSON.parse(JSON.stringify(executionData.data)), runExecutionData, runIndex, this.additionalData, _1.NodeExecuteFunctions, this.mode);
-                    if (nodeSuccessData === null) {
-                        continue;
+                let maxTries = 1;
+                if (executionData.node.retryOnFail === true) {
+                    maxTries = Math.min(5, Math.max(2, executionData.node.maxTries || 3));
+                }
+                let waitBetweenTries = 0;
+                if (executionData.node.retryOnFail === true) {
+                    waitBetweenTries = Math.min(5000, Math.max(0, executionData.node.waitBetweenTries || 1000));
+                }
+                for (let tryIndex = 0; tryIndex < maxTries; tryIndex++) {
+                    try {
+                        if (tryIndex !== 0) {
+                            executionError = undefined;
+                            if (waitBetweenTries !== 0) {
+                                await new Promise((resolve) => {
+                                    setTimeout(() => {
+                                        resolve();
+                                    }, waitBetweenTries);
+                                });
+                            }
+                        }
+                        runExecutionData.resultData.lastNodeExecuted = executionData.node.name;
+                        nodeSuccessData = await workflow.runNode(executionData.node, JSON.parse(JSON.stringify(executionData.data)), runExecutionData, runIndex, this.additionalData, _1.NodeExecuteFunctions, this.mode);
+                        if (nodeSuccessData === null) {
+                            continue executionLoop;
+                        }
+                        break;
                     }
+                    catch (error) {
+                        executionError = {
+                            message: error.message,
+                            stack: error.stack,
+                        };
+                    }
                 }
-                catch (error) {
-                    executionError = {
-                        message: error.message,
-                        stack: error.stack,
-                    };
-                }
                 if (!runExecutionData.resultData.runData.hasOwnProperty(executionNode.name)) {
@@ -220,0 +241,0 @@ runExecutionData.resultData.runData[executionNode.name] = [];

package.json

 {
     "name": "n8n-core",
-    "version": "0.4.0",
+    "version": "0.5.0",
     "description": "Core functionality of n8n",
@@ -43,3 +43,3 @@ "license": "SEE LICENSE IN LICENSE.md",
         "mmmagic": "^0.5.2",
-        "n8n-workflow": "^0.5.0",
+        "n8n-workflow": "^0.6.0",
         "request-promise-native": "^1.0.7"
@@ -46,0 +46,0 @@ },

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

131896

increased by1.47%

Lines of code

1568

increased by1.36%

Dependency changes

• + Addedn8n-workflow@0.6.0(transitive)

• - Removedn8n-workflow@0.5.0(transitive)

• Updatedn8n-workflow@^0.6.0