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: Directing the stdout of curl monitoring commands to /dev/null
Date Wed, 06 Jun 2018 13:34:19 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 d5c2bdf  Directing the stdout of curl monitoring commands to /dev/null
d5c2bdf is described below

commit d5c2bdf4d380991fbd6eba584cd99dc65357356e
Author: dimuthu <dimuthu.upeksha2@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.

Mime
View raw message