You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2018/10/03 07:04:58 UTC
[airavata] branch staging updated: Minor logging improvements
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 591f997 Minor logging improvements
591f997 is described below
commit 591f997fa54aa1bedd6fea205fa52fce90f681d6
Author: Dimuthu Wannipurage <di...@datasprouts.com>
AuthorDate: Wed Oct 3 03:04:50 2018 -0400
Minor logging improvements
---
.../apache/airavata/helix/impl/controller/WorkflowCleanupAgent.java | 1 +
.../main/java/org/apache/airavata/helix/impl/task/AiravataTask.java | 3 +++
2 files changed, 4 insertions(+)
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/controller/WorkflowCleanupAgent.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/controller/WorkflowCleanupAgent.java
index 27cbd71..5188c78 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/controller/WorkflowCleanupAgent.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/controller/WorkflowCleanupAgent.java
@@ -68,6 +68,7 @@ public class WorkflowCleanupAgent implements Runnable {
@Override
public void run() {
+ logger.info("Cleaning up stale workflows");
Map<String, WorkflowConfig> workflows = taskDriver.getWorkflows();
workflows.keySet().forEach(id -> {
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java
index 8da60a3..035fcbc 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java
@@ -88,6 +88,7 @@ public abstract class AiravataTask extends AbstractTask {
}
try {
+ logger.info("Deleting task specific monitoring nodes");
MonitoringUtil.deleteTaskSpecificNodes(getCuratorClient(), getTaskId());
} catch (Exception e) {
logger.error("Failed to delete task specific nodes but continuing", e);
@@ -152,6 +153,7 @@ public abstract class AiravataTask extends AbstractTask {
}
try {
+ logger.info("Deleting task specific monitoring nodes");
MonitoringUtil.deleteTaskSpecificNodes(getCuratorClient(), getTaskId());
} catch (Exception e) {
logger.error("Failed to delete task specific nodes but continuing", e);
@@ -365,6 +367,7 @@ public abstract class AiravataTask extends AbstractTask {
}
try {
+ logger.info("Deleting task specific monitoring nodes");
MonitoringUtil.deleteTaskSpecificNodes(getCuratorClient(), getTaskId());
} catch (Exception e) {
logger.error("Failed to delete task specific nodes but continuing", e);