[airavata] branch staging updated: Fixing NPE when fetching the curator client

[di...@apache.org]

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 6c6cfdc  Fixing NPE when fetching the curator client
6c6cfdc is described below

commit 6c6cfdc01c58bd475f2ec488ae01822a3f3262f0
Author: dimuthu <di...@gmail.com>
AuthorDate: Thu Aug 23 22:34:45 2018 -0400

    Fixing NPE when fetching the curator client
---
 .../src/main/java/org/apache/airavata/helix/core/AbstractTask.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/AbstractTask.java b/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/AbstractTask.java
index 0dabe59..70652a9 100644
--- a/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/AbstractTask.java
+++ b/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/AbstractTask.java
@@ -176,14 +176,13 @@ public abstract class AbstractTask extends UserContentStore implements Task {
     }
 
     protected int getCurrentRetryCount() throws Exception {
-        return MonitoringUtil.getTaskRetryCount(curatorClient, taskId);
+        return MonitoringUtil.getTaskRetryCount(getCuratorClient(), taskId);
     }
 
     protected void markNewRetry() throws Exception {
-        MonitoringUtil.increaseTaskRetryCount(curatorClient, taskId);
+        MonitoringUtil.increaseTaskRetryCount(getCuratorClient(), taskId);
     }
 
-
     public int getRetryCount() {
         return retryCount;
     }