You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2012/12/11 22:50:36 UTC
svn commit: r1420439 -
/airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java
Author: lahiru
Date: Tue Dec 11 21:50:35 2012
New Revision: 1420439
URL: http://svn.apache.org/viewvc?rev=1420439&view=rev
Log:
adding output Node data in to provenance data.
Modified:
airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java
Modified: airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java?rev=1420439&r1=1420438&r2=1420439&view=diff
==============================================================================
--- airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java (original)
+++ airavata/trunk/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/interpretor/WorkflowInterpreter.java Tue Dec 11 21:50:35 2012
@@ -397,7 +397,7 @@ public class WorkflowInterpreter {
notifyViaInteractor(WorkflowExecutionMessage.EXECUTION_CLEANUP, null);
}
- private void sendOutputsDynamically() throws WorkflowException {
+ private void sendOutputsDynamically() throws WorkflowException, AiravataAPIInvocationException {
ArrayList<Node> outputNodes = getReadyOutputNodesDynamically();
if (outputNodes.size() != 0) {
LinkedList<Object> outputValues = new LinkedList<Object>();
@@ -423,6 +423,12 @@ public class WorkflowInterpreter {
} else {
((OutputNode) node).setDescription(val.toString());
}
+ // Saving output Node data in to database
+ WorkflowNodeType workflowNodeType = new WorkflowNodeType();
+ workflowNodeType.setNodeType(WorkflowNodeType.WorkflowNode.OUTPUTNODE);
+ WorkflowInstanceNode workflowInstanceNode = new WorkflowInstanceNode(new WorkflowInstance(config.getTopic(), config.getTopic()), node.getID());
+ this.getConfig().getConfiguration().getAiravataAPI().getProvenanceManager().setWorkflowInstanceNodeOutput(workflowInstanceNode, ((OutputNode) node).getDescription());
+ this.getConfig().getConfiguration().getAiravataAPI().getProvenanceManager().setWorkflowNodeType(workflowInstanceNode, workflowNodeType);
if (this.config.isActOnProvenance()) {
try {