Adding python generated code - AIRAVATA-1642
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/97c7a736 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/97c7a736 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/97c7a736 Branch: refs/heads/master Commit: 97c7a736236bd8275e2ea5c1fc9877ece2e4a550 Parents: c090519 Author: Suresh Marru <[email protected]> Authored: Tue Mar 24 05:19:03 2015 -0400 Committer: Suresh Marru <[email protected]> Committed: Tue Mar 24 05:19:03 2015 -0400 ---------------------------------------------------------------------- .../airavata-python-sdk/pom.xml | 114 + .../src/main/resources/lib/__init__.py | 0 .../src/main/resources/lib/apache/__init__.py | 0 .../resources/lib/apache/airavata/__init__.py | 0 .../lib/apache/airavata/api/Airavata-remote | 893 + .../lib/apache/airavata/api/Airavata.py | 29153 +++++++++++++++++ .../lib/apache/airavata/api/__init__.py | 1 + .../lib/apache/airavata/api/constants.py | 12 + .../lib/apache/airavata/api/error/__init__.py | 1 + .../lib/apache/airavata/api/error/constants.py | 11 + .../lib/apache/airavata/api/error/ttypes.py | 881 + .../resources/lib/apache/airavata/api/ttypes.py | 28 + .../lib/apache/airavata/model/__init__.py | 1 + .../airavata/model/appcatalog/__init__.py | 0 .../model/appcatalog/appdeployment/__init__.py | 1 + .../model/appcatalog/appdeployment/constants.py | 12 + .../model/appcatalog/appdeployment/ttypes.py | 530 + .../model/appcatalog/appinterface/__init__.py | 1 + .../model/appcatalog/appinterface/constants.py | 12 + .../model/appcatalog/appinterface/ttypes.py | 600 + .../appcatalog/computeresource/__init__.py | 1 + .../appcatalog/computeresource/constants.py | 12 + .../model/appcatalog/computeresource/ttypes.py | 1967 ++ .../model/appcatalog/gatewayprofile/__init__.py | 1 + .../appcatalog/gatewayprofile/constants.py | 11 + .../model/appcatalog/gatewayprofile/ttypes.py | 290 + .../lib/apache/airavata/model/constants.py | 11 + .../apache/airavata/model/messaging/__init__.py | 0 .../airavata/model/messaging/event/__init__.py | 1 + .../airavata/model/messaging/event/constants.py | 12 + .../airavata/model/messaging/event/ttypes.py | 1234 + .../lib/apache/airavata/model/ttypes.py | 22 + .../apache/airavata/model/workflow/__init__.py | 1 + .../apache/airavata/model/workflow/constants.py | 12 + .../apache/airavata/model/workflow/ttypes.py | 162 + .../apache/airavata/model/workspace/__init__.py | 1 + .../airavata/model/workspace/constants.py | 11 + .../model/workspace/experiment/__init__.py | 1 + .../model/workspace/experiment/constants.py | 14 + .../model/workspace/experiment/ttypes.py | 3042 ++ .../apache/airavata/model/workspace/ttypes.py | 429 + airavata-api/airavata-client-sdks/pom.xml | 5 +- .../airavataDataModel.thrift | 1 + .../airavataErrors.thrift | 2 +- .../applicationDeploymentModel.thrift | 1 + .../applicationInterfaceModel.thrift | 1 + .../computeResourceModel.thrift | 1 + .../experimentModel.thrift | 1 + .../gatewayResourceProfileModel.thrift | 2 + .../messagingEvents.thrift | 1 + .../workflowAPI.thrift | 4 +- .../workflowDataModel.thrift | 2 + .../workspaceModel.thrift | 1 + 53 files changed, 39503 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/pom.xml ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/pom.xml b/airavata-api/airavata-client-sdks/airavata-python-sdk/pom.xml new file mode 100644 index 0000000..9f5c1ae --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/pom.xml @@ -0,0 +1,114 @@ +<?xml version="1.0" encoding="UTF-8"?> + +<!--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. --> + +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + <parent> + <groupId>org.apache.airavata</groupId> + <artifactId>airavata-client-sdks</artifactId> + <version>0.15-SNAPSHOT</version> + <relativePath>../pom.xml</relativePath> + </parent> + + <modelVersion>4.0.0</modelVersion> + <artifactId>apache-airavata-client-python-sdk</artifactId> + <name>Airavata Client Python SDK</name> + <packaging>pom</packaging> + <url>http://airavata.apache.org/</url> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-dependency-plugin</artifactId> + <version>2.8</version> + <executions> + <execution> + <id>unpack</id> + <phase>compile</phase> + <goals> + <goal>unpack</goal> + </goals> + <configuration> + <artifactItems> + <artifactItem> + <groupId>org.apache.airavata</groupId> + <artifactId>airavata-client-configuration</artifactId> + <version>${project.version}</version> + <type>jar</type> + </artifactItem> + </artifactItems> + <outputDirectory>${project.build.directory}/conf</outputDirectory> + </configuration> + </execution> + </executions> + </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-assembly-plugin</artifactId> + <executions> + <execution> + <id>distribution-package</id> + <phase>package</phase> + <goals> + <goal>single</goal> + </goals> + <configuration> + <finalName>${archive.name}-${project.version}</finalName> + <descriptors> + <descriptor>src/main/assembly/bin-assembly.xml</descriptor> + </descriptors> + <attach>false</attach> + </configuration> + </execution> + </executions> + </plugin> + <plugin> + <groupId>org.codehaus.mojo</groupId> + <artifactId>build-helper-maven-plugin</artifactId> + <version>1.7</version> + <executions> + <execution> + <id>attach-artifacts</id> + <phase>package</phase> + <goals> + <goal>attach-artifact</goal> + </goals> + <configuration> + <artifacts> + <artifact> + <file>${airavata.client-bin.zip}</file> + <type>zip</type> + <classifier>bin</classifier> + </artifact> + <artifact> + <file>${airavata.client-bin.tar.gz}</file> + <type>tar.gz</type> + <classifier>bin</classifier> + </artifact> + </artifacts> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> + + + <properties> + <jersey.version>1.13</jersey.version> + <grizzly.version>2.0.0-M3</grizzly.version> + <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> + <archive.name>apache-airavata-client-python-sdk</archive.name> + <used.axis2.release>${axis2.version}</used.axis2.release> + <airavata.client-dist.name>${archive.name}-${project.version}</airavata.client-dist.name> + <airavata.client-bin.zip>${project.build.directory}/${airavata.client-dist.name}-bin.zip</airavata.client-bin.zip> + <airavata.client-bin.tar.gz>${project.build.directory}/${airavata.client-dist.name}-bin.tar.gz</airavata.client-bin.tar.gz> + </properties> +</project> http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/__init__.py new file mode 100644 index 0000000..e69de29 http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/__init__.py new file mode 100644 index 0000000..e69de29 http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/__init__.py new file mode 100644 index 0000000..e69de29 http://git-wip-us.apache.org/repos/asf/airavata/blob/97c7a736/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote new file mode 100755 index 0000000..f297497 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote @@ -0,0 +1,893 @@ +#!/usr/bin/env python +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py +# + +import sys +import pprint +from urlparse import urlparse +from thrift.transport import TTransport +from thrift.transport import TSocket +from thrift.transport import THttpClient +from thrift.protocol import TBinaryProtocol + +from apache.airavata.api import Airavata +from apache.airavata.api.ttypes import * + +if len(sys.argv) <= 1 or sys.argv[1] == '--help': + print '' + print 'Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] function [arg1 [arg2...]]' + print '' + print 'Functions:' + print ' string getAPIVersion()' + print ' string addGateway(Gateway gateway)' + print ' void updateGateway(string gatewayId, Gateway updatedGateway)' + print ' Gateway getGateway(string gatewayId)' + print ' bool deleteGateway(string gatewayId)' + print ' getAllGateways()' + print ' bool isGatewayExist(string gatewayId)' + print ' string generateAndRegisterSSHKeys(string gatewayId, string userName)' + print ' string getSSHPubKey(string airavataCredStoreToken)' + print ' getAllUserSSHPubKeys(string userName)' + print ' string createProject(string gatewayId, Project project)' + print ' void updateProject(string projectId, Project updatedProject)' + print ' Project getProject(string projectId)' + print ' bool deleteProject(string projectId)' + print ' getAllUserProjects(string gatewayId, string userName)' + print ' searchProjectsByProjectName(string gatewayId, string userName, string projectName)' + print ' searchProjectsByProjectDesc(string gatewayId, string userName, string description)' + print ' searchExperimentsByName(string gatewayId, string userName, string expName)' + print ' searchExperimentsByDesc(string gatewayId, string userName, string description)' + print ' searchExperimentsByApplication(string gatewayId, string userName, string applicationId)' + print ' searchExperimentsByStatus(string gatewayId, string userName, ExperimentState experimentState)' + print ' searchExperimentsByCreationTime(string gatewayId, string userName, i64 fromTime, i64 toTime)' + print ' getAllExperimentsInProject(string projectId)' + print ' getAllUserExperiments(string gatewayId, string userName)' + print ' string createExperiment(string gatewayId, Experiment experiment)' + print ' Experiment getExperiment(string airavataExperimentId)' + print ' void updateExperiment(string airavataExperimentId, Experiment experiment)' + print ' void updateExperimentConfiguration(string airavataExperimentId, UserConfigurationData userConfiguration)' + print ' void updateResourceScheduleing(string airavataExperimentId, ComputationalResourceScheduling resourceScheduling)' + print ' bool validateExperiment(string airavataExperimentId)' + print ' void launchExperiment(string airavataExperimentId, string airavataCredStoreToken)' + print ' ExperimentStatus getExperimentStatus(string airavataExperimentId)' + print ' getExperimentOutputs(string airavataExperimentId)' + print ' getIntermediateOutputs(string airavataExperimentId)' + print ' getJobStatuses(string airavataExperimentId)' + print ' getJobDetails(string airavataExperimentId)' + print ' getDataTransferDetails(string airavataExperimentId)' + print ' string cloneExperiment(string existingExperimentID, string newExperimentName)' + print ' void terminateExperiment(string airavataExperimentId)' + print ' string registerApplicationModule(string gatewayId, ApplicationModule applicationModule)' + print ' ApplicationModule getApplicationModule(string appModuleId)' + print ' bool updateApplicationModule(string appModuleId, ApplicationModule applicationModule)' + print ' getAllAppModules(string gatewayId)' + print ' bool deleteApplicationModule(string appModuleId)' + print ' string registerApplicationDeployment(string gatewayId, ApplicationDeploymentDescription applicationDeployment)' + print ' ApplicationDeploymentDescription getApplicationDeployment(string appDeploymentId)' + print ' bool updateApplicationDeployment(string appDeploymentId, ApplicationDeploymentDescription applicationDeployment)' + print ' bool deleteApplicationDeployment(string appDeploymentId)' + print ' getAllApplicationDeployments(string gatewayId)' + print ' getAppModuleDeployedResources(string appModuleId)' + print ' string registerApplicationInterface(string gatewayId, ApplicationInterfaceDescription applicationInterface)' + print ' ApplicationInterfaceDescription getApplicationInterface(string appInterfaceId)' + print ' bool updateApplicationInterface(string appInterfaceId, ApplicationInterfaceDescription applicationInterface)' + print ' bool deleteApplicationInterface(string appInterfaceId)' + print ' getAllApplicationInterfaceNames(string gatewayId)' + print ' getAllApplicationInterfaces(string gatewayId)' + print ' getApplicationInputs(string appInterfaceId)' + print ' getApplicationOutputs(string appInterfaceId)' + print ' getAvailableAppInterfaceComputeResources(string appInterfaceId)' + print ' string registerComputeResource(ComputeResourceDescription computeResourceDescription)' + print ' ComputeResourceDescription getComputeResource(string computeResourceId)' + print ' getAllComputeResourceNames()' + print ' bool updateComputeResource(string computeResourceId, ComputeResourceDescription computeResourceDescription)' + print ' bool deleteComputeResource(string computeResourceId)' + print ' string addLocalSubmissionDetails(string computeResourceId, i32 priorityOrder, LOCALSubmission localSubmission)' + print ' bool updateLocalSubmissionDetails(string jobSubmissionInterfaceId, LOCALSubmission localSubmission)' + print ' LOCALSubmission getLocalJobSubmission(string jobSubmissionId)' + print ' string addSSHJobSubmissionDetails(string computeResourceId, i32 priorityOrder, SSHJobSubmission sshJobSubmission)' + print ' SSHJobSubmission getSSHJobSubmission(string jobSubmissionId)' + print ' string addUNICOREJobSubmissionDetails(string computeResourceId, i32 priorityOrder, UnicoreJobSubmission unicoreJobSubmission)' + print ' UnicoreJobSubmission getUnicoreJobSubmission(string jobSubmissionId)' + print ' string addCloudJobSubmissionDetails(string computeResourceId, i32 priorityOrder, CloudJobSubmission cloudSubmission)' + print ' CloudJobSubmission getCloudJobSubmission(string jobSubmissionId)' + print ' bool updateSSHJobSubmissionDetails(string jobSubmissionInterfaceId, SSHJobSubmission sshJobSubmission)' + print ' bool updateCloudJobSubmissionDetails(string jobSubmissionInterfaceId, CloudJobSubmission sshJobSubmission)' + print ' bool updateUnicoreJobSubmissionDetails(string jobSubmissionInterfaceId, UnicoreJobSubmission unicoreJobSubmission)' + print ' string addLocalDataMovementDetails(string computeResourceId, i32 priorityOrder, LOCALDataMovement localDataMovement)' + print ' bool updateLocalDataMovementDetails(string dataMovementInterfaceId, LOCALDataMovement localDataMovement)' + print ' LOCALDataMovement getLocalDataMovement(string dataMovementId)' + print ' string addSCPDataMovementDetails(string computeResourceId, i32 priorityOrder, SCPDataMovement scpDataMovement)' + print ' bool updateSCPDataMovementDetails(string dataMovementInterfaceId, SCPDataMovement scpDataMovement)' + print ' SCPDataMovement getSCPDataMovement(string dataMovementId)' + print ' string addUnicoreDataMovementDetails(string computeResourceId, i32 priorityOrder, UnicoreDataMovement unicoreDataMovement)' + print ' bool updateUnicoreDataMovementDetails(string dataMovementInterfaceId, UnicoreDataMovement unicoreDataMovement)' + print ' UnicoreDataMovement getUnicoreDataMovement(string dataMovementId)' + print ' string addGridFTPDataMovementDetails(string computeResourceId, i32 priorityOrder, GridFTPDataMovement gridFTPDataMovement)' + print ' bool updateGridFTPDataMovementDetails(string dataMovementInterfaceId, GridFTPDataMovement gridFTPDataMovement)' + print ' GridFTPDataMovement getGridFTPDataMovement(string dataMovementId)' + print ' bool changeJobSubmissionPriority(string jobSubmissionInterfaceId, i32 newPriorityOrder)' + print ' bool changeDataMovementPriority(string dataMovementInterfaceId, i32 newPriorityOrder)' + print ' bool changeJobSubmissionPriorities( jobSubmissionPriorityMap)' + print ' bool changeDataMovementPriorities( dataMovementPriorityMap)' + print ' bool deleteJobSubmissionInterface(string computeResourceId, string jobSubmissionInterfaceId)' + print ' bool deleteDataMovementInterface(string computeResourceId, string dataMovementInterfaceId)' + print ' string registerResourceJobManager(ResourceJobManager resourceJobManager)' + print ' bool updateResourceJobManager(string resourceJobManagerId, ResourceJobManager updatedResourceJobManager)' + print ' ResourceJobManager getResourceJobManager(string resourceJobManagerId)' + print ' bool deleteResourceJobManager(string resourceJobManagerId)' + print ' bool deleteBatchQueue(string computeResourceId, string queueName)' + print ' string registerGatewayResourceProfile(GatewayResourceProfile gatewayResourceProfile)' + print ' GatewayResourceProfile getGatewayResourceProfile(string gatewayID)' + print ' bool updateGatewayResourceProfile(string gatewayID, GatewayResourceProfile gatewayResourceProfile)' + print ' bool deleteGatewayResourceProfile(string gatewayID)' + print ' bool addGatewayComputeResourcePreference(string gatewayID, string computeResourceId, ComputeResourcePreference computeResourcePreference)' + print ' ComputeResourcePreference getGatewayComputeResourcePreference(string gatewayID, string computeResourceId)' + print ' getAllGatewayComputeResourcePreferences(string gatewayID)' + print ' getAllGatewayComputeResources()' + print ' bool updateGatewayComputeResourcePreference(string gatewayID, string computeResourceId, ComputeResourcePreference computeResourcePreference)' + print ' bool deleteGatewayComputeResourcePreference(string gatewayID, string computeResourceId)' + print ' getAllWorkflows(string gatewayId)' + print ' Workflow getWorkflow(string workflowTemplateId)' + print ' void deleteWorkflow(string workflowTemplateId)' + print ' string registerWorkflow(string gatewayId, Workflow workflow)' + print ' void updateWorkflow(string workflowTemplateId, Workflow workflow)' + print ' string getWorkflowTemplateId(string workflowName)' + print ' bool isWorkflowExistWithName(string workflowName)' + print '' + sys.exit(0) + +pp = pprint.PrettyPrinter(indent = 2) +host = 'localhost' +port = 9090 +uri = '' +framed = False +http = False +argi = 1 + +if sys.argv[argi] == '-h': + parts = sys.argv[argi+1].split(':') + host = parts[0] + if len(parts) > 1: + port = int(parts[1]) + argi += 2 + +if sys.argv[argi] == '-u': + url = urlparse(sys.argv[argi+1]) + parts = url[1].split(':') + host = parts[0] + if len(parts) > 1: + port = int(parts[1]) + else: + port = 80 + uri = url[2] + if url[4]: + uri += '?%s' % url[4] + http = True + argi += 2 + +if sys.argv[argi] == '-f' or sys.argv[argi] == '-framed': + framed = True + argi += 1 + +cmd = sys.argv[argi] +args = sys.argv[argi+1:] + +if http: + transport = THttpClient.THttpClient(host, port, uri) +else: + socket = TSocket.TSocket(host, port) + if framed: + transport = TTransport.TFramedTransport(socket) + else: + transport = TTransport.TBufferedTransport(socket) +protocol = TBinaryProtocol.TBinaryProtocol(transport) +client = Airavata.Client(protocol) +transport.open() + +if cmd == 'getAPIVersion': + if len(args) != 0: + print 'getAPIVersion requires 0 args' + sys.exit(1) + pp.pprint(client.getAPIVersion()) + +elif cmd == 'addGateway': + if len(args) != 1: + print 'addGateway requires 1 args' + sys.exit(1) + pp.pprint(client.addGateway(eval(args[0]),)) + +elif cmd == 'updateGateway': + if len(args) != 2: + print 'updateGateway requires 2 args' + sys.exit(1) + pp.pprint(client.updateGateway(args[0],eval(args[1]),)) + +elif cmd == 'getGateway': + if len(args) != 1: + print 'getGateway requires 1 args' + sys.exit(1) + pp.pprint(client.getGateway(args[0],)) + +elif cmd == 'deleteGateway': + if len(args) != 1: + print 'deleteGateway requires 1 args' + sys.exit(1) + pp.pprint(client.deleteGateway(args[0],)) + +elif cmd == 'getAllGateways': + if len(args) != 0: + print 'getAllGateways requires 0 args' + sys.exit(1) + pp.pprint(client.getAllGateways()) + +elif cmd == 'isGatewayExist': + if len(args) != 1: + print 'isGatewayExist requires 1 args' + sys.exit(1) + pp.pprint(client.isGatewayExist(args[0],)) + +elif cmd == 'generateAndRegisterSSHKeys': + if len(args) != 2: + print 'generateAndRegisterSSHKeys requires 2 args' + sys.exit(1) + pp.pprint(client.generateAndRegisterSSHKeys(args[0],args[1],)) + +elif cmd == 'getSSHPubKey': + if len(args) != 1: + print 'getSSHPubKey requires 1 args' + sys.exit(1) + pp.pprint(client.getSSHPubKey(args[0],)) + +elif cmd == 'getAllUserSSHPubKeys': + if len(args) != 1: + print 'getAllUserSSHPubKeys requires 1 args' + sys.exit(1) + pp.pprint(client.getAllUserSSHPubKeys(args[0],)) + +elif cmd == 'createProject': + if len(args) != 2: + print 'createProject requires 2 args' + sys.exit(1) + pp.pprint(client.createProject(args[0],eval(args[1]),)) + +elif cmd == 'updateProject': + if len(args) != 2: + print 'updateProject requires 2 args' + sys.exit(1) + pp.pprint(client.updateProject(args[0],eval(args[1]),)) + +elif cmd == 'getProject': + if len(args) != 1: + print 'getProject requires 1 args' + sys.exit(1) + pp.pprint(client.getProject(args[0],)) + +elif cmd == 'deleteProject': + if len(args) != 1: + print 'deleteProject requires 1 args' + sys.exit(1) + pp.pprint(client.deleteProject(args[0],)) + +elif cmd == 'getAllUserProjects': + if len(args) != 2: + print 'getAllUserProjects requires 2 args' + sys.exit(1) + pp.pprint(client.getAllUserProjects(args[0],args[1],)) + +elif cmd == 'searchProjectsByProjectName': + if len(args) != 3: + print 'searchProjectsByProjectName requires 3 args' + sys.exit(1) + pp.pprint(client.searchProjectsByProjectName(args[0],args[1],args[2],)) + +elif cmd == 'searchProjectsByProjectDesc': + if len(args) != 3: + print 'searchProjectsByProjectDesc requires 3 args' + sys.exit(1) + pp.pprint(client.searchProjectsByProjectDesc(args[0],args[1],args[2],)) + +elif cmd == 'searchExperimentsByName': + if len(args) != 3: + print 'searchExperimentsByName requires 3 args' + sys.exit(1) + pp.pprint(client.searchExperimentsByName(args[0],args[1],args[2],)) + +elif cmd == 'searchExperimentsByDesc': + if len(args) != 3: + print 'searchExperimentsByDesc requires 3 args' + sys.exit(1) + pp.pprint(client.searchExperimentsByDesc(args[0],args[1],args[2],)) + +elif cmd == 'searchExperimentsByApplication': + if len(args) != 3: + print 'searchExperimentsByApplication requires 3 args' + sys.exit(1) + pp.pprint(client.searchExperimentsByApplication(args[0],args[1],args[2],)) + +elif cmd == 'searchExperimentsByStatus': + if len(args) != 3: + print 'searchExperimentsByStatus requires 3 args' + sys.exit(1) + pp.pprint(client.searchExperimentsByStatus(args[0],args[1],eval(args[2]),)) + +elif cmd == 'searchExperimentsByCreationTime': + if len(args) != 4: + print 'searchExperimentsByCreationTime requires 4 args' + sys.exit(1) + pp.pprint(client.searchExperimentsByCreationTime(args[0],args[1],eval(args[2]),eval(args[3]),)) + +elif cmd == 'getAllExperimentsInProject': + if len(args) != 1: + print 'getAllExperimentsInProject requires 1 args' + sys.exit(1) + pp.pprint(client.getAllExperimentsInProject(args[0],)) + +elif cmd == 'getAllUserExperiments': + if len(args) != 2: + print 'getAllUserExperiments requires 2 args' + sys.exit(1) + pp.pprint(client.getAllUserExperiments(args[0],args[1],)) + +elif cmd == 'createExperiment': + if len(args) != 2: + print 'createExperiment requires 2 args' + sys.exit(1) + pp.pprint(client.createExperiment(args[0],eval(args[1]),)) + +elif cmd == 'getExperiment': + if len(args) != 1: + print 'getExperiment requires 1 args' + sys.exit(1) + pp.pprint(client.getExperiment(args[0],)) + +elif cmd == 'updateExperiment': + if len(args) != 2: + print 'updateExperiment requires 2 args' + sys.exit(1) + pp.pprint(client.updateExperiment(args[0],eval(args[1]),)) + +elif cmd == 'updateExperimentConfiguration': + if len(args) != 2: + print 'updateExperimentConfiguration requires 2 args' + sys.exit(1) + pp.pprint(client.updateExperimentConfiguration(args[0],eval(args[1]),)) + +elif cmd == 'updateResourceScheduleing': + if len(args) != 2: + print 'updateResourceScheduleing requires 2 args' + sys.exit(1) + pp.pprint(client.updateResourceScheduleing(args[0],eval(args[1]),)) + +elif cmd == 'validateExperiment': + if len(args) != 1: + print 'validateExperiment requires 1 args' + sys.exit(1) + pp.pprint(client.validateExperiment(args[0],)) + +elif cmd == 'launchExperiment': + if len(args) != 2: + print 'launchExperiment requires 2 args' + sys.exit(1) + pp.pprint(client.launchExperiment(args[0],args[1],)) + +elif cmd == 'getExperimentStatus': + if len(args) != 1: + print 'getExperimentStatus requires 1 args' + sys.exit(1) + pp.pprint(client.getExperimentStatus(args[0],)) + +elif cmd == 'getExperimentOutputs': + if len(args) != 1: + print 'getExperimentOutputs requires 1 args' + sys.exit(1) + pp.pprint(client.getExperimentOutputs(args[0],)) + +elif cmd == 'getIntermediateOutputs': + if len(args) != 1: + print 'getIntermediateOutputs requires 1 args' + sys.exit(1) + pp.pprint(client.getIntermediateOutputs(args[0],)) + +elif cmd == 'getJobStatuses': + if len(args) != 1: + print 'getJobStatuses requires 1 args' + sys.exit(1) + pp.pprint(client.getJobStatuses(args[0],)) + +elif cmd == 'getJobDetails': + if len(args) != 1: + print 'getJobDetails requires 1 args' + sys.exit(1) + pp.pprint(client.getJobDetails(args[0],)) + +elif cmd == 'getDataTransferDetails': + if len(args) != 1: + print 'getDataTransferDetails requires 1 args' + sys.exit(1) + pp.pprint(client.getDataTransferDetails(args[0],)) + +elif cmd == 'cloneExperiment': + if len(args) != 2: + print 'cloneExperiment requires 2 args' + sys.exit(1) + pp.pprint(client.cloneExperiment(args[0],args[1],)) + +elif cmd == 'terminateExperiment': + if len(args) != 1: + print 'terminateExperiment requires 1 args' + sys.exit(1) + pp.pprint(client.terminateExperiment(args[0],)) + +elif cmd == 'registerApplicationModule': + if len(args) != 2: + print 'registerApplicationModule requires 2 args' + sys.exit(1) + pp.pprint(client.registerApplicationModule(args[0],eval(args[1]),)) + +elif cmd == 'getApplicationModule': + if len(args) != 1: + print 'getApplicationModule requires 1 args' + sys.exit(1) + pp.pprint(client.getApplicationModule(args[0],)) + +elif cmd == 'updateApplicationModule': + if len(args) != 2: + print 'updateApplicationModule requires 2 args' + sys.exit(1) + pp.pprint(client.updateApplicationModule(args[0],eval(args[1]),)) + +elif cmd == 'getAllAppModules': + if len(args) != 1: + print 'getAllAppModules requires 1 args' + sys.exit(1) + pp.pprint(client.getAllAppModules(args[0],)) + +elif cmd == 'deleteApplicationModule': + if len(args) != 1: + print 'deleteApplicationModule requires 1 args' + sys.exit(1) + pp.pprint(client.deleteApplicationModule(args[0],)) + +elif cmd == 'registerApplicationDeployment': + if len(args) != 2: + print 'registerApplicationDeployment requires 2 args' + sys.exit(1) + pp.pprint(client.registerApplicationDeployment(args[0],eval(args[1]),)) + +elif cmd == 'getApplicationDeployment': + if len(args) != 1: + print 'getApplicationDeployment requires 1 args' + sys.exit(1) + pp.pprint(client.getApplicationDeployment(args[0],)) + +elif cmd == 'updateApplicationDeployment': + if len(args) != 2: + print 'updateApplicationDeployment requires 2 args' + sys.exit(1) + pp.pprint(client.updateApplicationDeployment(args[0],eval(args[1]),)) + +elif cmd == 'deleteApplicationDeployment': + if len(args) != 1: + print 'deleteApplicationDeployment requires 1 args' + sys.exit(1) + pp.pprint(client.deleteApplicationDeployment(args[0],)) + +elif cmd == 'getAllApplicationDeployments': + if len(args) != 1: + print 'getAllApplicationDeployments requires 1 args' + sys.exit(1) + pp.pprint(client.getAllApplicationDeployments(args[0],)) + +elif cmd == 'getAppModuleDeployedResources': + if len(args) != 1: + print 'getAppModuleDeployedResources requires 1 args' + sys.exit(1) + pp.pprint(client.getAppModuleDeployedResources(args[0],)) + +elif cmd == 'registerApplicationInterface': + if len(args) != 2: + print 'registerApplicationInterface requires 2 args' + sys.exit(1) + pp.pprint(client.registerApplicationInterface(args[0],eval(args[1]),)) + +elif cmd == 'getApplicationInterface': + if len(args) != 1: + print 'getApplicationInterface requires 1 args' + sys.exit(1) + pp.pprint(client.getApplicationInterface(args[0],)) + +elif cmd == 'updateApplicationInterface': + if len(args) != 2: + print 'updateApplicationInterface requires 2 args' + sys.exit(1) + pp.pprint(client.updateApplicationInterface(args[0],eval(args[1]),)) + +elif cmd == 'deleteApplicationInterface': + if len(args) != 1: + print 'deleteApplicationInterface requires 1 args' + sys.exit(1) + pp.pprint(client.deleteApplicationInterface(args[0],)) + +elif cmd == 'getAllApplicationInterfaceNames': + if len(args) != 1: + print 'getAllApplicationInterfaceNames requires 1 args' + sys.exit(1) + pp.pprint(client.getAllApplicationInterfaceNames(args[0],)) + +elif cmd == 'getAllApplicationInterfaces': + if len(args) != 1: + print 'getAllApplicationInterfaces requires 1 args' + sys.exit(1) + pp.pprint(client.getAllApplicationInterfaces(args[0],)) + +elif cmd == 'getApplicationInputs': + if len(args) != 1: + print 'getApplicationInputs requires 1 args' + sys.exit(1) + pp.pprint(client.getApplicationInputs(args[0],)) + +elif cmd == 'getApplicationOutputs': + if len(args) != 1: + print 'getApplicationOutputs requires 1 args' + sys.exit(1) + pp.pprint(client.getApplicationOutputs(args[0],)) + +elif cmd == 'getAvailableAppInterfaceComputeResources': + if len(args) != 1: + print 'getAvailableAppInterfaceComputeResources requires 1 args' + sys.exit(1) + pp.pprint(client.getAvailableAppInterfaceComputeResources(args[0],)) + +elif cmd == 'registerComputeResource': + if len(args) != 1: + print 'registerComputeResource requires 1 args' + sys.exit(1) + pp.pprint(client.registerComputeResource(eval(args[0]),)) + +elif cmd == 'getComputeResource': + if len(args) != 1: + print 'getComputeResource requires 1 args' + sys.exit(1) + pp.pprint(client.getComputeResource(args[0],)) + +elif cmd == 'getAllComputeResourceNames': + if len(args) != 0: + print 'getAllComputeResourceNames requires 0 args' + sys.exit(1) + pp.pprint(client.getAllComputeResourceNames()) + +elif cmd == 'updateComputeResource': + if len(args) != 2: + print 'updateComputeResource requires 2 args' + sys.exit(1) + pp.pprint(client.updateComputeResource(args[0],eval(args[1]),)) + +elif cmd == 'deleteComputeResource': + if len(args) != 1: + print 'deleteComputeResource requires 1 args' + sys.exit(1) + pp.pprint(client.deleteComputeResource(args[0],)) + +elif cmd == 'addLocalSubmissionDetails': + if len(args) != 3: + print 'addLocalSubmissionDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addLocalSubmissionDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'updateLocalSubmissionDetails': + if len(args) != 2: + print 'updateLocalSubmissionDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateLocalSubmissionDetails(args[0],eval(args[1]),)) + +elif cmd == 'getLocalJobSubmission': + if len(args) != 1: + print 'getLocalJobSubmission requires 1 args' + sys.exit(1) + pp.pprint(client.getLocalJobSubmission(args[0],)) + +elif cmd == 'addSSHJobSubmissionDetails': + if len(args) != 3: + print 'addSSHJobSubmissionDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addSSHJobSubmissionDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'getSSHJobSubmission': + if len(args) != 1: + print 'getSSHJobSubmission requires 1 args' + sys.exit(1) + pp.pprint(client.getSSHJobSubmission(args[0],)) + +elif cmd == 'addUNICOREJobSubmissionDetails': + if len(args) != 3: + print 'addUNICOREJobSubmissionDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addUNICOREJobSubmissionDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'getUnicoreJobSubmission': + if len(args) != 1: + print 'getUnicoreJobSubmission requires 1 args' + sys.exit(1) + pp.pprint(client.getUnicoreJobSubmission(args[0],)) + +elif cmd == 'addCloudJobSubmissionDetails': + if len(args) != 3: + print 'addCloudJobSubmissionDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addCloudJobSubmissionDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'getCloudJobSubmission': + if len(args) != 1: + print 'getCloudJobSubmission requires 1 args' + sys.exit(1) + pp.pprint(client.getCloudJobSubmission(args[0],)) + +elif cmd == 'updateSSHJobSubmissionDetails': + if len(args) != 2: + print 'updateSSHJobSubmissionDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateSSHJobSubmissionDetails(args[0],eval(args[1]),)) + +elif cmd == 'updateCloudJobSubmissionDetails': + if len(args) != 2: + print 'updateCloudJobSubmissionDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateCloudJobSubmissionDetails(args[0],eval(args[1]),)) + +elif cmd == 'updateUnicoreJobSubmissionDetails': + if len(args) != 2: + print 'updateUnicoreJobSubmissionDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateUnicoreJobSubmissionDetails(args[0],eval(args[1]),)) + +elif cmd == 'addLocalDataMovementDetails': + if len(args) != 3: + print 'addLocalDataMovementDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addLocalDataMovementDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'updateLocalDataMovementDetails': + if len(args) != 2: + print 'updateLocalDataMovementDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateLocalDataMovementDetails(args[0],eval(args[1]),)) + +elif cmd == 'getLocalDataMovement': + if len(args) != 1: + print 'getLocalDataMovement requires 1 args' + sys.exit(1) + pp.pprint(client.getLocalDataMovement(args[0],)) + +elif cmd == 'addSCPDataMovementDetails': + if len(args) != 3: + print 'addSCPDataMovementDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addSCPDataMovementDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'updateSCPDataMovementDetails': + if len(args) != 2: + print 'updateSCPDataMovementDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateSCPDataMovementDetails(args[0],eval(args[1]),)) + +elif cmd == 'getSCPDataMovement': + if len(args) != 1: + print 'getSCPDataMovement requires 1 args' + sys.exit(1) + pp.pprint(client.getSCPDataMovement(args[0],)) + +elif cmd == 'addUnicoreDataMovementDetails': + if len(args) != 3: + print 'addUnicoreDataMovementDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addUnicoreDataMovementDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'updateUnicoreDataMovementDetails': + if len(args) != 2: + print 'updateUnicoreDataMovementDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateUnicoreDataMovementDetails(args[0],eval(args[1]),)) + +elif cmd == 'getUnicoreDataMovement': + if len(args) != 1: + print 'getUnicoreDataMovement requires 1 args' + sys.exit(1) + pp.pprint(client.getUnicoreDataMovement(args[0],)) + +elif cmd == 'addGridFTPDataMovementDetails': + if len(args) != 3: + print 'addGridFTPDataMovementDetails requires 3 args' + sys.exit(1) + pp.pprint(client.addGridFTPDataMovementDetails(args[0],eval(args[1]),eval(args[2]),)) + +elif cmd == 'updateGridFTPDataMovementDetails': + if len(args) != 2: + print 'updateGridFTPDataMovementDetails requires 2 args' + sys.exit(1) + pp.pprint(client.updateGridFTPDataMovementDetails(args[0],eval(args[1]),)) + +elif cmd == 'getGridFTPDataMovement': + if len(args) != 1: + print 'getGridFTPDataMovement requires 1 args' + sys.exit(1) + pp.pprint(client.getGridFTPDataMovement(args[0],)) + +elif cmd == 'changeJobSubmissionPriority': + if len(args) != 2: + print 'changeJobSubmissionPriority requires 2 args' + sys.exit(1) + pp.pprint(client.changeJobSubmissionPriority(args[0],eval(args[1]),)) + +elif cmd == 'changeDataMovementPriority': + if len(args) != 2: + print 'changeDataMovementPriority requires 2 args' + sys.exit(1) + pp.pprint(client.changeDataMovementPriority(args[0],eval(args[1]),)) + +elif cmd == 'changeJobSubmissionPriorities': + if len(args) != 1: + print 'changeJobSubmissionPriorities requires 1 args' + sys.exit(1) + pp.pprint(client.changeJobSubmissionPriorities(eval(args[0]),)) + +elif cmd == 'changeDataMovementPriorities': + if len(args) != 1: + print 'changeDataMovementPriorities requires 1 args' + sys.exit(1) + pp.pprint(client.changeDataMovementPriorities(eval(args[0]),)) + +elif cmd == 'deleteJobSubmissionInterface': + if len(args) != 2: + print 'deleteJobSubmissionInterface requires 2 args' + sys.exit(1) + pp.pprint(client.deleteJobSubmissionInterface(args[0],args[1],)) + +elif cmd == 'deleteDataMovementInterface': + if len(args) != 2: + print 'deleteDataMovementInterface requires 2 args' + sys.exit(1) + pp.pprint(client.deleteDataMovementInterface(args[0],args[1],)) + +elif cmd == 'registerResourceJobManager': + if len(args) != 1: + print 'registerResourceJobManager requires 1 args' + sys.exit(1) + pp.pprint(client.registerResourceJobManager(eval(args[0]),)) + +elif cmd == 'updateResourceJobManager': + if len(args) != 2: + print 'updateResourceJobManager requires 2 args' + sys.exit(1) + pp.pprint(client.updateResourceJobManager(args[0],eval(args[1]),)) + +elif cmd == 'getResourceJobManager': + if len(args) != 1: + print 'getResourceJobManager requires 1 args' + sys.exit(1) + pp.pprint(client.getResourceJobManager(args[0],)) + +elif cmd == 'deleteResourceJobManager': + if len(args) != 1: + print 'deleteResourceJobManager requires 1 args' + sys.exit(1) + pp.pprint(client.deleteResourceJobManager(args[0],)) + +elif cmd == 'deleteBatchQueue': + if len(args) != 2: + print 'deleteBatchQueue requires 2 args' + sys.exit(1) + pp.pprint(client.deleteBatchQueue(args[0],args[1],)) + +elif cmd == 'registerGatewayResourceProfile': + if len(args) != 1: + print 'registerGatewayResourceProfile requires 1 args' + sys.exit(1) + pp.pprint(client.registerGatewayResourceProfile(eval(args[0]),)) + +elif cmd == 'getGatewayResourceProfile': + if len(args) != 1: + print 'getGatewayResourceProfile requires 1 args' + sys.exit(1) + pp.pprint(client.getGatewayResourceProfile(args[0],)) + +elif cmd == 'updateGatewayResourceProfile': + if len(args) != 2: + print 'updateGatewayResourceProfile requires 2 args' + sys.exit(1) + pp.pprint(client.updateGatewayResourceProfile(args[0],eval(args[1]),)) + +elif cmd == 'deleteGatewayResourceProfile': + if len(args) != 1: + print 'deleteGatewayResourceProfile requires 1 args' + sys.exit(1) + pp.pprint(client.deleteGatewayResourceProfile(args[0],)) + +elif cmd == 'addGatewayComputeResourcePreference': + if len(args) != 3: + print 'addGatewayComputeResourcePreference requires 3 args' + sys.exit(1) + pp.pprint(client.addGatewayComputeResourcePreference(args[0],args[1],eval(args[2]),)) + +elif cmd == 'getGatewayComputeResourcePreference': + if len(args) != 2: + print 'getGatewayComputeResourcePreference requires 2 args' + sys.exit(1) + pp.pprint(client.getGatewayComputeResourcePreference(args[0],args[1],)) + +elif cmd == 'getAllGatewayComputeResourcePreferences': + if len(args) != 1: + print 'getAllGatewayComputeResourcePreferences requires 1 args' + sys.exit(1) + pp.pprint(client.getAllGatewayComputeResourcePreferences(args[0],)) + +elif cmd == 'getAllGatewayComputeResources': + if len(args) != 0: + print 'getAllGatewayComputeResources requires 0 args' + sys.exit(1) + pp.pprint(client.getAllGatewayComputeResources()) + +elif cmd == 'updateGatewayComputeResourcePreference': + if len(args) != 3: + print 'updateGatewayComputeResourcePreference requires 3 args' + sys.exit(1) + pp.pprint(client.updateGatewayComputeResourcePreference(args[0],args[1],eval(args[2]),)) + +elif cmd == 'deleteGatewayComputeResourcePreference': + if len(args) != 2: + print 'deleteGatewayComputeResourcePreference requires 2 args' + sys.exit(1) + pp.pprint(client.deleteGatewayComputeResourcePreference(args[0],args[1],)) + +elif cmd == 'getAllWorkflows': + if len(args) != 1: + print 'getAllWorkflows requires 1 args' + sys.exit(1) + pp.pprint(client.getAllWorkflows(args[0],)) + +elif cmd == 'getWorkflow': + if len(args) != 1: + print 'getWorkflow requires 1 args' + sys.exit(1) + pp.pprint(client.getWorkflow(args[0],)) + +elif cmd == 'deleteWorkflow': + if len(args) != 1: + print 'deleteWorkflow requires 1 args' + sys.exit(1) + pp.pprint(client.deleteWorkflow(args[0],)) + +elif cmd == 'registerWorkflow': + if len(args) != 2: + print 'registerWorkflow requires 2 args' + sys.exit(1) + pp.pprint(client.registerWorkflow(args[0],eval(args[1]),)) + +elif cmd == 'updateWorkflow': + if len(args) != 2: + print 'updateWorkflow requires 2 args' + sys.exit(1) + pp.pprint(client.updateWorkflow(args[0],eval(args[1]),)) + +elif cmd == 'getWorkflowTemplateId': + if len(args) != 1: + print 'getWorkflowTemplateId requires 1 args' + sys.exit(1) + pp.pprint(client.getWorkflowTemplateId(args[0],)) + +elif cmd == 'isWorkflowExistWithName': + if len(args) != 1: + print 'isWorkflowExistWithName requires 1 args' + sys.exit(1) + pp.pprint(client.isWorkflowExistWithName(args[0],)) + +else: + print 'Unrecognized method %s' % cmd + sys.exit(1) + +transport.close()
