http://git-wip-us.apache.org/repos/asf/airavata/blob/a513dcde/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py index aa4c456..775a246 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.2) +# Autogenerated by Thrift Compiler (0.9.3) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -7,6 +7,7 @@ # from thrift.Thrift import TType, TMessageType, TException, TApplicationException +import logging from ttypes import * from thrift.Thrift import TProcessor from thrift.transport import TTransport @@ -22,6 +23,7 @@ class Iface: """ Fetch Apache Airavata API version + Parameters: - authzToken """ @@ -29,6 +31,16 @@ class Iface: def addGateway(self, authzToken, gateway): """ + Register a Gateway with Airavata. + + @param gateway + The gateway data model. + + @return gatewayId + Th unique identifier of the newly registered gateway. + + + Parameters: - authzToken - gateway @@ -37,6 +49,16 @@ class Iface: def updateGateway(self, authzToken, gatewayId, updatedGateway): """ + Update previously registered Gateway metadata. + + @param gatewayId + The gateway Id of the Gateway which require an update. + + @return gateway + Modified gateway obejct. + + + Parameters: - authzToken - gatewayId @@ -46,6 +68,16 @@ class Iface: def getGateway(self, authzToken, gatewayId): """ + Get Gateway details by providing gatewayId + + @param gatewayId + The gateway Id of the Gateway. + + @return gateway + Gateway obejct. + + + Parameters: - authzToken - gatewayId @@ -54,6 +86,16 @@ class Iface: def deleteGateway(self, authzToken, gatewayId): """ + Delete a Gateway + + @param gatewayId + The gateway Id of the Gateway to be deleted. + + @return boolean + Boolean identifier for the success or failure of the deletion operation. + + + Parameters: - authzToken - gatewayId @@ -62,6 +104,9 @@ class Iface: def getAllGateways(self, authzToken): """ + Get All the Gateways Connected to Airavata. + + Parameters: - authzToken """ @@ -80,7 +125,7 @@ class Iface: Generate and Register SSH Key Pair with Airavata Credential Store. @param gatewayId - The identifier for the requested gateway. + The identifier for the requested Gateway. @param userName The User for which the credential should be registered. For community accounts, this user is the name of the @@ -88,7 +133,7 @@ class Iface: @return airavataCredStoreToken An SSH Key pair is generated and stored in the credential store and associated with users or community account - belonging to a gateway. + belonging to a Gateway. @@ -101,6 +146,18 @@ class Iface: def getSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ + Get a Public Key by Providing the Token + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return publicKey + + + Parameters: - authzToken - airavataCredStoreToken @@ -110,6 +167,18 @@ class Iface: def getAllUserSSHPubKeys(self, authzToken, userName): """ + Get a Public Key by Providing the Token + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return SSHpubKey + + + Parameters: - authzToken - userName @@ -118,6 +187,18 @@ class Iface: def getAllGatewaySSHPubKeys(self, authzToken, gatewayId): """ + Get all Public Keys of the Gateway + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return publicKey + + + Parameters: - authzToken - gatewayId @@ -2357,6 +2438,7 @@ class Client(Iface): """ Fetch Apache Airavata API version + Parameters: - authzToken """ @@ -2392,10 +2474,20 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAPIVersion failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAPIVersion failed: unknown result") def addGateway(self, authzToken, gateway): """ + Register a Gateway with Airavata. + + @param gateway + The gateway data model. + + @return gatewayId + Th unique identifier of the newly registered gateway. + + + Parameters: - authzToken - gateway @@ -2433,10 +2525,20 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addGateway failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addGateway failed: unknown result") def updateGateway(self, authzToken, gatewayId, updatedGateway): """ + Update previously registered Gateway metadata. + + @param gatewayId + The gateway Id of the Gateway which require an update. + + @return gateway + Modified gateway obejct. + + + Parameters: - authzToken - gatewayId @@ -2478,6 +2580,16 @@ class Client(Iface): def getGateway(self, authzToken, gatewayId): """ + Get Gateway details by providing gatewayId + + @param gatewayId + The gateway Id of the Gateway. + + @return gateway + Gateway obejct. + + + Parameters: - authzToken - gatewayId @@ -2515,10 +2627,20 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getGateway failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGateway failed: unknown result") def deleteGateway(self, authzToken, gatewayId): """ + Delete a Gateway + + @param gatewayId + The gateway Id of the Gateway to be deleted. + + @return boolean + Boolean identifier for the success or failure of the deletion operation. + + + Parameters: - authzToken - gatewayId @@ -2556,10 +2678,13 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGateway failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGateway failed: unknown result") def getAllGateways(self, authzToken): """ + Get All the Gateways Connected to Airavata. + + Parameters: - authzToken """ @@ -2595,7 +2720,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGateways failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGateways failed: unknown result") def isGatewayExist(self, authzToken, gatewayId): """ @@ -2636,14 +2761,14 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "isGatewayExist failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "isGatewayExist failed: unknown result") def generateAndRegisterSSHKeys(self, authzToken, gatewayId, userName): """ Generate and Register SSH Key Pair with Airavata Credential Store. @param gatewayId - The identifier for the requested gateway. + The identifier for the requested Gateway. @param userName The User for which the credential should be registered. For community accounts, this user is the name of the @@ -2651,7 +2776,7 @@ class Client(Iface): @return airavataCredStoreToken An SSH Key pair is generated and stored in the credential store and associated with users or community account - belonging to a gateway. + belonging to a Gateway. @@ -2692,10 +2817,22 @@ class Client(Iface): raise result.ace if result.ase is not None: raise result.ase - raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result") def getSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ + Get a Public Key by Providing the Token + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return publicKey + + + Parameters: - authzToken - airavataCredStoreToken @@ -2733,10 +2870,22 @@ class Client(Iface): raise result.ace if result.ase is not None: raise result.ase - raise TApplicationException(TApplicationException.MISSING_RESULT, "getSSHPubKey failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getSSHPubKey failed: unknown result") def getAllUserSSHPubKeys(self, authzToken, userName): """ + Get a Public Key by Providing the Token + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return SSHpubKey + + + Parameters: - authzToken - userName @@ -2772,10 +2921,22 @@ class Client(Iface): raise result.ace if result.ase is not None: raise result.ase - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllUserSSHPubKeys failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllUserSSHPubKeys failed: unknown result") def getAllGatewaySSHPubKeys(self, authzToken, gatewayId): """ + Get all Public Keys of the Gateway + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return publicKey + + + Parameters: - authzToken - gatewayId @@ -2811,7 +2972,7 @@ class Client(Iface): raise result.ace if result.ase is not None: raise result.ase - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result") def deleteSSHPubKey(self, authzToken, airavataCredStoreToken, gatewayId): """ @@ -2852,7 +3013,7 @@ class Client(Iface): raise result.ace if result.ase is not None: raise result.ase - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteSSHPubKey failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteSSHPubKey failed: unknown result") def createProject(self, authzToken, gatewayId, project): """ @@ -2905,7 +3066,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "createProject failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "createProject failed: unknown result") def updateProject(self, authzToken, projectId, updatedProject): """ @@ -2997,7 +3158,7 @@ class Client(Iface): raise result.pnfe if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getProject failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getProject failed: unknown result") def deleteProject(self, authzToken, projectId): """ @@ -3040,7 +3201,7 @@ class Client(Iface): raise result.pnfe if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteProject failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteProject failed: unknown result") def getUserProjects(self, authzToken, gatewayId, userName, limit, offset): """ @@ -3100,7 +3261,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserProjects failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserProjects failed: unknown result") def searchProjectsByProjectName(self, authzToken, gatewayId, userName, projectName, limit, offset): """ @@ -3163,7 +3324,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchProjectsByProjectName failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchProjectsByProjectName failed: unknown result") def searchProjectsByProjectDesc(self, authzToken, gatewayId, userName, description, limit, offset): """ @@ -3226,7 +3387,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchProjectsByProjectDesc failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchProjectsByProjectDesc failed: unknown result") def searchExperimentsByName(self, authzToken, gatewayId, userName, expName, limit, offset): """ @@ -3289,7 +3450,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByName failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByName failed: unknown result") def searchExperimentsByDesc(self, authzToken, gatewayId, userName, description, limit, offset): """ @@ -3352,7 +3513,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByDesc failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByDesc failed: unknown result") def searchExperimentsByApplication(self, authzToken, gatewayId, userName, applicationId, limit, offset): """ @@ -3415,7 +3576,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByApplication failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByApplication failed: unknown result") def searchExperimentsByStatus(self, authzToken, gatewayId, userName, experimentState, limit, offset): """ @@ -3478,7 +3639,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByStatus failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByStatus failed: unknown result") def searchExperimentsByCreationTime(self, authzToken, gatewayId, userName, fromTime, toTime, limit, offset): """ @@ -3545,7 +3706,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByCreationTime failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperimentsByCreationTime failed: unknown result") def searchExperiments(self, authzToken, gatewayId, userName, filters, limit, offset): """ @@ -3608,7 +3769,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperiments failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperiments failed: unknown result") def getExperimentStatistics(self, authzToken, gatewayId, fromTime, toTime): """ @@ -3662,7 +3823,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentStatistics failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentStatistics failed: unknown result") def getExperimentsInProject(self, authzToken, projectId, limit, offset): """ @@ -3719,7 +3880,7 @@ class Client(Iface): raise result.pnfe if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentsInProject failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentsInProject failed: unknown result") def getUserExperiments(self, authzToken, gatewayId, userName, limit, offset): """ @@ -3778,7 +3939,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserExperiments failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserExperiments failed: unknown result") def createExperiment(self, authzToken, gatewayId, experiment): """ @@ -3855,7 +4016,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "createExperiment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "createExperiment failed: unknown result") def deleteExperiment(self, authzToken, experimentId): """ @@ -3904,7 +4065,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteExperiment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteExperiment failed: unknown result") def getExperiment(self, authzToken, airavataExperimentId): """ @@ -3979,7 +4140,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperiment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperiment failed: unknown result") def getDetailedExperimentTree(self, authzToken, airavataExperimentId): """ @@ -4055,7 +4216,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getDetailedExperimentTree failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getDetailedExperimentTree failed: unknown result") def updateExperiment(self, authzToken, airavataExperimentId, experiment): """ @@ -4257,7 +4418,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "validateExperiment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "validateExperiment failed: unknown result") def launchExperiment(self, authzToken, airavataExperimentId, gatewayId): """ @@ -4376,7 +4537,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentStatus failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentStatus failed: unknown result") def getExperimentOutputs(self, authzToken, airavataExperimentId): """ @@ -4419,7 +4580,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentOutputs failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentOutputs failed: unknown result") def getIntermediateOutputs(self, authzToken, airavataExperimentId): """ @@ -4462,7 +4623,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getIntermediateOutputs failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getIntermediateOutputs failed: unknown result") def getJobStatuses(self, authzToken, airavataExperimentId): """ @@ -4505,7 +4666,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobStatuses failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobStatuses failed: unknown result") def getJobDetails(self, authzToken, airavataExperimentId): """ @@ -4548,7 +4709,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getJobDetails failed: unknown result") def cloneExperiment(self, authzToken, existingExperimentID, newExperimentName): """ @@ -4631,7 +4792,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "cloneExperiment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "cloneExperiment failed: unknown result") def terminateExperiment(self, authzToken, airavataExperimentId, gatewayId): """ @@ -4758,7 +4919,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerApplicationModule failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerApplicationModule failed: unknown result") def getApplicationModule(self, authzToken, appModuleId): """ @@ -4808,7 +4969,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationModule failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationModule failed: unknown result") def updateApplicationModule(self, authzToken, appModuleId, applicationModule): """ @@ -4863,7 +5024,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateApplicationModule failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateApplicationModule failed: unknown result") def getAllAppModules(self, authzToken, gatewayId): """ @@ -4904,7 +5065,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllAppModules failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllAppModules failed: unknown result") def deleteApplicationModule(self, authzToken, appModuleId): """ @@ -4954,7 +5115,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteApplicationModule failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteApplicationModule failed: unknown result") def registerApplicationDeployment(self, authzToken, gatewayId, applicationDeployment): """ @@ -5006,7 +5167,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerApplicationDeployment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerApplicationDeployment failed: unknown result") def getApplicationDeployment(self, authzToken, appDeploymentId): """ @@ -5056,7 +5217,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationDeployment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationDeployment failed: unknown result") def updateApplicationDeployment(self, authzToken, appDeploymentId, applicationDeployment): """ @@ -5111,7 +5272,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateApplicationDeployment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateApplicationDeployment failed: unknown result") def deleteApplicationDeployment(self, authzToken, appDeploymentId): """ @@ -5161,7 +5322,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteApplicationDeployment failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteApplicationDeployment failed: unknown result") def getAllApplicationDeployments(self, authzToken, gatewayId): """ @@ -5208,7 +5369,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllApplicationDeployments failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllApplicationDeployments failed: unknown result") def getAppModuleDeployedResources(self, authzToken, appModuleId): """ @@ -5258,7 +5419,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAppModuleDeployedResources failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAppModuleDeployedResources failed: unknown result") def registerApplicationInterface(self, authzToken, gatewayId, applicationInterface): """ @@ -5310,7 +5471,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerApplicationInterface failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerApplicationInterface failed: unknown result") def getApplicationInterface(self, authzToken, appInterfaceId): """ @@ -5361,7 +5522,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationInterface failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationInterface failed: unknown result") def updateApplicationInterface(self, authzToken, appInterfaceId, applicationInterface): """ @@ -5417,7 +5578,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateApplicationInterface failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateApplicationInterface failed: unknown result") def deleteApplicationInterface(self, authzToken, appInterfaceId): """ @@ -5468,7 +5629,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteApplicationInterface failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteApplicationInterface failed: unknown result") def getAllApplicationInterfaceNames(self, authzToken, gatewayId): """ @@ -5516,7 +5677,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllApplicationInterfaceNames failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllApplicationInterfaceNames failed: unknown result") def getAllApplicationInterfaces(self, authzToken, gatewayId): """ @@ -5564,7 +5725,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllApplicationInterfaces failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllApplicationInterfaces failed: unknown result") def getApplicationInputs(self, authzToken, appInterfaceId): """ @@ -5614,7 +5775,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationInputs failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationInputs failed: unknown result") def getApplicationOutputs(self, authzToken, appInterfaceId): """ @@ -5664,7 +5825,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationOutputs failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getApplicationOutputs failed: unknown result") def getAvailableAppInterfaceComputeResources(self, authzToken, appInterfaceId): """ @@ -5715,7 +5876,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAvailableAppInterfaceComputeResources failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAvailableAppInterfaceComputeResources failed: unknown result") def registerComputeResource(self, authzToken, computeResourceDescription): """ @@ -5765,7 +5926,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerComputeResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerComputeResource failed: unknown result") def getComputeResource(self, authzToken, computeResourceId): """ @@ -5815,7 +5976,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getComputeResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getComputeResource failed: unknown result") def getAllComputeResourceNames(self, authzToken): """ @@ -5860,7 +6021,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllComputeResourceNames failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllComputeResourceNames failed: unknown result") def updateComputeResource(self, authzToken, computeResourceId, computeResourceDescription): """ @@ -5915,7 +6076,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateComputeResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateComputeResource failed: unknown result") def deleteComputeResource(self, authzToken, computeResourceId): """ @@ -5965,7 +6126,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteComputeResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteComputeResource failed: unknown result") def registerStorageResource(self, authzToken, storageResourceDescription): """ @@ -6015,7 +6176,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerStorageResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerStorageResource failed: unknown result") def getStorageResource(self, authzToken, storageResourceId): """ @@ -6065,7 +6226,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getStorageResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getStorageResource failed: unknown result") def getAllStorageResourceNames(self, authzToken): """ @@ -6110,7 +6271,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllStorageResourceNames failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllStorageResourceNames failed: unknown result") def updateStorageResource(self, authzToken, storageResourceId, storageResourceDescription): """ @@ -6165,7 +6326,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateStorageResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateStorageResource failed: unknown result") def deleteStorageResource(self, authzToken, storageResourceId): """ @@ -6215,7 +6376,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteStorageResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteStorageResource failed: unknown result") def addLocalSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, localSubmission): """ @@ -6276,7 +6437,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addLocalSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addLocalSubmissionDetails failed: unknown result") def updateLocalSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, localSubmission): """ @@ -6331,7 +6492,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateLocalSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateLocalSubmissionDetails failed: unknown result") def getLocalJobSubmission(self, authzToken, jobSubmissionId): """ @@ -6378,7 +6539,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getLocalJobSubmission failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getLocalJobSubmission failed: unknown result") def addSSHJobSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, sshJobSubmission): """ @@ -6439,7 +6600,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addSSHJobSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addSSHJobSubmissionDetails failed: unknown result") def addSSHForkJobSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, sshJobSubmission): """ @@ -6500,7 +6661,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addSSHForkJobSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addSSHForkJobSubmissionDetails failed: unknown result") def getSSHJobSubmission(self, authzToken, jobSubmissionId): """ @@ -6547,7 +6708,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getSSHJobSubmission failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getSSHJobSubmission failed: unknown result") def addUNICOREJobSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, unicoreJobSubmission): """ @@ -6608,7 +6769,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addUNICOREJobSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addUNICOREJobSubmissionDetails failed: unknown result") def getUnicoreJobSubmission(self, authzToken, jobSubmissionId): """ @@ -6655,7 +6816,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnicoreJobSubmission failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnicoreJobSubmission failed: unknown result") def addCloudJobSubmissionDetails(self, authzToken, computeResourceId, priorityOrder, cloudSubmission): """ @@ -6716,7 +6877,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addCloudJobSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addCloudJobSubmissionDetails failed: unknown result") def getCloudJobSubmission(self, authzToken, jobSubmissionId): """ @@ -6763,7 +6924,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getCloudJobSubmission failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getCloudJobSubmission failed: unknown result") def updateSSHJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, sshJobSubmission): """ @@ -6818,7 +6979,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateSSHJobSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateSSHJobSubmissionDetails failed: unknown result") def updateCloudJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, sshJobSubmission): """ @@ -6873,7 +7034,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateCloudJobSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateCloudJobSubmissionDetails failed: unknown result") def updateUnicoreJobSubmissionDetails(self, authzToken, jobSubmissionInterfaceId, unicoreJobSubmission): """ @@ -6916,7 +7077,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateUnicoreJobSubmissionDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateUnicoreJobSubmissionDetails failed: unknown result") def addLocalDataMovementDetails(self, authzToken, resourceId, dataMoveType, priorityOrder, localDataMovement): """ @@ -6979,7 +7140,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addLocalDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addLocalDataMovementDetails failed: unknown result") def updateLocalDataMovementDetails(self, authzToken, dataMovementInterfaceId, localDataMovement): """ @@ -7034,7 +7195,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateLocalDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateLocalDataMovementDetails failed: unknown result") def getLocalDataMovement(self, authzToken, dataMovementId): """ @@ -7081,7 +7242,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getLocalDataMovement failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getLocalDataMovement failed: unknown result") def addSCPDataMovementDetails(self, authzToken, resourceId, dataMoveType, priorityOrder, scpDataMovement): """ @@ -7144,7 +7305,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addSCPDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addSCPDataMovementDetails failed: unknown result") def updateSCPDataMovementDetails(self, authzToken, dataMovementInterfaceId, scpDataMovement): """ @@ -7200,7 +7361,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateSCPDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateSCPDataMovementDetails failed: unknown result") def getSCPDataMovement(self, authzToken, dataMovementId): """ @@ -7247,7 +7408,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getSCPDataMovement failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getSCPDataMovement failed: unknown result") def addUnicoreDataMovementDetails(self, authzToken, resourceId, dataMoveType, priorityOrder, unicoreDataMovement): """ @@ -7294,7 +7455,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addUnicoreDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addUnicoreDataMovementDetails failed: unknown result") def updateUnicoreDataMovementDetails(self, authzToken, dataMovementInterfaceId, unicoreDataMovement): """ @@ -7337,7 +7498,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateUnicoreDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateUnicoreDataMovementDetails failed: unknown result") def getUnicoreDataMovement(self, authzToken, dataMovementId): """ @@ -7378,7 +7539,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnicoreDataMovement failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnicoreDataMovement failed: unknown result") def addGridFTPDataMovementDetails(self, authzToken, resourceId, dataMoveType, priorityOrder, gridFTPDataMovement): """ @@ -7441,7 +7602,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addGridFTPDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addGridFTPDataMovementDetails failed: unknown result") def updateGridFTPDataMovementDetails(self, authzToken, dataMovementInterfaceId, gridFTPDataMovement): """ @@ -7497,7 +7658,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGridFTPDataMovementDetails failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGridFTPDataMovementDetails failed: unknown result") def getGridFTPDataMovement(self, authzToken, dataMovementId): """ @@ -7544,7 +7705,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getGridFTPDataMovement failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGridFTPDataMovement failed: unknown result") def changeJobSubmissionPriority(self, authzToken, jobSubmissionInterfaceId, newPriorityOrder): """ @@ -7599,7 +7760,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "changeJobSubmissionPriority failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "changeJobSubmissionPriority failed: unknown result") def changeDataMovementPriority(self, authzToken, dataMovementInterfaceId, newPriorityOrder): """ @@ -7654,7 +7815,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "changeDataMovementPriority failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "changeDataMovementPriority failed: unknown result") def changeJobSubmissionPriorities(self, authzToken, jobSubmissionPriorityMap): """ @@ -7704,7 +7865,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "changeJobSubmissionPriorities failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "changeJobSubmissionPriorities failed: unknown result") def changeDataMovementPriorities(self, authzToken, dataMovementPriorityMap): """ @@ -7754,7 +7915,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "changeDataMovementPriorities failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "changeDataMovementPriorities failed: unknown result") def deleteJobSubmissionInterface(self, authzToken, computeResourceId, jobSubmissionInterfaceId): """ @@ -7806,7 +7967,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteJobSubmissionInterface failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteJobSubmissionInterface failed: unknown result") def deleteDataMovementInterface(self, authzToken, computeResourceId, dataMovementInterfaceId): """ @@ -7858,7 +8019,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteDataMovementInterface failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteDataMovementInterface failed: unknown result") def registerResourceJobManager(self, authzToken, resourceJobManager): """ @@ -7899,7 +8060,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerResourceJobManager failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerResourceJobManager failed: unknown result") def updateResourceJobManager(self, authzToken, resourceJobManagerId, updatedResourceJobManager): """ @@ -7942,7 +8103,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateResourceJobManager failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateResourceJobManager failed: unknown result") def getResourceJobManager(self, authzToken, resourceJobManagerId): """ @@ -7983,7 +8144,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getResourceJobManager failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getResourceJobManager failed: unknown result") def deleteResourceJobManager(self, authzToken, resourceJobManagerId): """ @@ -8024,7 +8185,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteResourceJobManager failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteResourceJobManager failed: unknown result") def deleteBatchQueue(self, authzToken, computeResourceId, queueName): """ @@ -8067,7 +8228,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteBatchQueue failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteBatchQueue failed: unknown result") def registerGatewayResourceProfile(self, authzToken, gatewayResourceProfile): """ @@ -8119,7 +8280,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerGatewayResourceProfile failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerGatewayResourceProfile failed: unknown result") def getGatewayResourceProfile(self, authzToken, gatewayID): """ @@ -8169,7 +8330,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayResourceProfile failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayResourceProfile failed: unknown result") def updateGatewayResourceProfile(self, authzToken, gatewayID, gatewayResourceProfile): """ @@ -8224,7 +8385,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayResourceProfile failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayResourceProfile failed: unknown result") def deleteGatewayResourceProfile(self, authzToken, gatewayID): """ @@ -8274,7 +8435,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayResourceProfile failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayResourceProfile failed: unknown result") def addGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId, computeResourcePreference): """ @@ -8335,7 +8496,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayComputeResourcePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayComputeResourcePreference failed: unknown result") def addGatewayStoragePreference(self, authzToken, gatewayID, storageResourceId, storagePreference): """ @@ -8380,7 +8541,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayStoragePreference failed: unknown result") def getGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ @@ -8435,7 +8596,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayComputeResourcePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayComputeResourcePreference failed: unknown result") def getGatewayStoragePreference(self, authzToken, gatewayID, storageResourceId): """ @@ -8478,7 +8639,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayStoragePreference failed: unknown result") def getAllGatewayComputeResourcePreferences(self, authzToken, gatewayID): """ @@ -8528,7 +8689,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayComputeResourcePreferences failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayComputeResourcePreferences failed: unknown result") def getAllGatewayStoragePreferences(self, authzToken, gatewayID): """ @@ -8569,7 +8730,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayStoragePreferences failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayStoragePreferences failed: unknown result") def getAllGatewayResourceProfiles(self, authzToken): """ @@ -8611,7 +8772,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayResourceProfiles failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayResourceProfiles failed: unknown result") def updateGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId, computeResourcePreference): """ @@ -8671,7 +8832,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayComputeResourcePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayComputeResourcePreference failed: unknown result") def updateGatewayStoragePreference(self, authzToken, gatewayID, storageId, storagePreference): """ @@ -8716,7 +8877,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayStoragePreference failed: unknown result") def deleteGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ @@ -8771,7 +8932,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayComputeResourcePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayComputeResourcePreference failed: unknown result") def deleteGatewayStoragePreference(self, authzToken, gatewayID, storageId): """ @@ -8814,7 +8975,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayStoragePreference failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayStoragePreference failed: unknown result") def getAllWorkflows(self, authzToken, gatewayId): """ @@ -8855,7 +9016,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllWorkflows failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllWorkflows failed: unknown result") def getWorkflow(self, authzToken, workflowTemplateId): """ @@ -8896,7 +9057,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getWorkflow failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getWorkflow failed: unknown result") def deleteWorkflow(self, authzToken, workflowTemplateId): """ @@ -8978,7 +9139,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerWorkflow failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerWorkflow failed: unknown result") def updateWorkflow(self, authzToken, workflowTemplateId, workflow): """ @@ -9060,7 +9221,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getWorkflowTemplateId failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getWorkflowTemplateId failed: unknown result") def isWorkflowExistWithName(self, authzToken, workflowName): """ @@ -9101,7 +9262,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "isWorkflowExistWithName failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "isWorkflowExistWithName failed: unknown result") def registerDataResource(self, authzToken, dataResourceModel): """ @@ -9145,7 +9306,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "registerDataResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "registerDataResource failed: unknown result") def updateDataResource(self, authzToken, dataResourceModel): """ @@ -9264,7 +9425,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "getDataResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getDataResource failed: unknown result") class Processor(Iface, TProcessor): @@ -9430,15 +9591,26 @@ class Processor(Iface, TProcessor): result = getAPIVersion_result() try: result.success = self._handler.getAPIVersion(args.authzToken) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("getAPIVersion", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAPIVersion", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9450,15 +9622,26 @@ class Processor(Iface, TProcessor): result = addGateway_result() try: result.success = self._handler.addGateway(args.authzToken, args.gateway) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("addGateway", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("addGateway", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9470,15 +9653,26 @@ class Processor(Iface, TProcessor): result = updateGateway_result() try: self._handler.updateGateway(args.authzToken, args.gatewayId, args.updatedGateway) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("updateGateway", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("updateGateway", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9490,15 +9684,26 @@ class Processor(Iface, TProcessor): result = getGateway_result() try: result.success = self._handler.getGateway(args.authzToken, args.gatewayId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("getGateway", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getGateway", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9510,15 +9715,26 @@ class Processor(Iface, TProcessor): result = deleteGateway_result() try: result.success = self._handler.deleteGateway(args.authzToken, args.gatewayId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("deleteGateway", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("deleteGateway", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9530,15 +9746,26 @@ class Processor(Iface, TProcessor): result = getAllGateways_result() try: result.success = self._handler.getAllGateways(args.authzToken) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("getAllGateways", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAllGateways", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9550,15 +9777,26 @@ class Processor(Iface, TProcessor): result = isGatewayExist_result() try: result.success = self._handler.isGatewayExist(args.authzToken, args.gatewayId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("isGatewayExist", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("isGatewayExist", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9570,13 +9808,23 @@ class Processor(Iface, TProcessor): result = generateAndRegisterSSHKeys_result() try: result.success = self._handler.generateAndRegisterSSHKeys(args.authzToken, args.gatewayId, args.userName) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - oprot.writeMessageBegin("generateAndRegisterSSHKeys", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("generateAndRegisterSSHKeys", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9588,13 +9836,23 @@ class Processor(Iface, TProcessor): result = getSSHPubKey_result() try: result.success = self._handler.getSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - oprot.writeMessageBegin("getSSHPubKey", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getSSHPubKey", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9606,13 +9864,23 @@ class Processor(Iface, TProcessor): result = getAllUserSSHPubKeys_result() try: result.success = self._handler.getAllUserSSHPubKeys(args.authzToken, args.userName) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - oprot.writeMessageBegin("getAllUserSSHPubKeys", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAllUserSSHPubKeys", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9624,13 +9892,23 @@ class Processor(Iface, TProcessor): result = getAllGatewaySSHPubKeys_result() try: result.success = self._handler.getAllGatewaySSHPubKeys(args.authzToken, args.gatewayId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - oprot.writeMessageBegin("getAllGatewaySSHPubKeys", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAllGatewaySSHPubKeys", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9642,13 +9920,23 @@ class Processor(Iface, TProcessor): result = deleteSSHPubKey_result() try: result.success = self._handler.deleteSSHPubKey(args.authzToken, args.airavataCredStoreToken, args.gatewayId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - oprot.writeMessageBegin("deleteSSHPubKey", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("deleteSSHPubKey", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9660,15 +9948,26 @@ class Processor(Iface, TProcessor): result = createProject_result() try: result.success = self._handler.createProject(args.authzToken, args.gatewayId, args.project) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("createProject", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("createProject", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9680,17 +9979,29 @@ class Processor(Iface, TProcessor): result = updateProject_result() try: self._handler.updateProject(args.authzToken, args.projectId, args.updatedProject) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.ProjectNotFoundException, pnfe: + except apache.airavata.api.error.ttypes.ProjectNotFoundException as pnfe: + msg_type = TMessageType.REPLY result.pnfe = pnfe - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("updateProject", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("updateProject", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9702,17 +10013,29 @@ class Processor(Iface, TProcessor): result = getProject_result() try: result.success = self._handler.getProject(args.authzToken, args.projectId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.ProjectNotFoundException, pnfe: + except apache.airavata.api.error.ttypes.ProjectNotFoundException as pnfe: + msg_type = TMessageType.REPLY result.pnfe = pnfe - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("getProject", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getProject", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -9724,17 +10047,29 @@ class Processor(Iface, TProcessor): result = deleteProject_result() try: result.success = self._handler.deleteProject(args.authzToken, args.projectId) - except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except apache.airavata.api.error.ttypes.InvalidRequestException as ire: + msg_type = TMessageType.REPLY result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException, ace: + except apache.airavata.api.error.ttypes.AiravataClientException as ace: + msg_type = TMessageType.REPLY result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + except apache.airavata.api.error.ttypes.AiravataSystemException as ase: + msg_type = TMessageType.REPLY result.ase = ase - except apache.airavata.api.error.ttypes.ProjectNotFoundException, pnfe: + except apache.airavata.api.error.ttypes.ProjectNotFoundException as pnfe: + msg_type = TMessageType.REPLY result.pnfe = pnfe - except apache.airavata.api.error.ttypes.AuthorizationException, ae: + except apache.airavata.api.error.ttypes.AuthorizationException as ae: + msg_type = TMessageType.REPLY result.ae = ae - oprot.writeMessageBegin("deleteProject", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationE
<TRUNCATED>
