airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject svn commit: r1377006 - in /incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api: ./ impl/ workflow/
Date Fri, 24 Aug 2012 17:48:32 GMT
Author: lahiru
Date: Fri Aug 24 17:48:32 2012
New Revision: 1377006

URL: http://svn.apache.org/viewvc?rev=1377006&view=rev
Log:
adding modification to cope with AiravataProvenanceRegistry interface.

Added:
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeGramData.java
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeType.java
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowRunTimeData.java
Modified:
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataProvenanceRegistry.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/workflow/WorkflowInstance.java
    incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowServiceIOData.java

Modified: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataProvenanceRegistry.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataProvenanceRegistry.java?rev=1377006&r1=1377005&r2=1377006&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataProvenanceRegistry.java
(original)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/AiravataProvenanceRegistry.java
Fri Aug 24 17:48:32 2012
@@ -21,14 +21,12 @@
 
 package org.apache.airavata.registry.api;
 
+import java.sql.Timestamp;
 import java.util.List;
 
 import org.apache.airavata.common.registry.api.exception.RegistryException;
-import org.apache.airavata.registry.api.workflow.WorkflowExecution;
-import org.apache.airavata.registry.api.workflow.WorkflowIOData;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
+import org.apache.airavata.registry.api.workflow.*;
 import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus.ExecutionStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowServiceIOData;
 
 public abstract class AiravataProvenanceRegistry implements DataRegistry{
 	private String user;
@@ -73,15 +71,6 @@ public abstract class AiravataProvenance
 	public abstract boolean saveWorkflowExecutionName(String experimentId,String workflowIntanceName)throws
RegistryException;
     
     /**
-     * Save a status for this workflow execution
-     * @param experimentId
-     * @param status - contains the status and the time of the status was defined
-     * @return
-     * @throws RegistryException
-     */
-	public abstract boolean saveWorkflowExecutionStatus(String experimentId,WorkflowInstanceStatus
status)throws RegistryException;
-    
-    /**
      * Save a status for this workflow execution with the current time at the moment
      * @param experimentId
      * @param status - contains the status
@@ -233,7 +222,63 @@ public abstract class AiravataProvenance
      * @throws RegistryException
      */
     public abstract List<WorkflowExecution> getWorkflowExecutionByUser(String user,
int pageSize, int pageNo) throws RegistryException;
-    
+
+    /**
+     * This store set of metadata for each Workflow Run, Not the workflowNode Specific data,
just full workflow Run specific data
+     * @param runTimeData
+     * @return
+     */
+    public abstract boolean saveWorkflowData(WorkflowRunTimeData runTimeData)throws RegistryException;
+
+    /**
+     * This will update the workflowStatus for given experimentID,workflowInstanceID combination.
+     * @param workflowInstanceID
+     * @param workflowStatus
+     * @return
+     */
+    public abstract boolean saveWorkflowStatus(String workflowInstanceID,WorkflowInstanceStatus
workflowStatus)throws RegistryException;
+
+    /**
+     * This will update the last update time of the workflow.
+     * @param workflowInstanceID
+     * @param lastUpdateTime
+     * @return
+     */
+    public abstract boolean saveWorkflowLastUpdateTime(String workflowInstanceID,Timestamp
lastUpdateTime)throws RegistryException;
+
+    /**
+     * This will change the status of a given WorkflowNode for a given workflowInstanceID(given
workflow Run).
+     * @param workflowInstanceID
+     * @param status
+     * @return
+     */
+    public abstract boolean saveWorkflowNodeStatus(String workflowInstanceID,String workflowNodeID,ExecutionStatus
status)throws RegistryException;
+
+    /**
+     * This will change the lastUpdate time for a given Workflow Node for a given workflow
Run.
+     * @param workflowInstanceID
+     * @param workflowNodeID
+     * @param lastUpdateTime
+     * @return
+     */
+    public abstract boolean saveWorkflowNodeLastUpdateTime(String workflowInstanceID,String
workflowNodeID,Timestamp lastUpdateTime)throws RegistryException;
+
+    /**
+     * This will store the gram specific data in to repository, this can be called before
submitting the workflow in to Grid
+     * @param workflowNodeGramData
+     * @return
+     */
+    public abstract boolean saveWorkflowNodeGramData(WorkflowNodeGramData workflowNodeGramData)throws
RegistryException;
+
+    /**
+     * This will update the local job ID for a submitted job to grid.
+     * @param workflowInstanceID
+     * @param workflowNodeID
+     * @param localJobID
+     * @return
+     */
+    public abstract boolean saveWorkflowNodeGramLocalJobID(String workflowInstanceID,String
workflowNodeID,String localJobID)throws RegistryException;
+
 	public String getUser() {
 		return user;
 	}

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=1377006&r1=1377005&r2=1377006&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 Aug 24 17:48:32 2012
@@ -22,6 +22,7 @@
 package org.apache.airavata.registry.api;
 
 import java.net.URI;
+import java.sql.Timestamp;
 import java.util.List;
 import java.util.Map;
 
@@ -37,11 +38,8 @@ import org.apache.airavata.commons.gfac.
 import org.apache.airavata.registry.api.exception.DeploymentDescriptionRetrieveException;
 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.WorkflowIOData;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
+import org.apache.airavata.registry.api.workflow.*;
 import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus.ExecutionStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowServiceIOData;
 
 public interface AiravataRegistry extends Registry{
     /**
@@ -281,4 +279,16 @@ public interface AiravataRegistry extend
     public String getWorkflowExecutionMetadata(String experimentId) throws RegistryException;
     
     public boolean saveWorkflowExecutionMetadata(String experimentId, String metadata) throws
RegistryException;
+
+    public boolean saveWorkflowData(WorkflowRunTimeData workflowData)throws RegistryException;
+
+    public  boolean saveWorkflowLastUpdateTime(String experimentId,Timestamp timestamp)throws
RegistryException;
+
+    public boolean saveWorkflowNodeStatus(String workflowInstanceID,String workflowNodeID,ExecutionStatus
status)throws RegistryException;
+
+    public boolean saveWorkflowNodeLastUpdateTime(String workflowInstanceID,String workflowNodeID,Timestamp
lastUpdateTime)throws RegistryException;
+
+    public boolean saveWorkflowNodeGramData(WorkflowNodeGramData workflowNodeGramData)throws
RegistryException;
+
+    public boolean saveWorkflowNodeGramLocalJobID(String workflowInstanceID,String workflowNodeID,String
localJobID)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=1377006&r1=1377005&r2=1377006&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 Aug 24 17:48:32 2012
@@ -53,12 +53,8 @@ import org.apache.airavata.registry.api.
 import org.apache.airavata.registry.api.exception.DeploymentDescriptionRetrieveException;
 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.WorkflowIOData;
-import org.apache.airavata.registry.api.workflow.WorkflowInstance;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
+import org.apache.airavata.registry.api.workflow.*;
 import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus.ExecutionStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowServiceIOData;
 import org.apache.airavata.schemas.gfac.MethodType;
 import org.apache.airavata.schemas.gfac.PortTypeType;
 import org.apache.airavata.schemas.gfac.ServiceType;
@@ -951,7 +947,7 @@ public class AiravataJCRRegistry extends
 
     public boolean saveWorkflowExecutionStatus(String experimentId,WorkflowInstanceStatus
status)throws RegistryException{
     	if (getProvenanceRegistry()!=null){
-    		return getProvenanceRegistry().saveWorkflowExecutionStatus(experimentId, status);
+    		return getProvenanceRegistry().saveWorkflowExecutionStatus(experimentId, status.getExecutionStatus());
     	}
         Session session = null;
         boolean isSaved = true;
@@ -1359,6 +1355,7 @@ public class AiravataJCRRegistry extends
     	}
 		return saveWorkflowExecutionStatus(experimentId,new WorkflowInstanceStatus(new WorkflowInstance(experimentId,
experimentId), status));
 	}
+
 	@Override
 	public boolean saveWorkflowExecutionName(String experimentId,
 			String workflowIntanceName) throws RegistryException {
@@ -1625,4 +1622,51 @@ public class AiravataJCRRegistry extends
 		}
         
 	}
+    @Override
+    public boolean saveWorkflowData(WorkflowRunTimeData workflowData)throws RegistryException{
+        if (getProvenanceRegistry()!=null){
+    		return getProvenanceRegistry().saveWorkflowData(workflowData);
+    	}
+        return false;
+    }
+
+    @Override
+    public  boolean saveWorkflowLastUpdateTime(String experimentId,Timestamp timestamp)throws
RegistryException{
+        if (getProvenanceRegistry()!=null){
+    		return getProvenanceRegistry().saveWorkflowLastUpdateTime(experimentId, timestamp);
+    	}
+        return false;
+    }
+
+    @Override
+    public boolean saveWorkflowNodeStatus(String workflowInstanceID,String workflowNodeID,ExecutionStatus
status)throws RegistryException{
+       if (getProvenanceRegistry()!=null){
+    		return getProvenanceRegistry().saveWorkflowNodeStatus(workflowInstanceID,workflowNodeID,
status);
+    	}
+        return false;
+    }
+
+    @Override
+    public boolean saveWorkflowNodeLastUpdateTime(String workflowInstanceID,String workflowNodeID,Timestamp
lastUpdateTime)throws RegistryException{
+        if (getProvenanceRegistry()!=null){
+    		return getProvenanceRegistry().saveWorkflowNodeLastUpdateTime(workflowInstanceID,workflowNodeID,
lastUpdateTime);
+    	}
+        return false;
+    }
+
+    @Override
+    public boolean saveWorkflowNodeGramData(WorkflowNodeGramData workflowNodeGramData)throws
RegistryException{
+        if (getProvenanceRegistry()!=null){
+    		return getProvenanceRegistry().saveWorkflowNodeGramData(workflowNodeGramData);
+    	}
+        return false;
+    }
+
+    @Override
+    public boolean saveWorkflowNodeGramLocalJobID(String workflowInstanceID, String workflowNodeID,
String localJobID) throws RegistryException {
+        if (getProvenanceRegistry() != null) {
+            return getProvenanceRegistry().saveWorkflowNodeGramLocalJobID(workflowInstanceID,
workflowNodeID, localJobID);
+        }
+        return false;
+    }
 }

Modified: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstance.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstance.java?rev=1377006&r1=1377005&r2=1377006&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstance.java
(original)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowInstance.java
Fri Aug 24 17:48:32 2012
@@ -31,7 +31,13 @@ public class WorkflowInstance {
 		setWorkflowInstanceId(topicId);
 	}
 
-	public String getWorkflowInstanceId() {
+    public WorkflowInstance(String experimentId, String workflowInstanceId, String workflowName)
{
+        this.experimentId = experimentId;
+        this.workflowInstanceId = workflowInstanceId;
+        this.workflowName = workflowName;
+    }
+
+    public String getWorkflowInstanceId() {
 		return workflowInstanceId;
 	}
 

Added: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeGramData.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeGramData.java?rev=1377006&view=auto
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeGramData.java
(added)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeGramData.java
Fri Aug 24 17:48:32 2012
@@ -0,0 +1,67 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+*/
+package org.apache.airavata.registry.api.workflow;
+
+public class WorkflowNodeGramData {
+    String NodeID;
+    String rsl;
+    String invokedHost;
+    String gramJobID;
+
+    public WorkflowNodeGramData(String nodeID, String rsl, String invokedHost, String gramJobID)
{
+        NodeID = nodeID;
+        this.rsl = rsl;
+        this.invokedHost = invokedHost;
+        this.gramJobID = gramJobID;
+    }
+
+    public void setNodeID(String nodeID) {
+        NodeID = nodeID;
+    }
+
+    public void setRsl(String rsl) {
+        this.rsl = rsl;
+    }
+
+    public void setInvokedHost(String invokedHost) {
+        this.invokedHost = invokedHost;
+    }
+
+    public void setGramJobID(String gramJobID) {
+        this.gramJobID = gramJobID;
+    }
+
+    public String getNodeID() {
+        return NodeID;
+    }
+
+    public String getRsl() {
+        return rsl;
+    }
+
+    public String getInvokedHost() {
+        return invokedHost;
+    }
+
+    public String getGramJobID() {
+        return gramJobID;
+    }
+}

Added: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeType.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeType.java?rev=1377006&view=auto
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeType.java
(added)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowNodeType.java
Fri Aug 24 17:48:32 2012
@@ -0,0 +1,40 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+*/
+package org.apache.airavata.registry.api.workflow;
+
+public class WorkflowNodeType {
+    public enum WorkflowNode{
+		SERVICENODE,
+		CONTROLNODE,
+	    INPUTNODE,
+		OUTPUTNODE,
+		UNKNOWN,
+	}
+    private WorkflowNode nodeType;
+
+    public WorkflowNode getNodeType() {
+        return nodeType;
+    }
+
+    public void setNodeType(WorkflowNode nodeType) {
+        this.nodeType = nodeType;
+    }
+}

Added: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowRunTimeData.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowRunTimeData.java?rev=1377006&view=auto
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowRunTimeData.java
(added)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowRunTimeData.java
Fri Aug 24 17:48:32 2012
@@ -0,0 +1,90 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+*/
+package org.apache.airavata.registry.api.workflow;
+
+import java.sql.Timestamp;
+
+public class WorkflowRunTimeData {
+    String experimentID;
+    String workflowInstanceID;
+    String templateID;
+    Timestamp startTime;
+    WorkflowInstanceStatus.ExecutionStatus workflowStatus;
+    Timestamp lastUpdateTime;
+
+    public WorkflowRunTimeData(String experimentID, String workflowInstanceID, String templateID,
+                               Timestamp startTime, WorkflowInstanceStatus.ExecutionStatus
workflowStatus, Timestamp lastUpdateTime) {
+        this.experimentID = experimentID;
+        this.workflowInstanceID = workflowInstanceID;
+        this.templateID = templateID;
+        this.startTime = startTime;
+        this.workflowStatus = workflowStatus;
+        this.lastUpdateTime = lastUpdateTime;
+    }
+
+    public String getExperimentID() {
+        return experimentID;
+    }
+
+    public String getWorkflowInstanceID() {
+        return workflowInstanceID;
+    }
+
+    public String getTemplateID() {
+        return templateID;
+    }
+
+    public Timestamp getStartTime() {
+        return startTime;
+    }
+
+    public WorkflowInstanceStatus.ExecutionStatus getWorkflowStatus() {
+        return workflowStatus;
+    }
+
+    public Timestamp getLastUpdateTime() {
+        return lastUpdateTime;
+    }
+
+    public void setExperimentID(String experimentID) {
+        this.experimentID = experimentID;
+    }
+
+    public void setWorkflowInstanceID(String workflowInstanceID) {
+        this.workflowInstanceID = workflowInstanceID;
+    }
+
+    public void setTemplateID(String templateID) {
+        this.templateID = templateID;
+    }
+
+    public void setStartTime(Timestamp startTime) {
+        this.startTime = startTime;
+    }
+
+    public void setWorkflowStatus(WorkflowInstanceStatus.ExecutionStatus workflowStatus)
{
+        this.workflowStatus = workflowStatus;
+    }
+
+    public void setLastUpdateTime(Timestamp lastUpdateTime) {
+        this.lastUpdateTime = lastUpdateTime;
+    }
+}

Modified: incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowServiceIOData.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowServiceIOData.java?rev=1377006&r1=1377005&r2=1377006&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowServiceIOData.java
(original)
+++ incubator/airavata/trunk/modules/commons/registry-api/src/main/java/org/apache/airavata/registry/api/workflow/WorkflowServiceIOData.java
Fri Aug 24 17:48:32 2012
@@ -25,6 +25,10 @@ public class WorkflowServiceIOData exten
 	private String experimentId;
     private String workflowName;
     private String workflowId;
+    private WorkflowNodeType nodeType;
+    /** when you construct this object it set to STARTED state **/
+    private WorkflowInstanceStatus nodeStatus = new
+            WorkflowInstanceStatus(new WorkflowInstance(experimentId,workflowId,workflowName),
WorkflowInstanceStatus.ExecutionStatus.STARTED);
     
     public WorkflowServiceIOData() {
 	}
@@ -42,7 +46,14 @@ public class WorkflowServiceIOData exten
 		this(data, experimentId, experimentId, nodeId, workflowName);
 	}
 
-	public String getExperimentId() {
+    public WorkflowServiceIOData(String experimentId, String workflowName, String workflowId,
WorkflowNodeType nodeType) {
+        this.experimentId = experimentId;
+        this.workflowName = workflowName;
+        this.workflowId = workflowId;
+        this.nodeType = nodeType;
+    }
+
+    public String getExperimentId() {
 		return experimentId;
 	}
 



Mime
View raw message