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/06/06 13:34:19 UTC
[airavata] branch staging updated: Directing the stdout of curl
monitoring commands to /dev/null
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 d5c2bdf Directing the stdout of curl monitoring commands to /dev/null
d5c2bdf is described below
commit d5c2bdf4d380991fbd6eba584cd99dc65357356e
Author: dimuthu <di...@gmail.com>
AuthorDate: Wed Jun 6 09:33:54 2018 -0400
Directing the stdout of curl monitoring commands to /dev/null
---
.../apache/airavata/helix/impl/task/submission/JobSubmissionTask.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/submission/JobSubmissionTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/submission/JobSubmissionTask.java
index 93f1768..e36c726 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/submission/JobSubmissionTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/submission/JobSubmissionTask.java
@@ -233,7 +233,7 @@ public abstract class JobSubmissionTask extends AiravataTask {
mapData.getPreJobCommands().add(0, "curl -X POST -H \"Content-Type: application/vnd.kafka.json.v2+json\" " +
"-H \"Accept: application/vnd.kafka.v2+json\" " +
"--data '{\"records\":[{\"value\":{\"jobName\":\"" + mapData.getJobName() + "\", \"status\":\"RUNNING\"}}]}' \"" +
- ServerSettings.getSetting("job.status.publish.endpoint") + "\" || true");
+ ServerSettings.getSetting("job.status.publish.endpoint") + "\" > /dev/null || true");
if (mapData.getPostJobCommands() == null) {
mapData.setPostJobCommands(new ArrayList<>());
@@ -242,6 +242,6 @@ public abstract class JobSubmissionTask extends AiravataTask {
mapData.getPostJobCommands().add("curl -X POST -H \"Content-Type: application/vnd.kafka.json.v2+json\" " +
"-H \"Accept: application/vnd.kafka.v2+json\" " +
"--data '{\"records\":[{\"value\":{\"jobName\":\"" + mapData.getJobName() + "\", \"status\":\"COMPLETED\"}}]}' \"" +
- ServerSettings.getSetting("job.status.publish.endpoint") + "\" || true");
+ ServerSettings.getSetting("job.status.publish.endpoint") + "\" > /dev/null || true");
}
}
--
To stop receiving notification emails like this one, please contact
dimuthuupe@apache.org.