blob: 1e6a3c0bb5159004c5ab678f232c021a9bef469c [file] [log] [blame]
#!/usr/bin/env python
#
# Autogenerated by Thrift Compiler (0.9.2)
#
# 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 TSSLSocket
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]] [-s[sl]] function [arg1 [arg2...]]')
print('')
print('Functions:')
print(' string getAPIVersion(AuthzToken authzToken)')
print(' string addGateway(AuthzToken authzToken, Gateway gateway)')
print(' void updateGateway(AuthzToken authzToken, string gatewayId, Gateway updatedGateway)')
print(' Gateway getGateway(AuthzToken authzToken, string gatewayId)')
print(' bool deleteGateway(AuthzToken authzToken, string gatewayId)')
print(' getAllGateways(AuthzToken authzToken)')
print(' bool isGatewayExist(AuthzToken authzToken, string gatewayId)')
print(' string generateAndRegisterSSHKeys(AuthzToken authzToken, string gatewayId, string userName)')
print(' string getSSHPubKey(AuthzToken authzToken, string airavataCredStoreToken, string gatewayId)')
print(' getAllUserSSHPubKeys(AuthzToken authzToken, string userName)')
print(' string createProject(AuthzToken authzToken, string gatewayId, Project project)')
print(' void updateProject(AuthzToken authzToken, string projectId, Project updatedProject)')
print(' Project getProject(AuthzToken authzToken, string projectId)')
print(' bool deleteProject(AuthzToken authzToken, string projectId)')
print(' getUserProjects(AuthzToken authzToken, string gatewayId, string userName, i32 limit, i32 offset)')
print(' searchProjectsByProjectName(AuthzToken authzToken, string gatewayId, string userName, string projectName, i32 limit, i32 offset)')
print(' searchProjectsByProjectDesc(AuthzToken authzToken, string gatewayId, string userName, string description, i32 limit, i32 offset)')
print(' searchExperimentsByName(AuthzToken authzToken, string gatewayId, string userName, string expName, i32 limit, i32 offset)')
print(' searchExperimentsByDesc(AuthzToken authzToken, string gatewayId, string userName, string description, i32 limit, i32 offset)')
print(' searchExperimentsByApplication(AuthzToken authzToken, string gatewayId, string userName, string applicationId, i32 limit, i32 offset)')
print(' searchExperimentsByStatus(AuthzToken authzToken, string gatewayId, string userName, ExperimentState experimentState, i32 limit, i32 offset)')
print(' searchExperimentsByCreationTime(AuthzToken authzToken, string gatewayId, string userName, i64 fromTime, i64 toTime, i32 limit, i32 offset)')
print(' searchExperiments(AuthzToken authzToken, string gatewayId, string userName, filters, i32 limit, i32 offset)')
print(' ExperimentStatistics getExperimentStatistics(AuthzToken authzToken, string gatewayId, i64 fromTime, i64 toTime)')
print(' getExperimentsInProject(AuthzToken authzToken, string projectId, i32 limit, i32 offset)')
print(' getUserExperiments(AuthzToken authzToken, string gatewayId, string userName, i32 limit, i32 offset)')
print(' string createExperiment(AuthzToken authzToken, string gatewayId, ExperimentModel experiment)')
print(' bool deleteExperiment(AuthzToken authzToken, string experimentId)')
print(' ExperimentModel getExperiment(AuthzToken authzToken, string airavataExperimentId)')
print(' void updateExperiment(AuthzToken authzToken, string airavataExperimentId, ExperimentModel experiment)')
print(' void updateExperimentConfiguration(AuthzToken authzToken, string airavataExperimentId, UserConfigurationDataModel userConfiguration)')
print(' void updateResourceScheduleing(AuthzToken authzToken, string airavataExperimentId, ComputationalResourceSchedulingModel resourceScheduling)')
print(' bool validateExperiment(AuthzToken authzToken, string airavataExperimentId)')
print(' void launchExperiment(AuthzToken authzToken, string airavataExperimentId, string gatewayId)')
print(' ExperimentStatus getExperimentStatus(AuthzToken authzToken, string airavataExperimentId)')
print(' getExperimentOutputs(AuthzToken authzToken, string airavataExperimentId)')
print(' getIntermediateOutputs(AuthzToken authzToken, string airavataExperimentId)')
print(' getJobStatuses(AuthzToken authzToken, string airavataExperimentId)')
print(' getJobDetails(AuthzToken authzToken, string airavataExperimentId)')
print(' string cloneExperiment(AuthzToken authzToken, string existingExperimentID, string newExperimentName)')
print(' void terminateExperiment(AuthzToken authzToken, string airavataExperimentId, string gatewayId)')
print(' string registerApplicationModule(AuthzToken authzToken, string gatewayId, ApplicationModule applicationModule)')
print(' ApplicationModule getApplicationModule(AuthzToken authzToken, string appModuleId)')
print(' bool updateApplicationModule(AuthzToken authzToken, string appModuleId, ApplicationModule applicationModule)')
print(' getAllAppModules(AuthzToken authzToken, string gatewayId)')
print(' bool deleteApplicationModule(AuthzToken authzToken, string appModuleId)')
print(' string registerApplicationDeployment(AuthzToken authzToken, string gatewayId, ApplicationDeploymentDescription applicationDeployment)')
print(' ApplicationDeploymentDescription getApplicationDeployment(AuthzToken authzToken, string appDeploymentId)')
print(' bool updateApplicationDeployment(AuthzToken authzToken, string appDeploymentId, ApplicationDeploymentDescription applicationDeployment)')
print(' bool deleteApplicationDeployment(AuthzToken authzToken, string appDeploymentId)')
print(' getAllApplicationDeployments(AuthzToken authzToken, string gatewayId)')
print(' getAppModuleDeployedResources(AuthzToken authzToken, string appModuleId)')
print(' string registerApplicationInterface(AuthzToken authzToken, string gatewayId, ApplicationInterfaceDescription applicationInterface)')
print(' ApplicationInterfaceDescription getApplicationInterface(AuthzToken authzToken, string appInterfaceId)')
print(' bool updateApplicationInterface(AuthzToken authzToken, string appInterfaceId, ApplicationInterfaceDescription applicationInterface)')
print(' bool deleteApplicationInterface(AuthzToken authzToken, string appInterfaceId)')
print(' getAllApplicationInterfaceNames(AuthzToken authzToken, string gatewayId)')
print(' getAllApplicationInterfaces(AuthzToken authzToken, string gatewayId)')
print(' getApplicationInputs(AuthzToken authzToken, string appInterfaceId)')
print(' getApplicationOutputs(AuthzToken authzToken, string appInterfaceId)')
print(' getAvailableAppInterfaceComputeResources(AuthzToken authzToken, string appInterfaceId)')
print(' string registerComputeResource(AuthzToken authzToken, ComputeResourceDescription computeResourceDescription)')
print(' ComputeResourceDescription getComputeResource(AuthzToken authzToken, string computeResourceId)')
print(' getAllComputeResourceNames(AuthzToken authzToken)')
print(' bool updateComputeResource(AuthzToken authzToken, string computeResourceId, ComputeResourceDescription computeResourceDescription)')
print(' bool deleteComputeResource(AuthzToken authzToken, string computeResourceId)')
print(' string addLocalSubmissionDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, LOCALSubmission localSubmission)')
print(' bool updateLocalSubmissionDetails(AuthzToken authzToken, string jobSubmissionInterfaceId, LOCALSubmission localSubmission)')
print(' LOCALSubmission getLocalJobSubmission(AuthzToken authzToken, string jobSubmissionId)')
print(' string addSSHJobSubmissionDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, SSHJobSubmission sshJobSubmission)')
print(' string addSSHForkJobSubmissionDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, SSHJobSubmission sshJobSubmission)')
print(' SSHJobSubmission getSSHJobSubmission(AuthzToken authzToken, string jobSubmissionId)')
print(' string addUNICOREJobSubmissionDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, UnicoreJobSubmission unicoreJobSubmission)')
print(' UnicoreJobSubmission getUnicoreJobSubmission(AuthzToken authzToken, string jobSubmissionId)')
print(' string addCloudJobSubmissionDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, CloudJobSubmission cloudSubmission)')
print(' CloudJobSubmission getCloudJobSubmission(AuthzToken authzToken, string jobSubmissionId)')
print(' bool updateSSHJobSubmissionDetails(AuthzToken authzToken, string jobSubmissionInterfaceId, SSHJobSubmission sshJobSubmission)')
print(' bool updateCloudJobSubmissionDetails(AuthzToken authzToken, string jobSubmissionInterfaceId, CloudJobSubmission sshJobSubmission)')
print(' bool updateUnicoreJobSubmissionDetails(AuthzToken authzToken, string jobSubmissionInterfaceId, UnicoreJobSubmission unicoreJobSubmission)')
print(' string addLocalDataMovementDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, LOCALDataMovement localDataMovement)')
print(' bool updateLocalDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, LOCALDataMovement localDataMovement)')
print(' LOCALDataMovement getLocalDataMovement(AuthzToken authzToken, string dataMovementId)')
print(' string addSCPDataMovementDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, SCPDataMovement scpDataMovement)')
print(' bool updateSCPDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, SCPDataMovement scpDataMovement)')
print(' SCPDataMovement getSCPDataMovement(AuthzToken authzToken, string dataMovementId)')
print(' string addUnicoreDataMovementDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, UnicoreDataMovement unicoreDataMovement)')
print(' bool updateUnicoreDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, UnicoreDataMovement unicoreDataMovement)')
print(' UnicoreDataMovement getUnicoreDataMovement(AuthzToken authzToken, string dataMovementId)')
print(' string addGridFTPDataMovementDetails(AuthzToken authzToken, string computeResourceId, i32 priorityOrder, GridFTPDataMovement gridFTPDataMovement)')
print(' bool updateGridFTPDataMovementDetails(AuthzToken authzToken, string dataMovementInterfaceId, GridFTPDataMovement gridFTPDataMovement)')
print(' GridFTPDataMovement getGridFTPDataMovement(AuthzToken authzToken, string dataMovementId)')
print(' bool changeJobSubmissionPriority(AuthzToken authzToken, string jobSubmissionInterfaceId, i32 newPriorityOrder)')
print(' bool changeDataMovementPriority(AuthzToken authzToken, string dataMovementInterfaceId, i32 newPriorityOrder)')
print(' bool changeJobSubmissionPriorities(AuthzToken authzToken, jobSubmissionPriorityMap)')
print(' bool changeDataMovementPriorities(AuthzToken authzToken, dataMovementPriorityMap)')
print(' bool deleteJobSubmissionInterface(AuthzToken authzToken, string computeResourceId, string jobSubmissionInterfaceId)')
print(' bool deleteDataMovementInterface(AuthzToken authzToken, string computeResourceId, string dataMovementInterfaceId)')
print(' string registerResourceJobManager(AuthzToken authzToken, ResourceJobManager resourceJobManager)')
print(' bool updateResourceJobManager(AuthzToken authzToken, string resourceJobManagerId, ResourceJobManager updatedResourceJobManager)')
print(' ResourceJobManager getResourceJobManager(AuthzToken authzToken, string resourceJobManagerId)')
print(' bool deleteResourceJobManager(AuthzToken authzToken, string resourceJobManagerId)')
print(' bool deleteBatchQueue(AuthzToken authzToken, string computeResourceId, string queueName)')
print(' string registerGatewayResourceProfile(AuthzToken authzToken, GatewayResourceProfile gatewayResourceProfile)')
print(' GatewayResourceProfile getGatewayResourceProfile(AuthzToken authzToken, string gatewayID)')
print(' bool updateGatewayResourceProfile(AuthzToken authzToken, string gatewayID, GatewayResourceProfile gatewayResourceProfile)')
print(' bool deleteGatewayResourceProfile(AuthzToken authzToken, string gatewayID)')
print(' bool addGatewayComputeResourcePreference(AuthzToken authzToken, string gatewayID, string computeResourceId, ComputeResourcePreference computeResourcePreference)')
print(' bool addGatewayDataStoragePreference(AuthzToken authzToken, string gatewayID, string dataMoveId, DataStoragePreference dataStoragePreference)')
print(' ComputeResourcePreference getGatewayComputeResourcePreference(AuthzToken authzToken, string gatewayID, string computeResourceId)')
print(' DataStoragePreference getGatewayDataStoragePreference(AuthzToken authzToken, string gatewayID, string dataMoveId)')
print(' getAllGatewayComputeResourcePreferences(AuthzToken authzToken, string gatewayID)')
print(' getAllGatewayDataStoragePreferences(AuthzToken authzToken, string gatewayID)')
print(' getAllGatewayResourceProfiles(AuthzToken authzToken)')
print(' bool updateGatewayComputeResourcePreference(AuthzToken authzToken, string gatewayID, string computeResourceId, ComputeResourcePreference computeResourcePreference)')
print(' bool updateGatewayDataStoragePreference(AuthzToken authzToken, string gatewayID, string dataMoveId, DataStoragePreference dataStoragePreference)')
print(' bool deleteGatewayComputeResourcePreference(AuthzToken authzToken, string gatewayID, string computeResourceId)')
print(' bool deleteGatewayDataStoragePreference(AuthzToken authzToken, string gatewayID, string dataMoveId)')
print(' getAllWorkflows(AuthzToken authzToken, string gatewayId)')
print(' Workflow getWorkflow(AuthzToken authzToken, string workflowTemplateId)')
print(' void deleteWorkflow(AuthzToken authzToken, string workflowTemplateId)')
print(' string registerWorkflow(AuthzToken authzToken, string gatewayId, Workflow workflow)')
print(' void updateWorkflow(AuthzToken authzToken, string workflowTemplateId, Workflow workflow)')
print(' string getWorkflowTemplateId(AuthzToken authzToken, string workflowName)')
print(' bool isWorkflowExistWithName(AuthzToken authzToken, string workflowName)')
print('')
sys.exit(0)
pp = pprint.PrettyPrinter(indent = 2)
host = 'localhost'
port = 9090
uri = ''
framed = False
ssl = 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
if sys.argv[argi] == '-s' or sys.argv[argi] == '-ssl':
ssl = True
argi += 1
cmd = sys.argv[argi]
args = sys.argv[argi+1:]
if http:
transport = THttpClient.THttpClient(host, port, uri)
else:
socket = TSSLSocket.TSSLSocket(host, port, validate=False) if ssl else 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) != 1:
print('getAPIVersion requires 1 args')
sys.exit(1)
pp.pprint(client.getAPIVersion(eval(args[0]),))
elif cmd == 'addGateway':
if len(args) != 2:
print('addGateway requires 2 args')
sys.exit(1)
pp.pprint(client.addGateway(eval(args[0]),eval(args[1]),))
elif cmd == 'updateGateway':
if len(args) != 3:
print('updateGateway requires 3 args')
sys.exit(1)
pp.pprint(client.updateGateway(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getGateway':
if len(args) != 2:
print('getGateway requires 2 args')
sys.exit(1)
pp.pprint(client.getGateway(eval(args[0]),args[1],))
elif cmd == 'deleteGateway':
if len(args) != 2:
print('deleteGateway requires 2 args')
sys.exit(1)
pp.pprint(client.deleteGateway(eval(args[0]),args[1],))
elif cmd == 'getAllGateways':
if len(args) != 1:
print('getAllGateways requires 1 args')
sys.exit(1)
pp.pprint(client.getAllGateways(eval(args[0]),))
elif cmd == 'isGatewayExist':
if len(args) != 2:
print('isGatewayExist requires 2 args')
sys.exit(1)
pp.pprint(client.isGatewayExist(eval(args[0]),args[1],))
elif cmd == 'generateAndRegisterSSHKeys':
if len(args) != 3:
print('generateAndRegisterSSHKeys requires 3 args')
sys.exit(1)
pp.pprint(client.generateAndRegisterSSHKeys(eval(args[0]),args[1],args[2],))
elif cmd == 'getSSHPubKey':
if len(args) != 3:
print('getSSHPubKey requires 3 args')
sys.exit(1)
pp.pprint(client.getSSHPubKey(eval(args[0]),args[1],args[2],))
elif cmd == 'getAllUserSSHPubKeys':
if len(args) != 2:
print('getAllUserSSHPubKeys requires 2 args')
sys.exit(1)
pp.pprint(client.getAllUserSSHPubKeys(eval(args[0]),args[1],))
elif cmd == 'createProject':
if len(args) != 3:
print('createProject requires 3 args')
sys.exit(1)
pp.pprint(client.createProject(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'updateProject':
if len(args) != 3:
print('updateProject requires 3 args')
sys.exit(1)
pp.pprint(client.updateProject(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getProject':
if len(args) != 2:
print('getProject requires 2 args')
sys.exit(1)
pp.pprint(client.getProject(eval(args[0]),args[1],))
elif cmd == 'deleteProject':
if len(args) != 2:
print('deleteProject requires 2 args')
sys.exit(1)
pp.pprint(client.deleteProject(eval(args[0]),args[1],))
elif cmd == 'getUserProjects':
if len(args) != 5:
print('getUserProjects requires 5 args')
sys.exit(1)
pp.pprint(client.getUserProjects(eval(args[0]),args[1],args[2],eval(args[3]),eval(args[4]),))
elif cmd == 'searchProjectsByProjectName':
if len(args) != 6:
print('searchProjectsByProjectName requires 6 args')
sys.exit(1)
pp.pprint(client.searchProjectsByProjectName(eval(args[0]),args[1],args[2],args[3],eval(args[4]),eval(args[5]),))
elif cmd == 'searchProjectsByProjectDesc':
if len(args) != 6:
print('searchProjectsByProjectDesc requires 6 args')
sys.exit(1)
pp.pprint(client.searchProjectsByProjectDesc(eval(args[0]),args[1],args[2],args[3],eval(args[4]),eval(args[5]),))
elif cmd == 'searchExperimentsByName':
if len(args) != 6:
print('searchExperimentsByName requires 6 args')
sys.exit(1)
pp.pprint(client.searchExperimentsByName(eval(args[0]),args[1],args[2],args[3],eval(args[4]),eval(args[5]),))
elif cmd == 'searchExperimentsByDesc':
if len(args) != 6:
print('searchExperimentsByDesc requires 6 args')
sys.exit(1)
pp.pprint(client.searchExperimentsByDesc(eval(args[0]),args[1],args[2],args[3],eval(args[4]),eval(args[5]),))
elif cmd == 'searchExperimentsByApplication':
if len(args) != 6:
print('searchExperimentsByApplication requires 6 args')
sys.exit(1)
pp.pprint(client.searchExperimentsByApplication(eval(args[0]),args[1],args[2],args[3],eval(args[4]),eval(args[5]),))
elif cmd == 'searchExperimentsByStatus':
if len(args) != 6:
print('searchExperimentsByStatus requires 6 args')
sys.exit(1)
pp.pprint(client.searchExperimentsByStatus(eval(args[0]),args[1],args[2],eval(args[3]),eval(args[4]),eval(args[5]),))
elif cmd == 'searchExperimentsByCreationTime':
if len(args) != 7:
print('searchExperimentsByCreationTime requires 7 args')
sys.exit(1)
pp.pprint(client.searchExperimentsByCreationTime(eval(args[0]),args[1],args[2],eval(args[3]),eval(args[4]),eval(args[5]),eval(args[6]),))
elif cmd == 'searchExperiments':
if len(args) != 6:
print('searchExperiments requires 6 args')
sys.exit(1)
pp.pprint(client.searchExperiments(eval(args[0]),args[1],args[2],eval(args[3]),eval(args[4]),eval(args[5]),))
elif cmd == 'getExperimentStatistics':
if len(args) != 4:
print('getExperimentStatistics requires 4 args')
sys.exit(1)
pp.pprint(client.getExperimentStatistics(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'getExperimentsInProject':
if len(args) != 4:
print('getExperimentsInProject requires 4 args')
sys.exit(1)
pp.pprint(client.getExperimentsInProject(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'getUserExperiments':
if len(args) != 5:
print('getUserExperiments requires 5 args')
sys.exit(1)
pp.pprint(client.getUserExperiments(eval(args[0]),args[1],args[2],eval(args[3]),eval(args[4]),))
elif cmd == 'createExperiment':
if len(args) != 3:
print('createExperiment requires 3 args')
sys.exit(1)
pp.pprint(client.createExperiment(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'deleteExperiment':
if len(args) != 2:
print('deleteExperiment requires 2 args')
sys.exit(1)
pp.pprint(client.deleteExperiment(eval(args[0]),args[1],))
elif cmd == 'getExperiment':
if len(args) != 2:
print('getExperiment requires 2 args')
sys.exit(1)
pp.pprint(client.getExperiment(eval(args[0]),args[1],))
elif cmd == 'updateExperiment':
if len(args) != 3:
print('updateExperiment requires 3 args')
sys.exit(1)
pp.pprint(client.updateExperiment(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'updateExperimentConfiguration':
if len(args) != 3:
print('updateExperimentConfiguration requires 3 args')
sys.exit(1)
pp.pprint(client.updateExperimentConfiguration(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'updateResourceScheduleing':
if len(args) != 3:
print('updateResourceScheduleing requires 3 args')
sys.exit(1)
pp.pprint(client.updateResourceScheduleing(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'validateExperiment':
if len(args) != 2:
print('validateExperiment requires 2 args')
sys.exit(1)
pp.pprint(client.validateExperiment(eval(args[0]),args[1],))
elif cmd == 'launchExperiment':
if len(args) != 3:
print('launchExperiment requires 3 args')
sys.exit(1)
pp.pprint(client.launchExperiment(eval(args[0]),args[1],args[2],))
elif cmd == 'getExperimentStatus':
if len(args) != 2:
print('getExperimentStatus requires 2 args')
sys.exit(1)
pp.pprint(client.getExperimentStatus(eval(args[0]),args[1],))
elif cmd == 'getExperimentOutputs':
if len(args) != 2:
print('getExperimentOutputs requires 2 args')
sys.exit(1)
pp.pprint(client.getExperimentOutputs(eval(args[0]),args[1],))
elif cmd == 'getIntermediateOutputs':
if len(args) != 2:
print('getIntermediateOutputs requires 2 args')
sys.exit(1)
pp.pprint(client.getIntermediateOutputs(eval(args[0]),args[1],))
elif cmd == 'getJobStatuses':
if len(args) != 2:
print('getJobStatuses requires 2 args')
sys.exit(1)
pp.pprint(client.getJobStatuses(eval(args[0]),args[1],))
elif cmd == 'getJobDetails':
if len(args) != 2:
print('getJobDetails requires 2 args')
sys.exit(1)
pp.pprint(client.getJobDetails(eval(args[0]),args[1],))
elif cmd == 'cloneExperiment':
if len(args) != 3:
print('cloneExperiment requires 3 args')
sys.exit(1)
pp.pprint(client.cloneExperiment(eval(args[0]),args[1],args[2],))
elif cmd == 'terminateExperiment':
if len(args) != 3:
print('terminateExperiment requires 3 args')
sys.exit(1)
pp.pprint(client.terminateExperiment(eval(args[0]),args[1],args[2],))
elif cmd == 'registerApplicationModule':
if len(args) != 3:
print('registerApplicationModule requires 3 args')
sys.exit(1)
pp.pprint(client.registerApplicationModule(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getApplicationModule':
if len(args) != 2:
print('getApplicationModule requires 2 args')
sys.exit(1)
pp.pprint(client.getApplicationModule(eval(args[0]),args[1],))
elif cmd == 'updateApplicationModule':
if len(args) != 3:
print('updateApplicationModule requires 3 args')
sys.exit(1)
pp.pprint(client.updateApplicationModule(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getAllAppModules':
if len(args) != 2:
print('getAllAppModules requires 2 args')
sys.exit(1)
pp.pprint(client.getAllAppModules(eval(args[0]),args[1],))
elif cmd == 'deleteApplicationModule':
if len(args) != 2:
print('deleteApplicationModule requires 2 args')
sys.exit(1)
pp.pprint(client.deleteApplicationModule(eval(args[0]),args[1],))
elif cmd == 'registerApplicationDeployment':
if len(args) != 3:
print('registerApplicationDeployment requires 3 args')
sys.exit(1)
pp.pprint(client.registerApplicationDeployment(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getApplicationDeployment':
if len(args) != 2:
print('getApplicationDeployment requires 2 args')
sys.exit(1)
pp.pprint(client.getApplicationDeployment(eval(args[0]),args[1],))
elif cmd == 'updateApplicationDeployment':
if len(args) != 3:
print('updateApplicationDeployment requires 3 args')
sys.exit(1)
pp.pprint(client.updateApplicationDeployment(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'deleteApplicationDeployment':
if len(args) != 2:
print('deleteApplicationDeployment requires 2 args')
sys.exit(1)
pp.pprint(client.deleteApplicationDeployment(eval(args[0]),args[1],))
elif cmd == 'getAllApplicationDeployments':
if len(args) != 2:
print('getAllApplicationDeployments requires 2 args')
sys.exit(1)
pp.pprint(client.getAllApplicationDeployments(eval(args[0]),args[1],))
elif cmd == 'getAppModuleDeployedResources':
if len(args) != 2:
print('getAppModuleDeployedResources requires 2 args')
sys.exit(1)
pp.pprint(client.getAppModuleDeployedResources(eval(args[0]),args[1],))
elif cmd == 'registerApplicationInterface':
if len(args) != 3:
print('registerApplicationInterface requires 3 args')
sys.exit(1)
pp.pprint(client.registerApplicationInterface(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getApplicationInterface':
if len(args) != 2:
print('getApplicationInterface requires 2 args')
sys.exit(1)
pp.pprint(client.getApplicationInterface(eval(args[0]),args[1],))
elif cmd == 'updateApplicationInterface':
if len(args) != 3:
print('updateApplicationInterface requires 3 args')
sys.exit(1)
pp.pprint(client.updateApplicationInterface(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'deleteApplicationInterface':
if len(args) != 2:
print('deleteApplicationInterface requires 2 args')
sys.exit(1)
pp.pprint(client.deleteApplicationInterface(eval(args[0]),args[1],))
elif cmd == 'getAllApplicationInterfaceNames':
if len(args) != 2:
print('getAllApplicationInterfaceNames requires 2 args')
sys.exit(1)
pp.pprint(client.getAllApplicationInterfaceNames(eval(args[0]),args[1],))
elif cmd == 'getAllApplicationInterfaces':
if len(args) != 2:
print('getAllApplicationInterfaces requires 2 args')
sys.exit(1)
pp.pprint(client.getAllApplicationInterfaces(eval(args[0]),args[1],))
elif cmd == 'getApplicationInputs':
if len(args) != 2:
print('getApplicationInputs requires 2 args')
sys.exit(1)
pp.pprint(client.getApplicationInputs(eval(args[0]),args[1],))
elif cmd == 'getApplicationOutputs':
if len(args) != 2:
print('getApplicationOutputs requires 2 args')
sys.exit(1)
pp.pprint(client.getApplicationOutputs(eval(args[0]),args[1],))
elif cmd == 'getAvailableAppInterfaceComputeResources':
if len(args) != 2:
print('getAvailableAppInterfaceComputeResources requires 2 args')
sys.exit(1)
pp.pprint(client.getAvailableAppInterfaceComputeResources(eval(args[0]),args[1],))
elif cmd == 'registerComputeResource':
if len(args) != 2:
print('registerComputeResource requires 2 args')
sys.exit(1)
pp.pprint(client.registerComputeResource(eval(args[0]),eval(args[1]),))
elif cmd == 'getComputeResource':
if len(args) != 2:
print('getComputeResource requires 2 args')
sys.exit(1)
pp.pprint(client.getComputeResource(eval(args[0]),args[1],))
elif cmd == 'getAllComputeResourceNames':
if len(args) != 1:
print('getAllComputeResourceNames requires 1 args')
sys.exit(1)
pp.pprint(client.getAllComputeResourceNames(eval(args[0]),))
elif cmd == 'updateComputeResource':
if len(args) != 3:
print('updateComputeResource requires 3 args')
sys.exit(1)
pp.pprint(client.updateComputeResource(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'deleteComputeResource':
if len(args) != 2:
print('deleteComputeResource requires 2 args')
sys.exit(1)
pp.pprint(client.deleteComputeResource(eval(args[0]),args[1],))
elif cmd == 'addLocalSubmissionDetails':
if len(args) != 4:
print('addLocalSubmissionDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addLocalSubmissionDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'updateLocalSubmissionDetails':
if len(args) != 3:
print('updateLocalSubmissionDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateLocalSubmissionDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getLocalJobSubmission':
if len(args) != 2:
print('getLocalJobSubmission requires 2 args')
sys.exit(1)
pp.pprint(client.getLocalJobSubmission(eval(args[0]),args[1],))
elif cmd == 'addSSHJobSubmissionDetails':
if len(args) != 4:
print('addSSHJobSubmissionDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addSSHJobSubmissionDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'addSSHForkJobSubmissionDetails':
if len(args) != 4:
print('addSSHForkJobSubmissionDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addSSHForkJobSubmissionDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'getSSHJobSubmission':
if len(args) != 2:
print('getSSHJobSubmission requires 2 args')
sys.exit(1)
pp.pprint(client.getSSHJobSubmission(eval(args[0]),args[1],))
elif cmd == 'addUNICOREJobSubmissionDetails':
if len(args) != 4:
print('addUNICOREJobSubmissionDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addUNICOREJobSubmissionDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'getUnicoreJobSubmission':
if len(args) != 2:
print('getUnicoreJobSubmission requires 2 args')
sys.exit(1)
pp.pprint(client.getUnicoreJobSubmission(eval(args[0]),args[1],))
elif cmd == 'addCloudJobSubmissionDetails':
if len(args) != 4:
print('addCloudJobSubmissionDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addCloudJobSubmissionDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'getCloudJobSubmission':
if len(args) != 2:
print('getCloudJobSubmission requires 2 args')
sys.exit(1)
pp.pprint(client.getCloudJobSubmission(eval(args[0]),args[1],))
elif cmd == 'updateSSHJobSubmissionDetails':
if len(args) != 3:
print('updateSSHJobSubmissionDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateSSHJobSubmissionDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'updateCloudJobSubmissionDetails':
if len(args) != 3:
print('updateCloudJobSubmissionDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateCloudJobSubmissionDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'updateUnicoreJobSubmissionDetails':
if len(args) != 3:
print('updateUnicoreJobSubmissionDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateUnicoreJobSubmissionDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'addLocalDataMovementDetails':
if len(args) != 4:
print('addLocalDataMovementDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addLocalDataMovementDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'updateLocalDataMovementDetails':
if len(args) != 3:
print('updateLocalDataMovementDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateLocalDataMovementDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getLocalDataMovement':
if len(args) != 2:
print('getLocalDataMovement requires 2 args')
sys.exit(1)
pp.pprint(client.getLocalDataMovement(eval(args[0]),args[1],))
elif cmd == 'addSCPDataMovementDetails':
if len(args) != 4:
print('addSCPDataMovementDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addSCPDataMovementDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'updateSCPDataMovementDetails':
if len(args) != 3:
print('updateSCPDataMovementDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateSCPDataMovementDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getSCPDataMovement':
if len(args) != 2:
print('getSCPDataMovement requires 2 args')
sys.exit(1)
pp.pprint(client.getSCPDataMovement(eval(args[0]),args[1],))
elif cmd == 'addUnicoreDataMovementDetails':
if len(args) != 4:
print('addUnicoreDataMovementDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addUnicoreDataMovementDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'updateUnicoreDataMovementDetails':
if len(args) != 3:
print('updateUnicoreDataMovementDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateUnicoreDataMovementDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getUnicoreDataMovement':
if len(args) != 2:
print('getUnicoreDataMovement requires 2 args')
sys.exit(1)
pp.pprint(client.getUnicoreDataMovement(eval(args[0]),args[1],))
elif cmd == 'addGridFTPDataMovementDetails':
if len(args) != 4:
print('addGridFTPDataMovementDetails requires 4 args')
sys.exit(1)
pp.pprint(client.addGridFTPDataMovementDetails(eval(args[0]),args[1],eval(args[2]),eval(args[3]),))
elif cmd == 'updateGridFTPDataMovementDetails':
if len(args) != 3:
print('updateGridFTPDataMovementDetails requires 3 args')
sys.exit(1)
pp.pprint(client.updateGridFTPDataMovementDetails(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getGridFTPDataMovement':
if len(args) != 2:
print('getGridFTPDataMovement requires 2 args')
sys.exit(1)
pp.pprint(client.getGridFTPDataMovement(eval(args[0]),args[1],))
elif cmd == 'changeJobSubmissionPriority':
if len(args) != 3:
print('changeJobSubmissionPriority requires 3 args')
sys.exit(1)
pp.pprint(client.changeJobSubmissionPriority(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'changeDataMovementPriority':
if len(args) != 3:
print('changeDataMovementPriority requires 3 args')
sys.exit(1)
pp.pprint(client.changeDataMovementPriority(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'changeJobSubmissionPriorities':
if len(args) != 2:
print('changeJobSubmissionPriorities requires 2 args')
sys.exit(1)
pp.pprint(client.changeJobSubmissionPriorities(eval(args[0]),eval(args[1]),))
elif cmd == 'changeDataMovementPriorities':
if len(args) != 2:
print('changeDataMovementPriorities requires 2 args')
sys.exit(1)
pp.pprint(client.changeDataMovementPriorities(eval(args[0]),eval(args[1]),))
elif cmd == 'deleteJobSubmissionInterface':
if len(args) != 3:
print('deleteJobSubmissionInterface requires 3 args')
sys.exit(1)
pp.pprint(client.deleteJobSubmissionInterface(eval(args[0]),args[1],args[2],))
elif cmd == 'deleteDataMovementInterface':
if len(args) != 3:
print('deleteDataMovementInterface requires 3 args')
sys.exit(1)
pp.pprint(client.deleteDataMovementInterface(eval(args[0]),args[1],args[2],))
elif cmd == 'registerResourceJobManager':
if len(args) != 2:
print('registerResourceJobManager requires 2 args')
sys.exit(1)
pp.pprint(client.registerResourceJobManager(eval(args[0]),eval(args[1]),))
elif cmd == 'updateResourceJobManager':
if len(args) != 3:
print('updateResourceJobManager requires 3 args')
sys.exit(1)
pp.pprint(client.updateResourceJobManager(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getResourceJobManager':
if len(args) != 2:
print('getResourceJobManager requires 2 args')
sys.exit(1)
pp.pprint(client.getResourceJobManager(eval(args[0]),args[1],))
elif cmd == 'deleteResourceJobManager':
if len(args) != 2:
print('deleteResourceJobManager requires 2 args')
sys.exit(1)
pp.pprint(client.deleteResourceJobManager(eval(args[0]),args[1],))
elif cmd == 'deleteBatchQueue':
if len(args) != 3:
print('deleteBatchQueue requires 3 args')
sys.exit(1)
pp.pprint(client.deleteBatchQueue(eval(args[0]),args[1],args[2],))
elif cmd == 'registerGatewayResourceProfile':
if len(args) != 2:
print('registerGatewayResourceProfile requires 2 args')
sys.exit(1)
pp.pprint(client.registerGatewayResourceProfile(eval(args[0]),eval(args[1]),))
elif cmd == 'getGatewayResourceProfile':
if len(args) != 2:
print('getGatewayResourceProfile requires 2 args')
sys.exit(1)
pp.pprint(client.getGatewayResourceProfile(eval(args[0]),args[1],))
elif cmd == 'updateGatewayResourceProfile':
if len(args) != 3:
print('updateGatewayResourceProfile requires 3 args')
sys.exit(1)
pp.pprint(client.updateGatewayResourceProfile(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'deleteGatewayResourceProfile':
if len(args) != 2:
print('deleteGatewayResourceProfile requires 2 args')
sys.exit(1)
pp.pprint(client.deleteGatewayResourceProfile(eval(args[0]),args[1],))
elif cmd == 'addGatewayComputeResourcePreference':
if len(args) != 4:
print('addGatewayComputeResourcePreference requires 4 args')
sys.exit(1)
pp.pprint(client.addGatewayComputeResourcePreference(eval(args[0]),args[1],args[2],eval(args[3]),))
elif cmd == 'addGatewayDataStoragePreference':
if len(args) != 4:
print('addGatewayDataStoragePreference requires 4 args')
sys.exit(1)
pp.pprint(client.addGatewayDataStoragePreference(eval(args[0]),args[1],args[2],eval(args[3]),))
elif cmd == 'getGatewayComputeResourcePreference':
if len(args) != 3:
print('getGatewayComputeResourcePreference requires 3 args')
sys.exit(1)
pp.pprint(client.getGatewayComputeResourcePreference(eval(args[0]),args[1],args[2],))
elif cmd == 'getGatewayDataStoragePreference':
if len(args) != 3:
print('getGatewayDataStoragePreference requires 3 args')
sys.exit(1)
pp.pprint(client.getGatewayDataStoragePreference(eval(args[0]),args[1],args[2],))
elif cmd == 'getAllGatewayComputeResourcePreferences':
if len(args) != 2:
print('getAllGatewayComputeResourcePreferences requires 2 args')
sys.exit(1)
pp.pprint(client.getAllGatewayComputeResourcePreferences(eval(args[0]),args[1],))
elif cmd == 'getAllGatewayDataStoragePreferences':
if len(args) != 2:
print('getAllGatewayDataStoragePreferences requires 2 args')
sys.exit(1)
pp.pprint(client.getAllGatewayDataStoragePreferences(eval(args[0]),args[1],))
elif cmd == 'getAllGatewayResourceProfiles':
if len(args) != 1:
print('getAllGatewayResourceProfiles requires 1 args')
sys.exit(1)
pp.pprint(client.getAllGatewayResourceProfiles(eval(args[0]),))
elif cmd == 'updateGatewayComputeResourcePreference':
if len(args) != 4:
print('updateGatewayComputeResourcePreference requires 4 args')
sys.exit(1)
pp.pprint(client.updateGatewayComputeResourcePreference(eval(args[0]),args[1],args[2],eval(args[3]),))
elif cmd == 'updateGatewayDataStoragePreference':
if len(args) != 4:
print('updateGatewayDataStoragePreference requires 4 args')
sys.exit(1)
pp.pprint(client.updateGatewayDataStoragePreference(eval(args[0]),args[1],args[2],eval(args[3]),))
elif cmd == 'deleteGatewayComputeResourcePreference':
if len(args) != 3:
print('deleteGatewayComputeResourcePreference requires 3 args')
sys.exit(1)
pp.pprint(client.deleteGatewayComputeResourcePreference(eval(args[0]),args[1],args[2],))
elif cmd == 'deleteGatewayDataStoragePreference':
if len(args) != 3:
print('deleteGatewayDataStoragePreference requires 3 args')
sys.exit(1)
pp.pprint(client.deleteGatewayDataStoragePreference(eval(args[0]),args[1],args[2],))
elif cmd == 'getAllWorkflows':
if len(args) != 2:
print('getAllWorkflows requires 2 args')
sys.exit(1)
pp.pprint(client.getAllWorkflows(eval(args[0]),args[1],))
elif cmd == 'getWorkflow':
if len(args) != 2:
print('getWorkflow requires 2 args')
sys.exit(1)
pp.pprint(client.getWorkflow(eval(args[0]),args[1],))
elif cmd == 'deleteWorkflow':
if len(args) != 2:
print('deleteWorkflow requires 2 args')
sys.exit(1)
pp.pprint(client.deleteWorkflow(eval(args[0]),args[1],))
elif cmd == 'registerWorkflow':
if len(args) != 3:
print('registerWorkflow requires 3 args')
sys.exit(1)
pp.pprint(client.registerWorkflow(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'updateWorkflow':
if len(args) != 3:
print('updateWorkflow requires 3 args')
sys.exit(1)
pp.pprint(client.updateWorkflow(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getWorkflowTemplateId':
if len(args) != 2:
print('getWorkflowTemplateId requires 2 args')
sys.exit(1)
pp.pprint(client.getWorkflowTemplateId(eval(args[0]),args[1],))
elif cmd == 'isWorkflowExistWithName':
if len(args) != 2:
print('isWorkflowExistWithName requires 2 args')
sys.exit(1)
pp.pprint(client.isWorkflowExistWithName(eval(args[0]),args[1],))
else:
print('Unrecognized method %s' % cmd)
sys.exit(1)
transport.close()