[airavata] branch master updated: Setting the task expiry to 24 hours

[di...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new ca7e3d5  Setting the task expiry to 24 hours
ca7e3d5 is described below

commit ca7e3d54eb9563da76b018184bfb9e1009dbd9e9
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Wed Jun 5 19:04:30 2019 -0400

    Setting the task expiry to 24 hours
---
 .../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 8d19ce1..26424b9 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
@@ -46,6 +46,7 @@ public class WorkflowOperator {
 
     private static final String WORKFLOW_PREFIX = "Workflow_of_process_";
     private static final long WORKFLOW_EXPIRY_TIME = 1 * 1000;
+    private static final long TASK_EXPIRY_TIME = 24 * 60 * 60 * 1000;
     private TaskDriver taskDriver;
     private HelixManager helixManager;
 
@@ -97,6 +98,7 @@ public class WorkflowOperator {
                     .addTaskConfigs(taskBuilds)
                     .setFailureThreshold(0)
                     .setExpiry(WORKFLOW_EXPIRY_TIME)
+                    .setTimeoutPerTask(TASK_EXPIRY_TIME)
                     .setNumConcurrentTasksPerInstance(20)
                     .setMaxAttemptsPerTask(data.getRetryCount());