[airavata] branch staging updated: Setting concurrent tasks per job 20

[dimuthuupe]

This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch staging
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/staging by this push:
     new 4b8ef37  Setting concurrent tasks per job 20
4b8ef37 is described below

commit 4b8ef3719e355aceb73af2c9b068fe84beb9407b
Author: Dimuthu Wannipurage <dimuthu.upeks...@gmail.com>
AuthorDate: Wed Apr 3 01:20:51 2019 -0400

    Setting concurrent tasks per job 20
---
 .../main/java/org/apache/airavata/helix/workflow/WorkflowOperator.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/modules/airavata-helix/workflow-impl/src/main/java/org/apache/airavata/helix/workflow/WorkflowOperator.java
 
b/modules/airavata-helix/workflow-impl/src/main/java/org/apache/airavata/helix/workflow/WorkflowOperator.java
index 746f912..8d19ce1 100644
--- 
a/modules/airavata-helix/workflow-impl/src/main/java/org/apache/airavata/helix/workflow/WorkflowOperator.java
+++ 
b/modules/airavata-helix/workflow-impl/src/main/java/org/apache/airavata/helix/workflow/WorkflowOperator.java
@@ -97,8 +97,10 @@ public class WorkflowOperator {
                     .addTaskConfigs(taskBuilds)
                     .setFailureThreshold(0)
                     .setExpiry(WORKFLOW_EXPIRY_TIME)
+                    .setNumConcurrentTasksPerInstance(20)
                     .setMaxAttemptsPerTask(data.getRetryCount());
 
+
             if (!globalParticipant) {
                 job.setInstanceGroupTag(taskType);
             }