[airavata] branch develop updated: Using the correct API to save experiment outputs

[di...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/develop by this push:
     new 7211467  Using the correct API to save experiment outputs
7211467 is described below

commit 721146745ecbafc93fcbaa2a5143dc825e09480e
Author: dimuthu <di...@gmail.com>
AuthorDate: Thu Apr 5 14:25:57 2018 -0400

    Using the correct API to save experiment outputs
---
 .../main/java/org/apache/airavata/helix/impl/task/AiravataTask.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 17215a6..978dd7b 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
@@ -51,6 +51,7 @@ import org.slf4j.MDC;
 
 import java.io.PrintWriter;
 import java.io.StringWriter;
+import java.util.Collections;
 import java.util.List;
 
 public abstract class AiravataTask extends AbstractTask {
@@ -195,10 +196,11 @@ public abstract class AiravataTask extends AbstractTask {
 
                         String productUri = getRegistryServiceClient().registerDataProduct(dataProductModel);
                         expOutput.setValue(productUri);
+                        getRegistryServiceClient().addExperimentProcessOutputs("EXPERIMENT_OUTPUT",
+                                Collections.singletonList(expOutput), experimentId);
                     }
                 }
             }
-            getRegistryServiceClient().updateExperiment(experimentId, experiment);
 
         } catch (TException e) {
             String msg = "expId: " + getExperimentId() + " processId: " + getProcessId() + " : - Error while updating experiment outputs";

-- 
To stop receiving notification emails like this one, please contact
dimuthuupe@apache.org.