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 {
