[DownloadBuildArtifactsV0] Respect "Parallelization limit" input

Tasks/DownloadBuildArtifactsV0/download_helper.ts

@@ -2,15 +2,6 @@ import { debug, loc } from 'azure-pipelines-task-lib/task';
 import { ArtifactDownloadTicket, ItemType, TicketState } from 'artifact-engine/Models';
 import { getFileSizeInBytes } from './file_helper';
 
-/**
- * Just a Promise wrapper for setTimeout function
- * @param {number} interval - timeout interval in milliseconds
- */
-export function timeoutPromise(interval: number): Promise<{}> {
-    debug(`Wait for ${interval} milliseconds`);
-    return new Promise(resolve => setTimeout(resolve, interval));
-}
-
 /**
  * This function checks a result of artifact download
  * @param  {Array<ArtifactDownloadTicket>} downloadTickets
@@ -96,3 +87,47 @@ function isItemCorrupted(ticket: ArtifactDownloadTicket): boolean {
 
     return isCorrupted;
 }
+
+/**
+ * This function resolves the value for the `parallelProcessingLimit` option of `ArtifactEngine`
+ *
+ * Earlier the only way to set parallelProcessingLimit in the task
+ * was by declaring the `release.artifact.download.parallellimit` variable.
+ *
+ * To save backward compatibility we will use the following strategy:
+ *
+ * Firstly, investigate the `release.artifact.download.parallellimit` variable.
+ * If everything is okay with this variable, the task will use the value from this variable.
+ *
+ * Secondly, investigate the `Parallelization limit` input of the task.
+ * If everything is okay with the value in the related task's input, the task will use the value from this input.
+ *
+ * If validation failed for both cases the function will return the default value for the `parallelProcessingLimit` option.
+ *
+ * @param artifactDownloadLimit {string} - value of `release.artifact.download.parallellimit` variable
+ * @param taskLimit {string} - value of `Parallelization limit` task input
+ * @returns {number} - parallel processing limit
+ */
+export function resolveParallelProcessingLimit(artifactDownloadLimit: string, taskLimit: string): number {
+    const artifactDownloadParallelLimit: number = Number(artifactDownloadLimit);
+    if (!isNaN(artifactDownloadParallelLimit) && artifactDownloadParallelLimit > 0) {
+        debug('The value from "release.artifact.download.parallellimit" variable will be used in the task');
+        debug(`The parallelization limit is set to ${artifactDownloadParallelLimit}`);
+        return artifactDownloadParallelLimit;
+    } else {
+        debug('The "release.artifact.download.parallellimit" variable contains the incorrect value');
+    }
+
+    const taskInputParallelLimit: number = Number(taskLimit);
+    if (!isNaN(taskInputParallelLimit) && taskInputParallelLimit > 0) {
+        debug('The value from "Parallelization limit" input will be used in the task');
+        debug(`The parallelization limit is set to ${taskInputParallelLimit}`);
+        return taskInputParallelLimit;
+    } else {
+        debug('The "Parallelization limit" input contains the incorrect value');
+    }
+
+    debug('The parallelization limit is set to default value - 8');
+
+    return 8;
+}

Tasks/DownloadBuildArtifactsV0/main.ts

@@ -17,6 +17,8 @@ import { DownloadHandlerContainer } from './DownloadHandlers/DownloadHandlerCont
 import { DownloadHandlerContainerZip } from './DownloadHandlers/DownloadHandlerContainerZip';
 import { DownloadHandlerFilePath } from './DownloadHandlers/DownloadHandlerFilePath';
 
+import { resolveParallelProcessingLimit } from './download_helper';
+
 var taskJson = require('./task.json');
 
 tl.setResourcePath(path.join(__dirname, 'task.json'));
@@ -73,7 +75,7 @@ async function main(): Promise<void> {
         var buildId: number = null;
         var buildVersionToDownload: string = tl.getInput("buildVersionToDownload", false);
         var allowPartiallySucceededBuilds: boolean = tl.getBoolInput("allowPartiallySucceededBuilds", false);
-        var branchName: string = tl.getInput("branchName", false);;
+        var branchName: string = tl.getInput("branchName", false);
         var downloadPath: string = tl.getInput("downloadPath", true);
         var downloadType: string = tl.getInput("downloadType", true);
         var tagFiltersInput: string = tl.getInput("tags", false);
@@ -253,7 +255,7 @@ async function main(): Promise<void> {
         if (artifacts) {
             var downloadPromises: Array<Promise<any>> = [];
             artifacts.forEach(async function (artifact, index, artifacts) {
-                let downloaderOptions = configureDownloaderOptions();
+                const downloaderOptions: engine.ArtifactEngineOptions = configureDownloaderOptions();
 
                 const config: IBaseHandlerConfig = {
                     artifactInfo: artifact,
@@ -372,11 +374,16 @@ function getRetryIntervalInSeconds(retryCount: number): number {
 }
 
 function configureDownloaderOptions(): engine.ArtifactEngineOptions {
-    var downloaderOptions = new engine.ArtifactEngineOptions();
-    downloaderOptions.itemPattern = tl.getInput('itemPattern', false) || "**";
-    downloaderOptions.parallelProcessingLimit = +tl.getVariable("release.artifact.download.parallellimit") || 8;
-    var debugMode = tl.getVariable('System.Debug');
-    downloaderOptions.verbose = debugMode ? debugMode.toLowerCase() != 'false' : false;
+    const downloaderOptions: engine.ArtifactEngineOptions = new engine.ArtifactEngineOptions();
+
+    const debugMode: string = tl.getVariable('System.Debug');
+    downloaderOptions.verbose = debugMode ? debugMode.toLowerCase() !== 'false' : false;
+
+    const artifactDownloadLimit: string = tl.getVariable('release.artifact.download.parallellimit');
+    const taskInputParallelLimit: string = tl.getInput('parallelizationLimit', false);
+    downloaderOptions.parallelProcessingLimit = resolveParallelProcessingLimit(artifactDownloadLimit, taskInputParallelLimit);
+
+    downloaderOptions.itemPattern = tl.getInput('itemPattern', false) || '**';
 
     return downloaderOptions;
 }

Tasks/DownloadBuildArtifactsV0/task.json

@@ -9,7 +9,7 @@
     "author": "Microsoft Corporation",
     "version": {
         "Major": 0,
-        "Minor": 183,
+        "Minor": 184,
         "Patch": 0
     },
     "groups": [

Tasks/DownloadBuildArtifactsV0/task.loc.json

@@ -9,7 +9,7 @@
   "author": "Microsoft Corporation",
   "version": {
     "Major": 0,
-    "Minor": 183,
+    "Minor": 184,
     "Patch": 0
   },
   "groups": [