airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From samin...@apache.org
Subject svn commit: r1355446 - in /incubator/airavata/trunk/modules: airavata-client/src/main/java/org/apache/airavata/client/airavata/ airavata-client/src/main/java/org/apache/airavata/client/api/ airavata-client/src/main/java/org/apache/airavata/client/impl/...
Date Fri, 29 Jun 2012 15:28:02 GMT
Author: samindaw
Date: Fri Jun 29 15:28:00 2012
New Revision: 1355446

URL: http://svn.apache.org/viewvc?rev=1355446&view=rev
Log:
merging branch api changes with trunk

Modified:
    incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/airavata/AiravataClient.java
    incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataAPI.java
    incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ExecutionManager.java
    incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ExecutionManagerImpl.java
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataRegistry.java
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/AiravataJCRRegistry.java
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/WorkflowExecutionImpl.java
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowExecution.java

Modified: incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/airavata/AiravataClient.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/airavata/AiravataClient.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/airavata/AiravataClient.java
(original)
+++ incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/airavata/AiravataClient.java
Fri Jun 29 15:28:00 2012
@@ -33,6 +33,7 @@ import java.nio.channels.FileChannel;
 import java.nio.charset.Charset;
 import java.rmi.RemoteException;
 import java.util.ArrayList;
+import java.util.Calendar;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -354,14 +355,14 @@ public class AiravataClient implements A
 	 */
 	@Override
 	public String runWorkflow(String topic, String user) {
-		return runWorkflow(topic, user, null);
+		return runWorkflow(topic, user, null, topic);
 	}
 
 	/* (non-Javadoc)
 	 * @see org.apache.airavata.client.airavata.AiravataAPI#runWorkflow(java.lang.String, java.lang.String,
java.lang.String)
 	 */
 	@Override
-	public String runWorkflow(String topic, String user, String metadata) {
+	public String runWorkflow(String topic, String user, String metadata, String workflowInstanceName)
{
         String worflowoutput = null;
                 try {
                     WorkflowInterpretorStub stub = new WorkflowInterpretorStub(
@@ -369,7 +370,7 @@ public class AiravataClient implements A
                     OMElement omElement = AXIOMUtil.stringToOM(XMLUtil.xmlElementToString(builder.getXml()));
                     stub._getServiceClient().addHeader(omElement);
                     worflowoutput = stub.launchWorkflow(workflow, topic,null);
-                    runPostWorkflowExecutionTasks(worflowoutput, user, metadata);
+                    runPreWorkflowExecutionTasks(worflowoutput, user, metadata, workflowInstanceName);
 
                 } catch (AxisFault e) {
 		} catch (RemoteException e) {
@@ -422,14 +423,17 @@ public class AiravataClient implements A
         return monitor;
     }
     
-	private void runPostWorkflowExecutionTasks(String topic, String user,
-			String metadata) throws RegistryException {
+    private void runPreWorkflowExecutionTasks(String topic, String user,
+    		String metadata,String workflowInstanceName) throws RegistryException {
 		if (user != null) {
 			getRegistry().saveWorkflowExecutionUser(topic, user);
 		}
 		if (metadata != null) {
 			getRegistry().saveWorkflowExecutionMetadata(topic, metadata);
 		}
+		if (workflowInstanceName!=null) {
+			getRegistry().saveWorkflowExecutionName(topic, workflowInstanceName);
+		}
 	}
 
 	/* (non-Javadoc)
@@ -445,7 +449,7 @@ public class AiravataClient implements A
 	 */
 	@Override
 	public String runWorkflow(String topic, NameValue[] inputs, String user) throws Exception
{
-		return runWorkflow(topic, inputs, user, null);
+		return runWorkflow(topic, inputs, user, null,topic);
 	}
 
 	/* (non-Javadoc)
@@ -453,7 +457,7 @@ public class AiravataClient implements A
 	 */
 	@Override
 	public String runWorkflow(final String topic, final NameValue[] inputs, final String user,
-			final String metadata) throws Exception{
+			final String metadata, final String workflowInstanceName) throws Exception{
 		new Thread(new Runnable() {
 			public void run() {
 				try {
@@ -463,8 +467,8 @@ public class AiravataClient implements A
 					stub._getServiceClient().addHeader(
 							AXIOMUtil.stringToOM(XMLUtil
 									.xmlElementToString(builder.getXml())));
+					runPreWorkflowExecutionTasks(topic, user, metadata,workflowInstanceName);
 					stub.launchWorkflow(workflow, topic, inputs);
-					runPostWorkflowExecutionTasks(topic, user, metadata);
 					//			log.info("Workflow output : " + worflowoutput);
 				} catch (RegistryException e) {
 					//			log.fine(e.getMessage(), e);
@@ -620,32 +624,36 @@ public class AiravataClient implements A
 		}
 		return workflowList;
 	}
-
+	
+	public String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs) throws
Exception{
+		return runWorkflow(workflowTemplateId,inputs,getRegistry().getUsername(),null,workflowTemplateId+"_"+Calendar.getInstance().getTime().toString());
+	}
+	
 	/* (non-Javadoc)
 	 * @see org.apache.airavata.client.airavata.AiravataAPI#runWorkflow(java.lang.String, java.util.List)
 	 */
 	@Override
-	public String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs) throws
Exception{
-		return runWorkflow(workflowTemplateId,inputs,getRegistry().getUsername(),null);
+	public String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs,String
workflowInstanceName) throws Exception{
+		return runWorkflow(workflowTemplateId,inputs,getRegistry().getUsername(),null,workflowInstanceName);
 	}
 	
 	/* (non-Javadoc)
 	 * @see org.apache.airavata.client.airavata.AiravataAPI#runWorkflow(java.lang.String, java.util.List,
java.lang.String, java.lang.String)
 	 */
 	@Override
-	public String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs, String
user, String metadata) throws Exception{
+	public String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs, String
user, String metadata, String workflowInstanceName) throws Exception{
 		Workflow workflowObj = getWorkflow(workflowTemplateId);
-		return runWorkflow(workflowObj, inputs, user, metadata);
+		return runWorkflow(workflowObj, inputs, user, metadata,workflowInstanceName);
 	}
 
 	public String runWorkflow(Workflow workflow,
-			List<WorkflowInput> inputs)
+			List<WorkflowInput> inputs, String workflowInstanceName)
 			throws GraphException, ComponentException, Exception {
-		return runWorkflow(workflow, inputs, null, null);
+		return runWorkflow(workflow, inputs, null, null, workflowInstanceName);
 	}
 	
 	public String runWorkflow(Workflow workflowObj,
-			List<WorkflowInput> inputs, String user, String metadata)
+			List<WorkflowInput> inputs, String user, String metadata, String workflowInstanceName)
 			throws GraphException, ComponentException, Exception {
 		try {
 			String workflowString=XMLUtil.xmlElementToString(workflowObj.toXML());
@@ -669,7 +677,7 @@ public class AiravataClient implements A
 			}
 			workflow=workflowString;
 			String topic=workflowObj.getName()+"_"+UUID.randomUUID();
-			return runWorkflow(topic, inputValues.toArray(new NameValue[]{}), user, metadata);
+			return runWorkflow(topic, inputValues.toArray(new NameValue[]{}), user, metadata, workflowInstanceName);
 		} catch (PathNotFoundException e) {
 			e.printStackTrace();
 		} catch (RegistryException e) {

Modified: incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataAPI.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataAPI.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataAPI.java
(original)
+++ incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataAPI.java
Fri Jun 29 15:28:00 2012
@@ -96,7 +96,7 @@ public interface AiravataAPI {
      * @return
      */
 	public abstract String runWorkflow(String topic, String user,
-			String metadata);
+			String metadata, String workflowInstanceName);
 
     /**
      *
@@ -145,7 +145,7 @@ public interface AiravataAPI {
      * @throws Exception
      */
 	public abstract String runWorkflow(final String topic,
-			final NameValue[] inputs, final String user, final String metadata)
+			final NameValue[] inputs, final String user, final String metadata, String workflowInstanceName)
 			throws Exception;
 
     /**
@@ -203,8 +203,16 @@ public interface AiravataAPI {
 	 * @param inputs
 	 * @return
 	 */
+	public String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs) throws
Exception;
+	
+	/**
+	 * Execute the given workflow template with the given inputs and return the topic id and
workflow instance
+	 * @param workflowTemplateId
+	 * @param inputs
+	 * @return
+	 */
 	public abstract String runWorkflow(String workflowTemplateId,
-			List<WorkflowInput> inputs) throws Exception;
+			List<WorkflowInput> inputs, String workflowInstanceName) throws Exception;
 
 	/**
 	 * Execute the given workflow template with the given inputs, user, metadata and return
the topic id
@@ -216,7 +224,7 @@ public interface AiravataAPI {
 	 * @throws Exception
 	 */
 	public abstract String runWorkflow(String workflowTemplateId,
-			List<WorkflowInput> inputs, String user, String metadata)
+			List<WorkflowInput> inputs, String user, String metadata, String workflowInstanceName)
 			throws Exception;
 
 	/**

Modified: incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ExecutionManager.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ExecutionManager.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ExecutionManager.java
(original)
+++ incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ExecutionManager.java
Fri Jun 29 15:28:00 2012
@@ -53,10 +53,11 @@ public interface ExecutionManager {
      * @param inputs
      * @param user
      * @param metadata
+     * @param workflowInstanceName
      * @return
      * @throws AiravataAPIInvocationException
      */
-	public abstract String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs,
String user, String metadata)throws AiravataAPIInvocationException;
+	public abstract String runWorkflow(String workflowTemplateId,List<WorkflowInput> inputs,
String user, String metadata, String workflowInstanceName)throws AiravataAPIInvocationException;
 
     /**
      *

Modified: incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ExecutionManagerImpl.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ExecutionManagerImpl.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ExecutionManagerImpl.java
(original)
+++ incubator/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ExecutionManagerImpl.java
Fri Jun 29 15:28:00 2012
@@ -21,6 +21,7 @@
 
 package org.apache.airavata.client.impl;
 
+import java.util.Calendar;
 import java.util.List;
 
 import org.apache.airavata.client.airavata.AiravataClient;
@@ -41,7 +42,7 @@ public class ExecutionManagerImpl implem
 	@Override
 	public String runWorkflow(String workflowTemplateId,
 			List<WorkflowInput> inputs) throws AiravataAPIInvocationException {
-		return runWorkflow(workflowTemplateId, inputs ,getClient().getCurrentUser(),null);
+		return runWorkflow(workflowTemplateId, inputs ,getClient().getCurrentUser(),null, workflowTemplateId+"_"+Calendar.getInstance().getTime().toString());
 	}
 
 	@Override
@@ -52,10 +53,10 @@ public class ExecutionManagerImpl implem
 
 	@Override
 	public String runWorkflow(String workflowTemplateId,
-			List<WorkflowInput> inputs, String user, String metadata)
+			List<WorkflowInput> inputs, String user, String metadata, String workflowInstanceName)
 			throws AiravataAPIInvocationException {
 		try {
-			return getClient().runWorkflow(workflowTemplateId, inputs, user, metadata);
+			return getClient().runWorkflow(workflowTemplateId, inputs, user, metadata, workflowInstanceName);
 		} catch (Exception e) {
 			throw new AiravataAPIInvocationException(e);
 		}
@@ -66,7 +67,7 @@ public class ExecutionManagerImpl implem
 	public String runWorkflow(Workflow workflow, List<WorkflowInput> inputs,
 			String user, String metadata) throws AiravataAPIInvocationException {
 		try {
-			return getClient().runWorkflow(workflow, inputs, user, metadata);
+			return getClient().runWorkflow(workflow, inputs, user, metadata,workflow.getName()+"_"+Calendar.getInstance().getTime().toString());
 		} catch (Exception e) {
 			throw new AiravataAPIInvocationException(e);
 		}

Modified: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataRegistry.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataRegistry.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataRegistry.java
(original)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataRegistry.java
Fri Jun 29 15:28:00 2012
@@ -22,7 +22,6 @@
 package org.apache.airavata.registry.api;
 
 import java.net.URI;
-import java.net.URL;
 import java.util.List;
 import java.util.Map;
 
@@ -39,10 +38,10 @@ import org.apache.airavata.registry.api.
 import org.apache.airavata.registry.api.exception.HostDescriptionRetrieveException;
 import org.apache.airavata.registry.api.exception.ServiceDescriptionRetrieveException;
 import org.apache.airavata.registry.api.workflow.WorkflowExecution;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
 import org.apache.airavata.registry.api.workflow.WorkflowIOData;
-import org.apache.airavata.registry.api.workflow.WorkflowServiceIOData;
+import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
 import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus.ExecutionStatus;
+import org.apache.airavata.registry.api.workflow.WorkflowServiceIOData;
 
 public interface AiravataRegistry extends Registry{
     /**
@@ -244,7 +243,9 @@ public interface AiravataRegistry extend
     public List<WorkflowServiceIOData> searchWorkflowExecutionServiceInput(String experimentIdRegEx,
String workflowNameRegEx, String nodeNameRegEx)throws RegistryException;
 
     public List<WorkflowServiceIOData> searchWorkflowExecutionServiceOutput(String
experimentIdRegEx, String workflowNameRegEx, String nodeNameRegEx)throws RegistryException;
-
+    
+    public boolean saveWorkflowExecutionName(String experimentId,String workflowIntanceName)throws
RegistryException;
+    
     public boolean saveWorkflowExecutionStatus(String experimentId,WorkflowInstanceStatus
status)throws RegistryException;
     
     public boolean saveWorkflowExecutionStatus(String experimentId,ExecutionStatus status)throws
RegistryException;
@@ -265,6 +266,8 @@ public interface AiravataRegistry extend
     
     public String getWorkflowExecutionUser(String experimentId) throws RegistryException;
     
+    public String getWorkflowExecutionName(String experimentId) throws RegistryException;
+    
     public WorkflowExecution getWorkflowExecution(String experimentId) throws RegistryException;
     
     public List<String> getWorkflowExecutionIdByUser(String user) throws RegistryException;

Modified: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/AiravataJCRRegistry.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/AiravataJCRRegistry.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/AiravataJCRRegistry.java
(original)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/AiravataJCRRegistry.java
Fri Jun 29 15:28:00 2012
@@ -96,6 +96,7 @@ public class AiravataJCRRegistry extends
     public static final String WORKFLOW_STATUS_PROPERTY = "Status";
     public static final String WORKFLOW_STATUS_TIME_PROPERTY = "Status_Time";
     public static final String WORKFLOW_METADATA_PROPERTY = "Metadata";
+    public static final String WORKFLOW_INSTANCE_NAME_PROPERTY = "Worflow_instace_name";
     public static final String WORKFLOW_USER_PROPERTY = "User";
     public static final String NOTIFICATION_STORE = "User";
 
@@ -1173,6 +1174,7 @@ public class AiravataJCRRegistry extends
 		workflowExecution.setExecutionStatus(getWorkflowExecutionStatus(experimentId));
 		workflowExecution.setUser(getWorkflowExecutionUser(experimentId));
 		workflowExecution.setMetadata(getWorkflowExecutionMetadata(experimentId));
+		workflowExecution.setWorkflowInstanceName(getWorkflowExecutionName(experimentId));
 		workflowExecution.setOutput(getWorkflowExecutionOutput(experimentId));
 		workflowExecution.setServiceInput(searchWorkflowExecutionServiceInput(experimentId,".*",".*"));
 		workflowExecution.setServiceOutput(searchWorkflowExecutionServiceOutput(experimentId,".*",".*"));
@@ -1196,8 +1198,10 @@ public class AiravataJCRRegistry extends
 		try {
 			session = getSession();
 			List<String> matchingExperimentIds = getMatchingExperimentIds(".*", session);
+			Pattern compile = Pattern.compile(user==null? ".*":user);
 			for (String id : matchingExperimentIds) {
-				if (user==null || user.equals(getWorkflowExecutionUser(id))){
+				String instanceUser = getWorkflowExecutionUser(id);
+				if (user==null || (instanceUser!=null && compile.matcher(instanceUser).find())){
 					ids.add(id);
 				}
 			}
@@ -1279,6 +1283,45 @@ public class AiravataJCRRegistry extends
 			ExecutionStatus status) throws RegistryException {
 		return saveWorkflowExecutionStatus(experimentId,new WorkflowInstanceStatus(new WorkflowInstance(experimentId,
experimentId), status));
 	}
+	@Override
+	public boolean saveWorkflowExecutionName(String experimentId,
+			String workflowIntanceName) throws RegistryException {
+		Session session = null;
+        boolean isSaved = true;
+        try {
+            session = getSession();
+            Node workflowDataNode = getWorkflowExperimentDataNode(experimentId, session);
+            workflowDataNode.setProperty(WORKFLOW_INSTANCE_NAME_PROPERTY,workflowIntanceName);
+            session.save();
+        } catch (Exception e) {
+            isSaved = false;
+            e.printStackTrace();
+        } finally {
+            closeSession(session);
+        }
+        return isSaved;
+	}
+
+	@Override
+	public String getWorkflowExecutionName(String experimentId)
+			throws RegistryException {
+		Session session = null;
+    	String property = null;
+        try {
+            session = getSession();
+            Node workflowDataNode = getWorkflowExperimentDataNode(experimentId, session);
+            if (workflowDataNode.hasProperty(WORKFLOW_INSTANCE_NAME_PROPERTY)) {
+				property = workflowDataNode.getProperty(
+						WORKFLOW_INSTANCE_NAME_PROPERTY).getString();
+			}
+			session.save();
+        } catch (Exception e) {
+            throw new RegistryException("Error while retrieving workflow metadata!!!", e);
+        } finally {
+            closeSession(session);
+        }
+        return property;
+	}	
 
 	private void saveServiceURL(URI gfacURL, String nodeName)
 			throws Exception {

Modified: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/WorkflowExecutionImpl.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/WorkflowExecutionImpl.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/WorkflowExecutionImpl.java
(original)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/impl/WorkflowExecutionImpl.java
Fri Jun 29 15:28:00 2012
@@ -37,6 +37,7 @@ public class WorkflowExecutionImpl imple
 	private List<WorkflowIOData> output;
 	private String experimentId;
 	private String metadata;
+	private String workflowInstanceName;
 	
 	public String getMetadata() {
 		return metadata;
@@ -125,4 +126,14 @@ public class WorkflowExecutionImpl imple
 		}
 		return null;
 	}
+	@Override
+	public String getWorkflowInstanceName() {
+		return workflowInstanceName;
+	}
+	
+	@Override
+	public void setWorkflowInstanceName(String workflowInstanceName) {
+		this.workflowInstanceName=workflowInstanceName;
+		
+	}
 }

Modified: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowExecution.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowExecution.java?rev=1355446&r1=1355445&r2=1355446&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowExecution.java
(original)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowExecution.java
Fri Jun 29 15:28:00 2012
@@ -36,7 +36,8 @@ public interface WorkflowExecution {
 	public WorkflowServiceIOData getServiceOutput(String nodeId);
 	public WorkflowIOData getOutput(String nodeId);
 	public String getMetadata();
-
+	public String getWorkflowInstanceName();
+	
 	public void setExperimentId(String experimentId);
 	public void setTopic(String topic);
 	public void setExecutionStatus(WorkflowInstanceStatus executionStatus);
@@ -48,4 +49,5 @@ public interface WorkflowExecution {
 	public void addServiceOutput(WorkflowServiceIOData serviceOutput);
 	public void addOutput(WorkflowIOData output);
 	public void setMetadata(String metadata);
+	public void setWorkflowInstanceName(String workflowInstanceName);
 }



Mime
View raw message