You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sm...@apache.org on 2015/03/24 10:19:19 UTC
[8/8] airavata git commit: Adding python generated code -
AIRAVATA-1642
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 <sm...@apache.org>
Authored: Tue Mar 24 05:19:03 2015 -0400
Committer: Suresh Marru <sm...@apache.org>
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()