airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chath...@apache.org
Subject [1/3] adding more to AIRAVATA-1234
Date Fri, 22 Aug 2014 20:10:22 GMT
Repository: airavata
Updated Branches:
  refs/heads/master f72637f21 -> 98f411019


http://git-wip-us.apache.org/repos/asf/airavata/blob/98f41101/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java
index d311fbf..e922a68 100644
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java
+++ b/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java
@@ -1,635 +1,638 @@
-/*
- *
- * 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.client.impl;
-
-import java.util.Calendar;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.airavata.client.AiravataClient;
-import org.apache.airavata.client.api.ProvenanceManager;
-import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
-import org.apache.airavata.common.exception.AiravataConfigurationException;
-import org.apache.airavata.registry.api.AiravataExperiment;
-import org.apache.airavata.registry.api.exception.RegException;
-import org.apache.airavata.registry.api.workflow.ApplicationJob;
-import org.apache.airavata.registry.api.workflow.ApplicationJob.ApplicationJobStatus;
-import org.apache.airavata.registry.api.workflow.ApplicationJobStatusData;
-import org.apache.airavata.registry.api.workflow.ExperimentData;
-import org.apache.airavata.registry.api.workflow.ExperimentMetadata;
-import org.apache.airavata.registry.api.workflow.ExperimentName;
-import org.apache.airavata.registry.api.workflow.ExperimentUser;
-import org.apache.airavata.registry.api.workflow.NodeExecutionStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowExecution;
-import org.apache.airavata.registry.api.workflow.WorkflowExecutionData;
-import org.apache.airavata.registry.api.workflow.WorkflowExecutionStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowExecutionStatus.State;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceNode;
-import org.apache.airavata.registry.api.workflow.WorkflowNodeGramData;
-import org.apache.airavata.registry.api.workflow.WorkflowNodeIOData;
-import org.apache.airavata.registry.api.workflow.WorkflowNodeType;
-
-public class ProvenanceManagerImpl implements ProvenanceManager {
-	private AiravataClient client;
-	
-	public ProvenanceManagerImpl(AiravataClient client) {
-		setClient(client);
-	}
-	
-	@Override
-	public void setWorkflowInstanceNodeInput(WorkflowInstanceNode node, String data)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateWorkflowNodeInput(node, data);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void setWorkflowInstanceNodeInput(String experimentId,
-			String workflowInstanceId, String nodeId, String data)
-			throws AiravataAPIInvocationException {
-		setWorkflowInstanceNodeInput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId), data);
-	}
-
-	@Override
-	public void setWorkflowInstanceNodeOutput(WorkflowInstanceNode node, String data)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateWorkflowNodeOutput(node, data);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void setWorkflowInstanceNodeOutput(String experimentId,
-			String workflowInstanceId, String nodeId, String data)
-			throws AiravataAPIInvocationException {
-		setWorkflowInstanceNodeOutput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId), data);
-		
-	}
-
-	@Override
-	public String getWorkflowInstanceNodeInput(WorkflowInstanceNode node) throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getWorkflowInstanceNodeData(node.getWorkflowInstance().getWorkflowExecutionId(), node.getNodeId()).getInput();
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public String getWorkflowInstanceNodeInput(String experimentId, String workflowInstanceId, String nodeId)
-			throws AiravataAPIInvocationException {
-		return getWorkflowInstanceNodeInput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId));
-	}
-	
-	@Override
-	public Map<WorkflowInstanceNode,String> getWorkflowInstanceNodeInput(String workflowName, String nodeId) throws AiravataAPIInvocationException{
-		try {
-			List<WorkflowNodeIOData> list = getClient().getRegistryClient().searchWorkflowInstanceNodeInput(".*", workflowName, nodeId);
-			return groupNodePortData(list);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	private Map<WorkflowInstanceNode, String> groupNodePortData(List<WorkflowNodeIOData> list) {
-		Map<WorkflowInstanceNode,String> portData=new HashMap<WorkflowInstanceNode, String>();
-		for (WorkflowNodeIOData data : list) {
-			portData.put(new WorkflowInstanceNode(new WorkflowExecution(data.getExperimentId(), data.getWorkflowInstanceId()), data.getNodeId()), data.getValue());
-		}
-		return portData;
-	}
-
-	@Override
-	public String getWorkflowInstanceNodeOutput(WorkflowInstanceNode node) throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getWorkflowInstanceNodeData(node.getWorkflowInstance().getWorkflowExecutionId(), node.getNodeId()).getOutput();
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public String getWorkflowInstanceNodeOutput(String experimentId, String workflowInstanceId, String nodeId)
-			throws AiravataAPIInvocationException {
-		return getWorkflowInstanceNodeOutput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId));
-
-	}
-
-	@Override
-	public Map<WorkflowInstanceNode,String> getWorkflowInstanceNodeOutput(String workflowName, String nodeId) throws AiravataAPIInvocationException{
-		try {
-			List<WorkflowNodeIOData> list = getClient().getRegistryClient().searchWorkflowInstanceNodeOutput(".*", workflowName, nodeId);
-			return groupNodePortData(list);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-	
-	@Override
-	public void setWorkflowInstanceStatus(String experimentId, String workflowInstanceId,
-			State status) throws AiravataAPIInvocationException {
-		setWorkflowInstanceStatus(new WorkflowExecutionStatus(new WorkflowExecution(experimentId, workflowInstanceId),status));
-	}
-
-	@Override
-	public void setWorkflowInstanceStatus(WorkflowExecutionStatus status)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateWorkflowInstanceStatus(status);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-		
-	}
-
-	@Override
-	public WorkflowExecutionStatus getWorkflowInstanceStatus(
-			String experimentId, String workflowInstanceId)
-			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getWorkflowInstanceStatus(experimentId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public WorkflowExecutionStatus getWorkflowInstanceStatus(
-			WorkflowExecution workflowInstance)
-			throws AiravataAPIInvocationException {
-		return getWorkflowInstanceStatus(workflowInstance.getExperimentId(), workflowInstance.getWorkflowExecutionId());
-	}
-
-	@Override
-	public void setExperimentUser(String experimentId, String user) throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateExperimentExecutionUser(experimentId, user);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void setExperimentUser(ExperimentUser user)
-			throws AiravataAPIInvocationException {
-		setExperimentUser(user.getExperimentId(), user.getUser());
-	}
-
-	@Override
-	public ExperimentUser getExperimentUser(String experimentId)throws AiravataAPIInvocationException {
-		try {
-			return new ExperimentUser(experimentId,getClient().getRegistryClient().getExperimentExecutionUser(experimentId));
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void setExperimentMetadata(String experimentId, String metadata)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateExperimentMetadata(experimentId, metadata);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-		
-	}
-
-	@Override
-	public void setExperimentMetadata(ExperimentMetadata instanceMetadata)
-			throws AiravataAPIInvocationException {
-		setExperimentMetadata(instanceMetadata.getExperimentId(), instanceMetadata.getMetadata());
-	}
-
-	@Override
-	public ExperimentMetadata getExperimentMetadata(String experimentId)throws AiravataAPIInvocationException {
-		try {
-			return new ExperimentMetadata(experimentId, getClient().getRegistryClient().getExperimentMetadata(experimentId));
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-    @Override
-    public boolean isExperimentNameExist(String experimentName) throws AiravataAPIInvocationException {
-        try {
-            return getClient().getRegistryClient().isExperimentNameExist(experimentName);
-        } catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
-    }
-
-    @Override
-	public List<String> getExperimentIdList(String owner) throws AiravataAPIInvocationException{
-		try {
-			return getClient().getRegistryClient().getExperimentIdByUser(owner);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-	
-	@Override
-	public List<String> getExperimentIdList() throws AiravataAPIInvocationException {
-		return getExperimentIdList(getClient().getCurrentUser());
-	}
-
-	@Override
-	public List<ExperimentData> getWorkflowExperimentDataList()
-			throws AiravataAPIInvocationException {
-		return getWorkflowExperimentDataList(getClient().getCurrentUser());
-	}
-
-	@Override
-	public List<ExperimentData> getWorkflowExperimentDataList(String user)
-			throws AiravataAPIInvocationException {
-		try {
-			return  getClient().getRegistryClient().getExperimentByUser(user);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public List<ExperimentData> getWorkflowExperimentData(String user,
-			int pageSize, int pageNo) throws AiravataAPIInvocationException {
-		try {
-			return  getClient().getRegistryClient().getExperimentByUser(user, pageSize, pageNo);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public WorkflowExecutionData getWorkflowInstanceData(String experimentId,
-			String workflowInstanceId) throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getWorkflowInstanceData(workflowInstanceId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public WorkflowExecutionData getWorkflowInstanceData(WorkflowExecution workflowInstance)
-			throws AiravataAPIInvocationException {
-		return getWorkflowInstanceData(workflowInstance.getExperimentId(), workflowInstance.getWorkflowExecutionId());
-	}
-
-	@Override
-	public String[] getWorkflowExecutionOutputNames(String exeperimentId)
-			throws AiravataAPIInvocationException {
-		throw new AiravataAPIInvocationException(new Exception("Not implemented"));
-	}
-
-	public AiravataClient getClient() {
-		return client;
-	}
-
-	public void setClient(AiravataClient client) {
-		this.client = client;
-	}
-
-	@Override
-	public void setExperimentName(String experimentId, String experimentName)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateExperimentName(experimentId, experimentName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void setExperimentName(ExperimentName experimentName)
-			throws AiravataAPIInvocationException {
-		setExperimentName(experimentName.getExperimentId(),experimentName.getInstanceName());
-	}
-
-	@Override
-	public ExperimentName getExperimentName(String experimentId)
-			throws AiravataAPIInvocationException {
-		try {
-			return new ExperimentName(experimentId, getClient().getRegistryClient().getExperimentName(experimentId));
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public ExperimentData getWorkflowExperimentData(String experimentId)
-			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getExperiment(experimentId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void setWorkflowInstanceNodeStatus(String experimentId,
-			String workflowInstaceId, String nodeId, State status)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateWorkflowNodeStatus(workflowInstaceId, nodeId, status);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-		
-	}
-
-	@Override
-	public void setWorkflowInstanceNodeStatus(NodeExecutionStatus status)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().updateWorkflowNodeStatus(status);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public NodeExecutionStatus getWorkflowInstanceNodeStatus(
-			String experimentId, String workflowInstaceId, String nodeId)
-			throws AiravataAPIInvocationException {
-		return getWorkflowInstanceNodeStatus(new WorkflowInstanceNode(new WorkflowExecution(experimentId,workflowInstaceId),nodeId));
-	}
-
-	@Override
-	public NodeExecutionStatus getWorkflowInstanceNodeStatus(
-			WorkflowInstanceNode node) throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getWorkflowNodeStatus(node);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}	
-	}
-
-	@Override
-	public void addExperiment(String projectName, String experimentId, String experimentName)
-			throws AiravataAPIInvocationException {
-		try {
-			AiravataExperiment experiment = new AiravataExperiment();
-			experiment.setExperimentId(experimentId);
-			getClient().getRegistryClient().addExperiment(projectName, experiment);
-			getClient().getRegistryClient().updateExperimentName(experimentId, experimentName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}	
-	}
-
-	@Override
-	public void addWorkflowInstance(String experimentId,
-			WorkflowExecution workflowInstance)
-			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().addWorkflowInstance(experimentId, workflowInstance.getWorkflowExecutionId(),workflowInstance.getTemplateName());
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-		
-	}
-
-    @Override
-    public List<WorkflowExecution> getExperimentWorkflowInstances(String experimentId) throws AiravataAPIInvocationException {
-        try{
-            return getClient().getRegistryClient().getExperimentWorkflowInstances(experimentId);
-        }catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
-    }
-
-    @Override
-    public void setWorkflowNodeType(WorkflowInstanceNode node, WorkflowNodeType type) throws AiravataAPIInvocationException {
-        try{
-            getClient().getRegistryClient().updateWorkflowNodeType(node, type);
-        }catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
-    }
-
-    @Override
-    public void setWorkflowInstanceTemplateName(String workflowInstanceId, String templateName) throws AiravataAPIInvocationException {
-        try{
-            getClient().getRegistryClient().setWorkflowInstanceTemplateName(workflowInstanceId, templateName);
-        }catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
-    }
-
-    @Override
-    public void saveWorkflowExecutionOutput(String experimentId, String outputNodeName, String output) throws AiravataAPIInvocationException {
-        try {
-            getClient().getRegistryClient().saveWorkflowExecutionOutput(experimentId, outputNodeName, output);
-        } catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
-    }
-
-    @Override
-	public ExperimentData getExperimentMetaInformation(String experimentId)
-			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getExperimentMetaInformation(experimentId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public List<ExperimentData> getAllExperimentMetaInformation(String user)
-			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getAllExperimentMetaInformation(user);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public List<ExperimentData> getExperimentDataList()
-			throws AiravataAPIInvocationException {
-		return getWorkflowExperimentDataList();
-	}
-
-	@Override
-	public List<ExperimentData> getExperimentDataList(String user)
-			throws AiravataAPIInvocationException {
-		return getWorkflowExperimentDataList(user);
-	}
-
-	@Override
-	public List<ExperimentData> getExperimentData(String user, int pageSize,
-			int pageNo) throws AiravataAPIInvocationException {
-		return getWorkflowExperimentData(user, pageSize, pageNo);
-	}
-
-	@Override
-	public ExperimentData getExperimentData(String experimentId)
-			throws AiravataAPIInvocationException {
-		return getWorkflowExperimentData(experimentId);
-	}
-
-    public void updateWorkflowNodeGramData(WorkflowNodeGramData data) throws AiravataAPIInvocationException {
-        try {
-            client.getRegistryClient().updateWorkflowNodeGramData(data);
-        } catch (RegException e) {
-            throw new AiravataAPIInvocationException(e);
-        } catch (AiravataConfigurationException e) {
-            throw new AiravataAPIInvocationException(e);
-        }
-    }
-
-	@Override
-	public boolean isApplicationJobExists(String gfacJobId)
-			throws AiravataAPIInvocationException {
-		try {
-			return client.getRegistryClient().isApplicationJobExists(gfacJobId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-	
-	@Override
-	public void addApplicationJob(ApplicationJob job) throws AiravataAPIInvocationException {
-		try {
-			client.getRegistryClient().addApplicationJob(job);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void updateApplicationJob(ApplicationJob job)
-			throws AiravataAPIInvocationException {
-		try {
-			client.getRegistryClient().updateApplicationJob(job);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void updateApplicationJobStatus(String jobId, ApplicationJobStatus status, Date statusUpdateTime)
-			throws AiravataAPIInvocationException {
-		try {
-			client.getRegistryClient().updateApplicationJobStatus(jobId, status, statusUpdateTime);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void updateApplicationJobData(String jobId, String jobdata)
-			throws AiravataAPIInvocationException {
-		try {
-			client.getRegistryClient().updateApplicationJobData(jobId, jobdata);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void updateApplicationJobSubmittedTime(String jobId, Date submitted)
-			throws AiravataAPIInvocationException {
-		try {
-			client.getRegistryClient().updateApplicationJobSubmittedTime(jobId, submitted);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void updateApplicationJobStatusUpdateTime(String jobId, Date completed)
-			throws AiravataAPIInvocationException {
-		try {
-			client.getRegistryClient().updateApplicationJobStatusUpdateTime(jobId, completed);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void updateApplicationJobMetadata(String jobId, String metadata)
-			throws AiravataAPIInvocationException {
-		try {
-			client.getRegistryClient().updateApplicationJobMetadata(jobId, metadata);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public ApplicationJob getApplicationJob(String jobId)
-			throws AiravataAPIInvocationException {
-		try {
-			return client.getRegistryClient().getApplicationJob(jobId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public List<ApplicationJob> getApplicationJobsForDescriptors(String serviceDescriptionId,
-			String hostDescriptionId, String applicationDescriptionId)
-			throws AiravataAPIInvocationException {
-		try {
-			return client.getRegistryClient().getApplicationJobsForDescriptors(serviceDescriptionId, hostDescriptionId, applicationDescriptionId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public List<ApplicationJob> getApplicationJobs(String experimentId,
-			String workflowExecutionId, String nodeId)
-			throws AiravataAPIInvocationException {
-		try {
-			return client.getRegistryClient().getApplicationJobs(experimentId, workflowExecutionId, nodeId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-	@Override
-	public void updateApplicationJobStatus(String jobId,
-			ApplicationJobStatus status) throws AiravataAPIInvocationException {
-		updateApplicationJobStatus(jobId, status, Calendar.getInstance().getTime());
-	}
-
-	@Override
-	public List<ApplicationJobStatusData> getApplicationJobStatusHistory(
-			String jobId) throws AiravataAPIInvocationException {
-		try {
-			return client.getRegistryClient().getApplicationJobStatusHistory(jobId);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
-	}
-
-}
+///*
+// *
+// * 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.client.impl;
+//
+//import org.apache.airavata.client.AiravataClient;
+//import org.apache.airavata.client.api.ProvenanceManager;
+//import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
+//import org.apache.airavata.registry.api.workflow.*;
+//import org.apache.airavata.registry.api.workflow.ApplicationJob.ApplicationJobStatus;
+//import org.apache.airavata.registry.api.workflow.WorkflowExecutionStatus.State;
+//
+//import java.util.*;
+//
+//public class ProvenanceManagerImpl implements ProvenanceManager {
+//	private AiravataClient client;
+//
+//	public ProvenanceManagerImpl(AiravataClient client) {
+//		setClient(client);
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceNodeInput(WorkflowInstanceNode node, String data)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateWorkflowNodeInput(node, data);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceNodeInput(String experimentId,
+//			String workflowInstanceId, String nodeId, String data)
+//			throws AiravataAPIInvocationException {
+//		setWorkflowInstanceNodeInput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId), data);
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceNodeOutput(WorkflowInstanceNode node, String data)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateWorkflowNodeOutput(node, data);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceNodeOutput(String experimentId,
+//			String workflowInstanceId, String nodeId, String data)
+//			throws AiravataAPIInvocationException {
+//		setWorkflowInstanceNodeOutput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId), data);
+//
+//	}
+//
+//	@Override
+//	public String getWorkflowInstanceNodeInput(WorkflowInstanceNode node) throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getWorkflowInstanceNodeData(node.getWorkflowInstance().getWorkflowExecutionId(), node.getNodeId()).getInput();
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public String getWorkflowInstanceNodeInput(String experimentId, String workflowInstanceId, String nodeId)
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowInstanceNodeInput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId));
+//	}
+//
+//	@Override
+//	public Map<WorkflowInstanceNode,String> getWorkflowInstanceNodeInput(String workflowName, String nodeId) throws AiravataAPIInvocationException{
+////		try {
+////			List<WorkflowNodeIOData> list = getClient().getRegistryClient().searchWorkflowInstanceNodeInput(".*", workflowName, nodeId);
+////			return groupNodePortData(list);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	private Map<WorkflowInstanceNode, String> groupNodePortData(List<WorkflowNodeIOData> list) {
+//		Map<WorkflowInstanceNode,String> portData=new HashMap<WorkflowInstanceNode, String>();
+//		for (WorkflowNodeIOData data : list) {
+//			portData.put(new WorkflowInstanceNode(new WorkflowExecution(data.getExperimentId(), data.getWorkflowInstanceId()), data.getNodeId()), data.getValue());
+//		}
+//		return portData;
+//	}
+//
+//	@Override
+//	public String getWorkflowInstanceNodeOutput(WorkflowInstanceNode node) throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getWorkflowInstanceNodeData(node.getWorkflowInstance().getWorkflowExecutionId(), node.getNodeId()).getOutput();
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public String getWorkflowInstanceNodeOutput(String experimentId, String workflowInstanceId, String nodeId)
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowInstanceNodeOutput(new WorkflowInstanceNode(new WorkflowExecution(experimentId, workflowInstanceId), nodeId));
+//
+//	}
+//
+//	@Override
+//	public Map<WorkflowInstanceNode,String> getWorkflowInstanceNodeOutput(String workflowName, String nodeId) throws AiravataAPIInvocationException{
+////		try {
+////			List<WorkflowNodeIOData> list = getClient().getRegistryClient().searchWorkflowInstanceNodeOutput(".*", workflowName, nodeId);
+////			return groupNodePortData(list);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceStatus(String experimentId, String workflowInstanceId,
+//			State status) throws AiravataAPIInvocationException {
+//		setWorkflowInstanceStatus(new WorkflowExecutionStatus(new WorkflowExecution(experimentId, workflowInstanceId),status));
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceStatus(WorkflowExecutionStatus status)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateWorkflowInstanceStatus(status);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//
+//	}
+//
+//	@Override
+//	public WorkflowExecutionStatus getWorkflowInstanceStatus(
+//			String experimentId, String workflowInstanceId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getWorkflowInstanceStatus(experimentId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public WorkflowExecutionStatus getWorkflowInstanceStatus(
+//			WorkflowExecution workflowInstance)
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowInstanceStatus(workflowInstance.getExperimentId(), workflowInstance.getWorkflowExecutionId());
+//	}
+//
+//	@Override
+//	public void setExperimentUser(String experimentId, String user) throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateExperimentExecutionUser(experimentId, user);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void setExperimentUser(ExperimentUser user)
+//			throws AiravataAPIInvocationException {
+//		setExperimentUser(user.getExperimentId(), user.getUser());
+//	}
+//
+//	@Override
+//	public ExperimentUser getExperimentUser(String experimentId)throws AiravataAPIInvocationException {
+////		try {
+////			return new ExperimentUser(experimentId,getClient().getRegistryClient().getExperimentExecutionUser(experimentId));
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public void setExperimentMetadata(String experimentId, String metadata)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateExperimentMetadata(experimentId, metadata);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//
+//	}
+//
+//	@Override
+//	public void setExperimentMetadata(ExperimentMetadata instanceMetadata)
+//			throws AiravataAPIInvocationException {
+//		setExperimentMetadata(instanceMetadata.getExperimentId(), instanceMetadata.getMetadata());
+//	}
+//
+//	@Override
+//	public ExperimentMetadata getExperimentMetadata(String experimentId)throws AiravataAPIInvocationException {
+////		try {
+////			return new ExperimentMetadata(experimentId, getClient().getRegistryClient().getExperimentMetadata(experimentId));
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//    @Override
+//    public boolean isExperimentNameExist(String experimentName) throws AiravataAPIInvocationException {
+////        try {
+////            return getClient().getRegistryClient().isExperimentNameExist(experimentName);
+////        } catch (Exception e) {
+////            throw new AiravataAPIInvocationException(e);
+////        }
+//        return false;
+//    }
+//
+//    @Override
+//	public List<String> getExperimentIdList(String owner) throws AiravataAPIInvocationException{
+////		try {
+////			return getClient().getRegistryClient().getExperimentIdByUser(owner);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public List<String> getExperimentIdList() throws AiravataAPIInvocationException {
+//		return getExperimentIdList(getClient().getCurrentUser());
+//	}
+//
+//	@Override
+//	public List<ExperimentData> getWorkflowExperimentDataList()
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowExperimentDataList(getClient().getCurrentUser());
+//	}
+//
+//	@Override
+//	public List<ExperimentData> getWorkflowExperimentDataList(String user)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return  getClient().getRegistryClient().getExperimentByUser(user);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public List<ExperimentData> getWorkflowExperimentData(String user,
+//			int pageSize, int pageNo) throws AiravataAPIInvocationException {
+////		try {
+////			return  getClient().getRegistryClient().getExperimentByUser(user, pageSize, pageNo);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public WorkflowExecutionData getWorkflowInstanceData(String experimentId,
+//			String workflowInstanceId) throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getWorkflowInstanceData(workflowInstanceId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public WorkflowExecutionData getWorkflowInstanceData(WorkflowExecution workflowInstance)
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowInstanceData(workflowInstance.getExperimentId(), workflowInstance.getWorkflowExecutionId());
+//	}
+//
+//	@Override
+//	public String[] getWorkflowExecutionOutputNames(String exeperimentId)
+//			throws AiravataAPIInvocationException {
+//		throw new AiravataAPIInvocationException(new Exception("Not implemented"));
+//	}
+//
+//	public AiravataClient getClient() {
+//		return client;
+//	}
+//
+//	public void setClient(AiravataClient client) {
+//		this.client = client;
+//	}
+//
+//	@Override
+//	public void setExperimentName(String experimentId, String experimentName)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateExperimentName(experimentId, experimentName);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void setExperimentName(ExperimentName experimentName)
+//			throws AiravataAPIInvocationException {
+//		setExperimentName(experimentName.getExperimentId(),experimentName.getInstanceName());
+//	}
+//
+//	@Override
+//	public ExperimentName getExperimentName(String experimentId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return new ExperimentName(experimentId, getClient().getRegistryClient().getExperimentName(experimentId));
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public ExperimentData getWorkflowExperimentData(String experimentId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getExperiment(experimentId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceNodeStatus(String experimentId,
+//			String workflowInstaceId, String nodeId, State status)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateWorkflowNodeStatus(workflowInstaceId, nodeId, status);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//
+//	}
+//
+//	@Override
+//	public void setWorkflowInstanceNodeStatus(NodeExecutionStatus status)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().updateWorkflowNodeStatus(status);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public NodeExecutionStatus getWorkflowInstanceNodeStatus(
+//			String experimentId, String workflowInstaceId, String nodeId)
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowInstanceNodeStatus(new WorkflowInstanceNode(new WorkflowExecution(experimentId,workflowInstaceId),nodeId));
+//	}
+//
+//	@Override
+//	public NodeExecutionStatus getWorkflowInstanceNodeStatus(
+//			WorkflowInstanceNode node) throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getWorkflowNodeStatus(node);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public void addExperiment(String projectName, String experimentId, String experimentName)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			AiravataExperiment experiment = new AiravataExperiment();
+////			experiment.setExperimentId(experimentId);
+////			getClient().getRegistryClient().addExperiment(projectName, experiment);
+////			getClient().getRegistryClient().updateExperimentName(experimentId, experimentName);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void addWorkflowInstance(String experimentId,
+//			WorkflowExecution workflowInstance)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			getClient().getRegistryClient().addWorkflowInstance(experimentId, workflowInstance.getWorkflowExecutionId(),workflowInstance.getTemplateName());
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//
+//	}
+//
+//    @Override
+//    public List<WorkflowExecution> getExperimentWorkflowInstances(String experimentId) throws AiravataAPIInvocationException {
+////        try{
+////            return getClient().getRegistryClient().getExperimentWorkflowInstances(experimentId);
+////        }catch (Exception e) {
+////            throw new AiravataAPIInvocationException(e);
+////        }
+//        return null;
+//    }
+//
+//    @Override
+//    public void setWorkflowNodeType(WorkflowInstanceNode node, WorkflowNodeType type) throws AiravataAPIInvocationException {
+////        try{
+////            getClient().getRegistryClient().updateWorkflowNodeType(node, type);
+////        }catch (Exception e) {
+////            throw new AiravataAPIInvocationException(e);
+////        }
+//    }
+//
+//    @Override
+//    public void setWorkflowInstanceTemplateName(String workflowInstanceId, String templateName) throws AiravataAPIInvocationException {
+////        try{
+////            getClient().getRegistryClient().setWorkflowInstanceTemplateName(workflowInstanceId, templateName);
+////        }catch (Exception e) {
+////            throw new AiravataAPIInvocationException(e);
+////        }
+//    }
+//
+//    @Override
+//    public void saveWorkflowExecutionOutput(String experimentId, String outputNodeName, String output) throws AiravataAPIInvocationException {
+////        try {
+////            getClient().getRegistryClient().saveWorkflowExecutionOutput(experimentId, outputNodeName, output);
+////        } catch (Exception e) {
+////            throw new AiravataAPIInvocationException(e);
+////        }
+//    }
+//
+//    @Override
+//	public ExperimentData getExperimentMetaInformation(String experimentId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getExperimentMetaInformation(experimentId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public List<ExperimentData> getAllExperimentMetaInformation(String user)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return getClient().getRegistryClient().getAllExperimentMetaInformation(user);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public List<ExperimentData> getExperimentDataList()
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowExperimentDataList();
+//	}
+//
+//	@Override
+//	public List<ExperimentData> getExperimentDataList(String user)
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowExperimentDataList(user);
+//	}
+//
+//	@Override
+//	public List<ExperimentData> getExperimentData(String user, int pageSize,
+//			int pageNo) throws AiravataAPIInvocationException {
+//		return getWorkflowExperimentData(user, pageSize, pageNo);
+//	}
+//
+//	@Override
+//	public ExperimentData getExperimentData(String experimentId)
+//			throws AiravataAPIInvocationException {
+//		return getWorkflowExperimentData(experimentId);
+//	}
+//
+//    public void updateWorkflowNodeGramData(WorkflowNodeGramData data) throws AiravataAPIInvocationException {
+////        try {
+////            client.getRegistryClient().updateWorkflowNodeGramData(data);
+////        } catch (RegException e) {
+////            throw new AiravataAPIInvocationException(e);
+////        } catch (AiravataConfigurationException e) {
+////            throw new AiravataAPIInvocationException(e);
+////        }
+//    }
+//
+//	@Override
+//	public boolean isApplicationJobExists(String gfacJobId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return client.getRegistryClient().isApplicationJobExists(gfacJobId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return false;
+//	}
+//
+//	@Override
+//	public void addApplicationJob(ApplicationJob job) throws AiravataAPIInvocationException {
+////		try {
+////			client.getRegistryClient().addApplicationJob(job);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void updateApplicationJob(ApplicationJob job)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			client.getRegistryClient().updateApplicationJob(job);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void updateApplicationJobStatus(String jobId, ApplicationJobStatus status, Date statusUpdateTime)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			client.getRegistryClient().updateApplicationJobStatus(jobId, status, statusUpdateTime);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void updateApplicationJobData(String jobId, String jobdata)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			client.getRegistryClient().updateApplicationJobData(jobId, jobdata);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void updateApplicationJobSubmittedTime(String jobId, Date submitted)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			client.getRegistryClient().updateApplicationJobSubmittedTime(jobId, submitted);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void updateApplicationJobStatusUpdateTime(String jobId, Date completed)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			client.getRegistryClient().updateApplicationJobStatusUpdateTime(jobId, completed);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public void updateApplicationJobMetadata(String jobId, String metadata)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			client.getRegistryClient().updateApplicationJobMetadata(jobId, metadata);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//	}
+//
+//	@Override
+//	public ApplicationJob getApplicationJob(String jobId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return client.getRegistryClient().getApplicationJob(jobId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public List<ApplicationJob> getApplicationJobsForDescriptors(String serviceDescriptionId,
+//			String hostDescriptionId, String applicationDescriptionId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return client.getRegistryClient().getApplicationJobsForDescriptors(serviceDescriptionId, hostDescriptionId, applicationDescriptionId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public List<ApplicationJob> getApplicationJobs(String experimentId,
+//			String workflowExecutionId, String nodeId)
+//			throws AiravataAPIInvocationException {
+////		try {
+////			return client.getRegistryClient().getApplicationJobs(experimentId, workflowExecutionId, nodeId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//	@Override
+//	public void updateApplicationJobStatus(String jobId,
+//			ApplicationJobStatus status) throws AiravataAPIInvocationException {
+//		updateApplicationJobStatus(jobId, status, Calendar.getInstance().getTime());
+//	}
+//
+//	@Override
+//	public List<ApplicationJobStatusData> getApplicationJobStatusHistory(
+//			String jobId) throws AiravataAPIInvocationException {
+////		try {
+////			return client.getRegistryClient().getApplicationJobStatusHistory(jobId);
+////		} catch (Exception e) {
+////			throw new AiravataAPIInvocationException(e);
+////		}
+//        return null;
+//	}
+//
+//}

http://git-wip-us.apache.org/repos/asf/airavata/blob/98f41101/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/WorkflowManagerImpl.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/WorkflowManagerImpl.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/WorkflowManagerImpl.java
index 484fd57..4596e42 100644
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/WorkflowManagerImpl.java
+++ b/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/WorkflowManagerImpl.java
@@ -21,24 +21,19 @@
 
 package org.apache.airavata.client.impl;
 
-import java.net.URI;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
 import org.apache.airavata.client.AiravataClient;
 import org.apache.airavata.client.api.WorkflowManager;
 import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
 import org.apache.airavata.client.api.exception.WorkflowAlreadyExistsException;
-import org.apache.airavata.common.exception.AiravataConfigurationException;
 import org.apache.airavata.common.utils.XMLUtil;
-import org.apache.airavata.registry.api.exception.RegException;
-import org.apache.airavata.registry.api.exception.worker.UserWorkflowAlreadyExistsException;
 import org.apache.airavata.workflow.model.wf.Workflow;
 import org.apache.airavata.workflow.model.wf.WorkflowData;
 import org.apache.airavata.workflow.model.wf.WorkflowInput;
 
+import java.net.URI;
+import java.util.List;
+import java.util.Map;
+
 public class WorkflowManagerImpl implements WorkflowManager {
 	private AiravataClient client;
 
@@ -105,107 +100,110 @@ public class WorkflowManagerImpl implements WorkflowManager {
 
     private void addWorkflow(Workflow workflow, String workflowAsString, String owner)
             throws WorkflowAlreadyExistsException, AiravataAPIInvocationException {
-        try {
-            getClient().getRegistryClient().addWorkflow(workflow.getName(), workflowAsString);
-        } catch (UserWorkflowAlreadyExistsException e) {
-            throw new WorkflowAlreadyExistsException("Workflow " +
-                    workflow.getName()
-                    + " already exists in the system.", e);
-        } catch (RegException e) {
-            throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
-                    workflow.getName(), e);
-        } catch (AiravataConfigurationException e) {
-            throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
-                    workflow.getName(), e);
-        }
-
-        if (owner == null) {
-            try {
-                getClient().getRegistryClient().publishWorkflow(workflow.getName());
-            } catch (RegException e) {
-                throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
-                        workflow.getName(), e);
-            } catch (AiravataConfigurationException e) {
-                throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
-                        workflow.getName(), e);
-            }
-        }
+//        try {
+//            getClient().getRegistryClient().addWorkflow(workflow.getName(), workflowAsString);
+//        } catch (UserWorkflowAlreadyExistsException e) {
+//            throw new WorkflowAlreadyExistsException("Workflow " +
+//                    workflow.getName()
+//                    + " already exists in the system.", e);
+//        } catch (RegException e) {
+//            throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
+//                    workflow.getName(), e);
+//        } catch (AiravataConfigurationException e) {
+//            throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
+//                    workflow.getName(), e);
+//        }
+
+//        if (owner == null) {
+//            try {
+//                getClient().getRegistryClient().publishWorkflow(workflow.getName());
+//            } catch (RegException e) {
+//                throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
+//                        workflow.getName(), e);
+//            } catch (AiravataConfigurationException e) {
+//                throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
+//                        workflow.getName(), e);
+//            }
+//        }
     }
 
     private void updateWorkflow(Workflow workflow, String workflowAsString, String owner)
             throws AiravataAPIInvocationException {
-        try {
-            getClient().getRegistryClient().updateWorkflow(workflow.getName(), workflowAsString);
-        } catch (RegException e) {
-            throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
-                    workflow.getName(), e);
-        } catch (AiravataConfigurationException e) {
-            throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
-                    workflow.getName(), e);
-        }
-
-        if (owner == null) {
-            try {
-                getClient().getRegistryClient().publishWorkflow(workflow.getName());
-            } catch (RegException e) {
-                throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
-                        workflow.getName(), e);
-            } catch (AiravataConfigurationException e) {
-                throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
-                        workflow.getName(), e);
-            }
-        }
+//        try {
+//            getClient().getRegistryClient().updateWorkflow(workflow.getName(), workflowAsString);
+//        } catch (RegException e) {
+//            throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
+//                    workflow.getName(), e);
+//        } catch (AiravataConfigurationException e) {
+//            throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
+//                    workflow.getName(), e);
+//        }
+//
+//        if (owner == null) {
+//            try {
+//                getClient().getRegistryClient().publishWorkflow(workflow.getName());
+//            } catch (RegException e) {
+//                throw new AiravataAPIInvocationException("An internal error occurred while adding workflow " +
+//                        workflow.getName(), e);
+//            } catch (AiravataConfigurationException e) {
+//                throw new AiravataAPIInvocationException("Error retrieving registry client for workflow " +
+//                        workflow.getName(), e);
+//            }
+//        }
     }
 
     // Remove once deprecated methods are removed from the API
     @Deprecated
 	private boolean saveWorkflow(Workflow workflow, String workflowAsString,String owner)
 			throws AiravataAPIInvocationException {
-		try {
-			
-			if (getClient().getRegistryClient().isWorkflowExists(workflow.getName())) {
-				getClient().getRegistryClient().updateWorkflow(workflow.getName(),workflowAsString);
-			}else{
-				getClient().getRegistryClient().addWorkflow(workflow.getName(),workflowAsString);
-			}
-			if (owner==null){
-				getClient().getRegistryClient().publishWorkflow(workflow.getName());
-			}
-			return true;
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//
+//			if (getClient().getRegistryClient().isWorkflowExists(workflow.getName())) {
+//				getClient().getRegistryClient().updateWorkflow(workflow.getName(),workflowAsString);
+//			}else{
+//				getClient().getRegistryClient().addWorkflow(workflow.getName(),workflowAsString);
+//			}
+//			if (owner==null){
+//				getClient().getRegistryClient().publishWorkflow(workflow.getName());
+//			}
+//			return true;
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return false;
 	}
 
 	@Override
 	public List<Workflow> getWorkflows(String owner)
 			throws AiravataAPIInvocationException {
-		try {
-			List<Workflow> workflows=new ArrayList<Workflow>();
-			Map<String, String> workflowMap = getClient().getRegistryClient().getWorkflows();
-			for(String workflowStr:workflowMap.values()){
-				workflows.add(getWorkflowFromString(workflowStr));
-			}
-			return workflows;
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			List<Workflow> workflows=new ArrayList<Workflow>();
+//			Map<String, String> workflowMap = getClient().getRegistryClient().getWorkflows();
+//			for(String workflowStr:workflowMap.values()){
+//				workflows.add(getWorkflowFromString(workflowStr));
+//			}
+//			return workflows;
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 
 	@Override
 	public List<String> getWorkflowTemplateIds(String owner)
 			throws AiravataAPIInvocationException {
-		try {
-			List<String> workflowList = new ArrayList<String>();
-			Map<String, String> workflows;
-			workflows = getClient().getRegistryClient().getWorkflows();
-			for (String name : workflows.keySet()) {
-				workflowList.add(name);
-			}
-			return workflowList;
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			List<String> workflowList = new ArrayList<String>();
+//			Map<String, String> workflows;
+//			workflows = getClient().getRegistryClient().getWorkflows();
+//			for (String name : workflows.keySet()) {
+//				workflowList.add(name);
+//			}
+//			return workflowList;
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 
 	@Override
@@ -217,22 +215,24 @@ public class WorkflowManagerImpl implements WorkflowManager {
 	@Override
 	public String getWorkflowAsString(String workflowName, String owner)
 			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getWorkflowGraphXML(workflowName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			return getClient().getRegistryClient().getWorkflowGraphXML(workflowName);
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 
 	@Override
 	public boolean deleteWorkflow(String workflowName, String owner)
 			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().removeWorkflow(workflowName);
-			return true;
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			getClient().getRegistryClient().removeWorkflow(workflowName);
+//			return true;
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return false;
 	}
 
 	@Override
@@ -380,41 +380,43 @@ public class WorkflowManagerImpl implements WorkflowManager {
 	@Override
 	public boolean isPublishedWorkflowExists(String workflowName)
 			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().isPublishedWorkflowExists(workflowName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			return getClient().getRegistryClient().isPublishedWorkflowExists(workflowName);
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return false;
 	}
 
 	@Override
 	public void publishWorkflow(String workflowName, String publishWorkflowName)
 			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().publishWorkflow(workflowName, publishWorkflowName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			getClient().getRegistryClient().publishWorkflow(workflowName, publishWorkflowName);
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
 	}
 
 	@Override
 	public void publishWorkflow(String workflowName)
 			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().publishWorkflow(workflowName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			getClient().getRegistryClient().publishWorkflow(workflowName);
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
 	}
 
 	@Override
 	public String getPublishedWorkflowGraphXML(String workflowName)
 			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getPublishedWorkflowGraphXML(workflowName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			return getClient().getRegistryClient().getPublishedWorkflowGraphXML(workflowName);
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 	
 	@Override
@@ -426,36 +428,38 @@ public class WorkflowManagerImpl implements WorkflowManager {
 	@Override
 	public List<String> getPublishedWorkflowNames()
 			throws AiravataAPIInvocationException {
-		try {
-			return getClient().getRegistryClient().getPublishedWorkflowNames();
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			return getClient().getRegistryClient().getPublishedWorkflowNames();
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 
 	@Override
 	public Map<String, Workflow> getPublishedWorkflows()
 			throws AiravataAPIInvocationException {
-		try {
-			Map<String, Workflow> workflows=new HashMap<String, Workflow>();
-			Map<String, String> publishedWorkflows = getClient().getRegistryClient().getPublishedWorkflows();
-			for (String name : publishedWorkflows.keySet()) {
-				workflows.put(name, getWorkflowFromString(publishedWorkflows.get(name)));
-			}
-			return workflows;
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			Map<String, Workflow> workflows=new HashMap<String, Workflow>();
+//			Map<String, String> publishedWorkflows = getClient().getRegistryClient().getPublishedWorkflows();
+//			for (String name : publishedWorkflows.keySet()) {
+//				workflows.put(name, getWorkflowFromString(publishedWorkflows.get(name)));
+//			}
+//			return workflows;
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 
 	@Override
 	public void removePublishedWorkflow(String workflowName)
 			throws AiravataAPIInvocationException {
-		try {
-			getClient().getRegistryClient().removePublishedWorkflow(workflowName);
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			getClient().getRegistryClient().removePublishedWorkflow(workflowName);
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
 	}
 
 	@Override
@@ -469,60 +473,63 @@ public class WorkflowManagerImpl implements WorkflowManager {
 
 	@Override
 	public List<WorkflowInput> getWorkflowInputs(WorkflowData workflowData) throws AiravataAPIInvocationException {
-		try {
-			if (workflowData.isPublished()){
-				return getWorkflowFromString(getClient().getRegistryClient().getPublishedWorkflowGraphXML(workflowData.getName())).getWorkflowInputs();
-			}else{
-				return getWorkflowInputs(workflowData.getName());
-			}
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		try {
+//			if (workflowData.isPublished()){
+//				return getWorkflowFromString(getClient().getRegistryClient().getPublishedWorkflowGraphXML(workflowData.getName())).getWorkflowInputs();
+//			}else{
+//				return getWorkflowInputs(workflowData.getName());
+//			}
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 
 	@Override
 	public List<WorkflowData> getAllWorkflows() throws AiravataAPIInvocationException {
-		List<WorkflowData> list = new ArrayList<WorkflowData>();
-		List<String> workflowTemplateIds = getWorkflowTemplateIds();
-		try {
-			for (String id : workflowTemplateIds) {
-				list.add(new WorkflowData(id,null,false));
-			}
-			List<String> publishedWorkflowNames = getClient().getRegistryClient().getPublishedWorkflowNames();
-			for (String id : publishedWorkflowNames) {
-				list.add(new WorkflowData(id,null,false));
-			}
-			return list;
-		} catch (Exception e) {
-			throw new AiravataAPIInvocationException(e);
-		}
+//		List<WorkflowData> list = new ArrayList<WorkflowData>();
+//		List<String> workflowTemplateIds = getWorkflowTemplateIds();
+//		try {
+//			for (String id : workflowTemplateIds) {
+//				list.add(new WorkflowData(id,null,false));
+//			}
+//			List<String> publishedWorkflowNames = getClient().getRegistryClient().getPublishedWorkflowNames();
+//			for (String id : publishedWorkflowNames) {
+//				list.add(new WorkflowData(id,null,false));
+//			}
+//			return list;
+//		} catch (Exception e) {
+//			throw new AiravataAPIInvocationException(e);
+//		}
+        return null;
 	}
 
     @Override
     public boolean isWorkflowExists(String workflowName) throws AiravataAPIInvocationException {
-        try {
-            return getClient().getRegistryClient().isWorkflowExists(workflowName);
-        } catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
+//        try {
+//            return getClient().getRegistryClient().isWorkflowExists(workflowName);
+//        } catch (Exception e) {
+//            throw new AiravataAPIInvocationException(e);
+//        }
+        return false;
     }
 
     @Override
     public void updateWorkflow(String workflowName, String workflowGraphXml) throws AiravataAPIInvocationException {
-        try {
-            getClient().getRegistryClient().updateWorkflow(workflowName, workflowGraphXml);
-        } catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
+//        try {
+//            getClient().getRegistryClient().updateWorkflow(workflowName, workflowGraphXml);
+//        } catch (Exception e) {
+//            throw new AiravataAPIInvocationException(e);
+//        }
     }
 
     @Override
     public void removeWorkflow(String workflowName) throws AiravataAPIInvocationException {
-        try {
-            getClient().getRegistryClient().removeWorkflow(workflowName);
-        } catch (Exception e) {
-            throw new AiravataAPIInvocationException(e);
-        }
+//        try {
+//            getClient().getRegistryClient().removeWorkflow(workflowName);
+//        } catch (Exception e) {
+//            throw new AiravataAPIInvocationException(e);
+//        }
     }
 
 }

http://git-wip-us.apache.org/repos/asf/airavata/blob/98f41101/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
----------------------------------------------------------------------
diff --git a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java b/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
index e60ba8a..6a1a4ed 100644
--- a/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
+++ b/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
@@ -22,7 +22,6 @@
 package org.apache.airavata.client.tools;
 
 import org.apache.airavata.client.api.AiravataAPI;
-import org.apache.airavata.registry.api.AiravataRegistry2;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

http://git-wip-us.apache.org/repos/asf/airavata/blob/98f41101/modules/integration-tests/src/test/java/org/apache/airavata/integration/ForEachCaseIT.java
----------------------------------------------------------------------
diff --git a/modules/integration-tests/src/test/java/org/apache/airavata/integration/ForEachCaseIT.java b/modules/integration-tests/src/test/java/org/apache/airavata/integration/ForEachCaseIT.java
index f909b35..6a76dbb 100644
--- a/modules/integration-tests/src/test/java/org/apache/airavata/integration/ForEachCaseIT.java
+++ b/modules/integration-tests/src/test/java/org/apache/airavata/integration/ForEachCaseIT.java
@@ -21,23 +21,11 @@
 
 package org.apache.airavata.integration;
 
-import junit.framework.Assert;
-import org.apache.airavata.client.api.builder.DescriptorBuilder;
 import org.apache.airavata.client.api.exception.AiravataAPIInvocationException;
 import org.apache.airavata.client.api.exception.DescriptorAlreadyExistsException;
-import org.apache.airavata.commons.gfac.type.ApplicationDescription;
-import org.apache.airavata.commons.gfac.type.HostDescription;
-import org.apache.airavata.commons.gfac.type.ServiceDescription;
-import org.apache.airavata.schemas.gfac.DataType;
-import org.apache.airavata.schemas.gfac.HostDescriptionType;
-import org.apache.airavata.schemas.gfac.InputParameterType;
-import org.apache.airavata.schemas.gfac.OutputParameterType;
 import org.testng.annotations.BeforeTest;
 
-import java.io.File;
 import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
 
 /**
  * Integration test class.

http://git-wip-us.apache.org/repos/asf/airavata/blob/98f41101/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowIntegrationTestBase.java
----------------------------------------------------------------------
diff --git a/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowIntegrationTestBase.java b/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowIntegrationTestBase.java
index dd4d2b6..f0e4242 100644
--- a/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowIntegrationTestBase.java
+++ b/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowIntegrationTestBase.java
@@ -21,36 +21,11 @@
 
 package org.apache.airavata.integration;
 
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
-import java.util.List;
-
-import junit.framework.Assert;
-
 import org.apache.airavata.api.Airavata;
 import org.apache.airavata.api.client.AiravataClientFactory;
-import org.apache.airavata.model.error.AiravataClientConnectException;
-import org.apache.airavata.model.error.AiravataClientException;
-import org.apache.airavata.model.error.AiravataSystemException;
-import org.apache.airavata.model.error.ExperimentNotFoundException;
-import org.apache.airavata.model.error.InvalidRequestException;
 import org.apache.airavata.common.utils.ServerSettings;
-import org.apache.airavata.common.utils.StringUtil;
-import org.apache.airavata.commons.gfac.type.ApplicationDescription;
-import org.apache.airavata.commons.gfac.type.HostDescription;
-import org.apache.airavata.commons.gfac.type.ServiceDescription;
+import org.apache.airavata.model.error.*;
 import org.apache.airavata.model.workspace.experiment.Experiment;
-import org.apache.airavata.registry.api.workflow.ExperimentData;
-import org.apache.airavata.registry.api.workflow.InputData;
-import org.apache.airavata.registry.api.workflow.NodeExecutionData;
-import org.apache.airavata.registry.api.workflow.OutputData;
-import org.apache.airavata.registry.api.workflow.WorkflowNodeType;
-import org.apache.airavata.workflow.model.component.ComponentException;
-import org.apache.airavata.workflow.model.graph.GraphException;
-import org.apache.airavata.workflow.model.wf.Workflow;
-import org.apache.airavata.workflow.model.wf.WorkflowInput;
 import org.apache.thrift.TException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

http://git-wip-us.apache.org/repos/asf/airavata/blob/98f41101/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowSamplesCaseIT.java
----------------------------------------------------------------------
diff --git a/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowSamplesCaseIT.java b/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowSamplesCaseIT.java
index 98f3fb3..110ca3c 100644
--- a/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowSamplesCaseIT.java
+++ b/modules/integration-tests/src/test/java/org/apache/airavata/integration/WorkflowSamplesCaseIT.java
@@ -21,18 +21,8 @@
 
 package org.apache.airavata.integration;
 
-import junit.framework.Assert;
-import org.apache.airavata.common.utils.StringUtil;
-import org.apache.airavata.workflow.model.component.ComponentException;
-import org.apache.airavata.workflow.model.graph.GraphException;
-import org.apache.airavata.workflow.model.wf.Workflow;
-import org.apache.airavata.workflow.model.wf.WorkflowInput;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.testng.annotations.BeforeTest;
-
-import java.io.IOException;
-import java.util.List;
 
 /**
  * Integration test class.


Mime
View raw message