[airavata] branch staging updated: Temporary removing cleaning up command in CancellationCompletingTask

[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 bb7d3ca  Temporary removing cleaning up command in CancellationCompletingTask
bb7d3ca is described below

commit bb7d3ca0770a1a0301d975e30e7eb37f9834b7c4
Author: Dimuthu Wannipurage <di...@datasprouts.com>
AuthorDate: Thu Nov 1 22:36:21 2018 -0400

    Temporary removing cleaning up command in CancellationCompletingTask
---
 .../apache/airavata/helix/impl/task/cancel/CancelCompletingTask.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/cancel/CancelCompletingTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/cancel/CancelCompletingTask.java
index 834864c..e9b3b0f 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/cancel/CancelCompletingTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/cancel/CancelCompletingTask.java
@@ -34,7 +34,8 @@ public class CancelCompletingTask extends AiravataTask {
 
         logger.info("Deleting process level monitoring nodes");
         try {
-            MonitoringUtil.deleteProcessSpecificNodes(getCuratorClient(), getProcessId());
+            // TODO temporary stop cleaning up because this will cause later cancellation events to be gone un notified
+            //MonitoringUtil.deleteProcessSpecificNodes(getCuratorClient(), getProcessId());
         } catch (Exception e) {
             logger.error("Failed to delete process specific nodes but continuing", e);
         }