airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dimuthu...@apache.org
Subject [airavata] branch staging updated: Fixing issues in task retry nodes
Date Mon, 24 Sep 2018 18:49:46 GMT
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 e0554fe  Fixing issues in task retry nodes
e0554fe is described below

commit e0554fe34425d8746eec1dfc9a7ef98943554915
Author: Dimuthu Wannipurage <dimuthu.wannipurage@datasprouts.com>
AuthorDate: Mon Sep 24 14:49:37 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