airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dimuthu...@apache.org
Subject [airavata] branch develop updated: Fixing issues in task retry nodes
Date Mon, 24 Sep 2018 18:46:18 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/develop by this push:
     new f876162  Fixing issues in task retry nodes
f876162 is described below

commit f8761624cb610576e6241fae7e8cf1d84d8dce00
Author: Dimuthu Wannipurage <dimuthu.wannipurage@datasprouts.com>
AuthorDate: Mon Sep 24 14:46:09 2018 -0400

    Fixing issues in task retry nodes
---
 .../java/org/apache/airavata/helix/core/util/MonitoringUtil.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/util/MonitoringUtil.java
b/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/util/MonitoringUtil.java
index 4a1f375..9a072b2 100644
--- a/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/util/MonitoringUtil.java
+++ b/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/util/MonitoringUtil.java
@@ -17,7 +17,7 @@ public class MonitoringUtil {
     private static final String REGISTRY = "/registry/";
 
     private static final String EXPERIMENT = "/experiment";
-    private static final String TASK = "/task/";
+    private static final String TASK = "/task";
     private static final String PROCESS = "/process";
     private static final String GATEWAY = "/gateway";
     private static final String LOCK = "/lock";
@@ -32,7 +32,7 @@ public class MonitoringUtil {
     public static final String CANCEL = "cancel";
 
     public static int getTaskRetryCount(CuratorFramework curatorClient, String taskId) throws
Exception {
-        String path = TASK + taskId + RETRY;
+        String path = TASK + "/" + taskId + RETRY;
         if (curatorClient.checkExists().forPath(path) != null) {
             byte[] processBytes = curatorClient.getData().forPath(path);
             return Integer.parseInt(new String(processBytes));
@@ -42,7 +42,7 @@ public class MonitoringUtil {
     }
 
     public static void increaseTaskRetryCount(CuratorFramework curatorClient, String takId)
throws Exception {
-        String path = TASK + takId + RETRY;
+        String path = TASK + "/" + takId + RETRY;
         int currentRetryCount = 2;
         if (curatorClient.checkExists().forPath(path) != null) {
             byte[] processBytes = curatorClient.getData().forPath(path);


Mime
View raw message