Add retry logic to JenkinsQueueJobV2

Tasks/JenkinsQueueJobV2/Strings/resources.resjson/en-US/resources.resjson

@@ -22,6 +22,10 @@
   "loc.input.help.jobParameters": "Specify job parameters, one per line, in the form <b>`<parameterName>=<parameterValue>`</b><p>To set a parameter to an empty value (useful for overriding a default value), leave off the parameter value. For example, specify <b>`<parameterName>=`</b><p>Variables are supported. For example, to set a <b>`commitId`</b> parameter value to the Git commit ID of the build, use: <b>`commitId=$(Build.SourceVersion)`</b>. See the [documentation on variables](https://go.microsoft.com/fwlink/?linkid=875288) for more details.<p>Supported Jenkins parameter types are: <ul><li>`Boolean`</li><li>`Choice`</li><li>`Password`</li><li>`String`</li></ul>",
   "loc.input.label.failOnUnstableResult": "Fail on unstable result",
   "loc.input.help.failOnUnstableResult": "Specifies strictness of a success definition: whether to consider unstable as a failure or not. False for non-strict, and true for strict version.",
+  "loc.input.label.retryNumber": "Number of retries for failed connection",
+  "loc.input.help.retryNumber": "Specify number of retries on errors or failures. Default is 3 times",
+  "loc.input.label.retryTimer": "Time between retries",
+  "loc.input.help.retryTimer": "Specify time between retries. Default is 60 seconds",
   "loc.messages.FailedToGenerateSummary": "Failed to generate build summary.",
   "loc.messages.succeeded": "succeeded",
   "loc.messages.unstable": "unstable",

Tasks/JenkinsQueueJobV2/jenkinsqueuejobtask.ts

@@ -30,6 +30,10 @@ export class TaskOptions {
 
     pollIntervalMillis: number;
 
+    //initialize retry count and timer
+    retryNumber: number;
+    retryTimer: number;
+
     parameterizedJob: boolean;
     // jobParameters are only possible if parameterizedJob is enabled
     jobParameters: string[];
@@ -71,6 +75,9 @@ export class TaskOptions {
 
         this.pollIntervalMillis = 5000; // five seconds is what the Jenkins Web UI uses
 
+        this.retryNumber = parseInt(tl.getInput('retryNumber', false));
+        this.retryTimer = parseInt(tl.getInput('retryTimer', false));
+
         this.parameterizedJob = tl.getBoolInput('parameterizedJob', true);
         // jobParameters are only possible if parameterizedJob is enabled
         this.jobParameters = this.parameterizedJob ? tl.getDelimitedInput('jobParameters', '\n', false) : [];

Tasks/JenkinsQueueJobV2/job.ts

@@ -131,6 +131,14 @@ export class Job {
         this.working = false;
     }
 
+
+    private RetryConnection(): void {
+        const thisJob: Job = this;
+        thisJob.queue.TaskOptions.retryNumber--;
+        thisJob.consoleLog(`Connection error. Retrying again in ${thisJob.queue.TaskOptions.retryTimer} seconds`);
+        thisJob.stopWork(thisJob.queue.TaskOptions.retryTimer*1000, thisJob.State);
+    }
+
     public IsActive(): boolean {
         return this.State === JobState.New ||
             this.State === JobState.Locating ||
@@ -404,9 +412,14 @@ export class Job {
         request.get({ url: fullUrl, strictSSL: thisJob.queue.TaskOptions.strictSSL }, function requestCallback(err, httpResponse, body) {
             tl.debug('streamConsole().requestCallback()');
             if (err) {
-                Util.handleConnectionResetError(err); // something went bad
-                thisJob.stopWork(thisJob.queue.TaskOptions.pollIntervalMillis, thisJob.State);
-                return;
+                if (thisJob.queue.TaskOptions.retryNumber < 1) {
+                    Util.handleConnectionResetError(err); // something went bad
+                    thisJob.stopWork(thisJob.queue.TaskOptions.pollIntervalMillis, thisJob.State);
+                    return;
+                }
+                else {
+                    thisJob.RetryConnection();                
+                }
             } else if (httpResponse.statusCode === 404) {
                 // got here too fast, stream not yet available, try again in the future
                 thisJob.stopWork(thisJob.queue.TaskOptions.pollIntervalMillis, thisJob.State);
@@ -418,8 +431,13 @@ export class Job {
                     thisJob.queue.TaskOptions.failureMsg = 'Job progress tracking failed to read job progress';
                     thisJob.stopWork(0, JobState.Finishing);
             } else if (httpResponse.statusCode !== 200) {
-                Util.failReturnCode(httpResponse, 'Job progress tracking failed to read job progress');
-                thisJob.stopWork(thisJob.queue.TaskOptions.pollIntervalMillis, thisJob.State);
+                if (thisJob.queue.TaskOptions.retryNumber < 1) {
+                    Util.failReturnCode(httpResponse, 'Job progress tracking failed to read job progress');
+                    thisJob.stopWork(thisJob.queue.TaskOptions.pollIntervalMillis, thisJob.State);
+                }
+                else {
+                    thisJob.RetryConnection();                                    
+                }
             } else {
                 thisJob.consoleLog(body); // redirect Jenkins console to task console
                 const xMoreData: string = httpResponse.headers['x-more-data'];
@@ -433,7 +451,9 @@ export class Job {
             }
         }).auth(thisJob.queue.TaskOptions.username, thisJob.queue.TaskOptions.password, true)
         .on('error', (err) => {
-            throw err;
+            if (thisJob.queue.TaskOptions.retryNumber < 1) {
+                throw err;
+            }
         });
     }
 

Tasks/JenkinsQueueJobV2/task.json

@@ -15,7 +15,7 @@
     "version": {
         "Major": 2,
         "Minor": 192,
-        "Patch": 0
+        "Patch": 1
     },
     "groups": [
         {
@@ -110,6 +110,24 @@
             "required": false,
             "helpMarkDown": "Specifies strictness of a success definition: whether to consider unstable as a failure or not. False for non-strict, and true for strict version.",
             "groupName": "advanced"
+        },
+        {
+            "name": "retryNumber",
+            "type": "string",
+            "label": "Number of retries for failed connection",
+            "defaultValue": "3",
+            "required": false,
+            "helpMarkDown": "Specify number of retries on errors or failures. Default is 3 times",
+            "groupName": "advanced"
+        },
+        {
+            "name": "retryTimer",
+            "type": "string",
+            "label": "Time between retries",
+            "defaultValue": "60",
+            "required": false,
+            "helpMarkDown": "Specify time between retries. Default is 60 seconds",
+            "groupName": "advanced"
         }
     ],
     "outputVariables": [

Tasks/JenkinsQueueJobV2/task.loc.json

@@ -15,7 +15,7 @@
   "version": {
     "Major": 2,
     "Minor": 192,
-    "Patch": 0
+    "Patch": 1
   },
   "groups": [
     {
@@ -110,6 +110,24 @@
       "required": false,
       "helpMarkDown": "ms-resource:loc.input.help.failOnUnstableResult",
       "groupName": "advanced"
+    },
+    {
+      "name": "retryNumber",
+      "type": "string",
+      "label": "ms-resource:loc.input.label.retryNumber",
+      "defaultValue": "3",
+      "required": false,
+      "helpMarkDown": "ms-resource:loc.input.help.retryNumber",
+      "groupName": "advanced"
+    },
+    {
+      "name": "retryTimer",
+      "type": "string",
+      "label": "ms-resource:loc.input.label.retryTimer",
+      "defaultValue": "60",
+      "required": false,
+      "helpMarkDown": "ms-resource:loc.input.help.retryTimer",
+      "groupName": "advanced"
     }
   ],
   "outputVariables": [