D-40783 Added maxTransientRetries input

Author: balaji-digital-ai

README.md

@@ -58,6 +58,7 @@ During execution, this action creates a temporary directory named **`tmp-dai`**
 | `username`  | Username for Digital.ai Deploy authentication.              | Yes      | N/A     |
 | `password`  | Password for Digital.ai Deploy authentication. | Yes      | N/A     |
 | `action`    | Specifies the operation(s). One of: `create`, `publish`, `deploy`, `create_publish`, `publish_deploy`, `create_publish_deploy` | No | `create_publish_deploy` |
+| `maxTransientRetries`  | The maximum number of retries when encountering transient errors. | No      | 5     |
 
 ---
 

action.yml

@@ -43,6 +43,9 @@ inputs:
   rollback:
     description: 'Invoke a rollback in case of deployment failure'
     required: false
+  maxTransientRetries:
+    description: 'The maximum number of retries when encountering transient errors'
+    required: false
 
 outputs:
   deploymentPackageId:

dist/index.js

@@ -64945,6 +64945,8 @@ class DeployManager {
 
   static serverConfig;
 
+  static maxTransientRetries = 5; // Default to 5 retries if not set
+
   // General API request method
   // deploy-manager.js
 
@@ -65237,7 +65239,6 @@ class DeployManager {
   // Wait for task to complete
   static async waitForTask(taskId) {
     const runningStates = ["QUEUED", "EXECUTING", "ABORTING", "STOPPING", "FAILING", "PENDING"];
-    const maxTransientRetries = 5;
     let transientAttempts = 0;
     let task;
     while (true) {
@@ -65252,9 +65253,9 @@ class DeployManager {
       } catch (error) {
         // Handle the specific 500 “cannot create children…” error as transient
         const msg = error.message || "";
-        if (msg.includes("500") && msg.includes("cannot create children while terminating or terminated") && transientAttempts < maxTransientRetries) {
+        if (msg.includes("500") && msg.includes("cannot create children while terminating or terminated") && transientAttempts < this.maxTransientRetries) {
           transientAttempts++;
-          console.log(`Transient error checking task status (attempt ${transientAttempts}/${maxTransientRetries}): ${msg}  Retrying in ${transientAttempts * 5}s…`);
+          console.log(`Transient error checking task status (attempt ${transientAttempts}/${this.maxTransientRetries}): ${msg}  Retrying in ${transientAttempts * 5}s…`);
           await this.sleepFor(transientAttempts * 5);
           continue;
         }
@@ -65377,6 +65378,9 @@ async function run() {
     const deploymentPackageIdInput = core.getInput('deploymentPackageId'); // Renamed to avoid conflict with local variable
     const environmentId = core.getInput('environmentId');
     const rollback = core.getInput('rollback') || 'false';
+    const maxTransientRetries = parseInt(core.getInput('maxTransientRetries'), 10) || 5; // Default to 5 retries if not set
+    
+    DeployManager.maxTransientRetries = maxTransientRetries; // Set the max transient retries for DeployManager
 
     function logNonEmptyInputs() {
       const inputs = {
@@ -65388,7 +65392,8 @@ async function run() {
         darPackagePath: darPackagePathInput,
         deploymentPackageId: deploymentPackageIdInput,
         environmentId,
-        rollback
+        rollback,
+        maxTransientRetries
       };
 
       core.info('Provided action inputs:');

dist/index.js.map

@@ -10,6 +10,8 @@ class DeployManager {
 
   static serverConfig;
 
+  static maxTransientRetries = 5; // Default to 5 retries if not set
+
   // General API request method
   // deploy-manager.js
 
@@ -302,7 +304,6 @@ class DeployManager {
   // Wait for task to complete
   static async waitForTask(taskId) {
     const runningStates = ["QUEUED", "EXECUTING", "ABORTING", "STOPPING", "FAILING", "PENDING"];
-    const maxTransientRetries = 5;
     let transientAttempts = 0;
     let task;
     while (true) {
@@ -317,9 +318,9 @@ class DeployManager {
       } catch (error) {
         // Handle the specific 500 “cannot create children…” error as transient
         const msg = error.message || "";
-        if (msg.includes("500") && msg.includes("cannot create children while terminating or terminated") && transientAttempts < maxTransientRetries) {
+        if (msg.includes("500") && msg.includes("cannot create children while terminating or terminated") && transientAttempts < this.maxTransientRetries) {
           transientAttempts++;
-          console.log(`Transient error checking task status (attempt ${transientAttempts}/${maxTransientRetries}): ${msg}  Retrying in ${transientAttempts * 5}s…`);
+          console.log(`Transient error checking task status (attempt ${transientAttempts}/${this.maxTransientRetries}): ${msg}  Retrying in ${transientAttempts * 5}s…`);
           await this.sleepFor(transientAttempts * 5);
           continue;
         }

src/deploy-manager.js

@@ -67,6 +67,9 @@ async function run() {
     const deploymentPackageIdInput = core.getInput('deploymentPackageId'); // Renamed to avoid conflict with local variable
     const environmentId = core.getInput('environmentId');
     const rollback = core.getInput('rollback') || 'false';
+    const maxTransientRetries = parseInt(core.getInput('maxTransientRetries'), 10) || 5; // Default to 5 retries if not set
+    
+    DeployManager.maxTransientRetries = maxTransientRetries; // Set the max transient retries for DeployManager
 
     function logNonEmptyInputs() {
       const inputs = {
@@ -78,7 +81,8 @@ async function run() {
         darPackagePath: darPackagePathInput,
         deploymentPackageId: deploymentPackageIdInput,
         environmentId,
-        rollback
+        rollback,
+        maxTransientRetries
       };
 
       core.info('Provided action inputs:');