svn commit: r1389688 - /airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/AiravataClient.java

[samindaw]

Author: samindaw
Date: Tue Sep 25 02:40:32 2012
New Revision: 1389688

URL: http://svn.apache.org/viewvc?rev=1389688&view=rev
Log:
save template name

Modified:
    
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/AiravataClient.java

Modified: 
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/AiravataClient.java
URL: 
http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/AiravataClient.java?rev=1389688&r1=1389687&r2=1389688&view=diff
==============================================================================
--- 
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/AiravataClient.java
 (original)
+++ 
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/AiravataClient.java
 Tue Sep 25 02:40:32 2012
@@ -72,6 +72,11 @@ import org.apache.airavata.common.workfl
 import org.apache.airavata.registry.api.AiravataRegistry2;
 import org.apache.airavata.registry.api.impl.AiravataJCRRegistry;
 import org.apache.airavata.registry.api.workflow.ExperimentData;
+import org.apache.airavata.registry.api.workflow.WorkflowInstance;
+import org.apache.airavata.registry.api.workflow.WorkflowInstanceData;
+import org.apache.airavata.registry.api.workflow.WorkflowInstanceNode;
+import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
+import 
org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus.ExecutionStatus;
 import org.apache.airavata.workflow.model.component.ComponentException;
 import 
org.apache.airavata.workflow.model.component.registry.JCRComponentRegistry;
 import org.apache.airavata.workflow.model.component.ws.WSComponentPort;
@@ -129,7 +134,7 @@ public class AiravataClient implements A
 
        // private NameValue[] configurations = new NameValue[7];
 
-       private static final Version API_VERSION=new 
Version("Airavata",0,4,null,"INCUBATING",null);
+       private static final Version API_VERSION=new 
Version("Airavata",0,5,null,null,null);
        
        protected AiravataClient(Map<String,String> configuration)
                        throws MalformedURLException {
@@ -619,6 +624,7 @@ public class AiravataClient implements A
                        }
                        workflow=workflowString;
                        String 
topic=workflowObj.getName()+"_"+UUID.randomUUID();
+                       getRegistry().setWorkflowInstanceTemplateName(topic, 
workflowObj.getName());
                        return runWorkflow(topic, inputValues.toArray(new 
NameValue[]{}), user, metadata, workflowInstanceName,builder);
                } catch (PathNotFoundException e) {
                        e.printStackTrace();
@@ -719,11 +725,18 @@ public class AiravataClient implements A
        public static void main(String[] args) throws Exception {
                AiravataAPI api = AiravataClientUtils.getAPI(new 
URI("http://localhost:8080";), "admin", "admin");
                ProvenanceManager pm = api.getProvenanceManager();
+               ExperimentData workflowExperimentData = 
pm.getWorkflowExperimentData("Workflow1_9341caee-b3fc-4474-9b15-b943756a5839");
+               
+//             pm.getExperimentIdList(owner)
+//             workflowInstanceData = 
d.getWorkflowInstanceData().get(0).getNodeDataList();
+//             d.get
+//             pm.setWorkflowInstanceNodeOutput(new WorkflowInstanceNode(new 
WorkflowInstance("test", "test"), "test_node"), "some_data");
+//             pm.setWorkflowInstanceStatus(new WorkflowInstanceStatus(new 
WorkflowInstance("test", "test"), ExecutionStatus.RUNNING));
 //             List<String> experiments = pm.getExperiments();
 //             for (String id : experiments) {
 //                     System.out.println(id);
 //             }
-               api.getAiravataManager().getEventingServiceURL();
+//             api.getAiravataManager().getEventingServiceURL();
 //             
System.out.println(api.getAiravataManager().getEventingServiceURL());
                
 ////           AiravataAPI api = AiravataClientUtils.getAPI(new 
URI("http://gf7.ucs.indiana.edu:8030/jackrabbit/rmi";), "admin", "admin");