http://git-wip-us.apache.org/repos/asf/airavata/blob/b490671e/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 ec02e28..81d711f 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 @@ -2715,7 +2716,7 @@ 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): """ @@ -2766,7 +2767,7 @@ 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): """ @@ -2870,7 +2871,7 @@ 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): """ @@ -2921,7 +2922,7 @@ 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): """ @@ -2963,7 +2964,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): """ @@ -3017,7 +3018,7 @@ 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): """ @@ -3073,7 +3074,7 @@ 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): """ @@ -3126,7 +3127,7 @@ 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): """ @@ -3177,7 +3178,7 @@ 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): """ @@ -3228,7 +3229,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): """ @@ -3279,7 +3280,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): """ @@ -3333,7 +3334,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): """ @@ -3440,7 +3441,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): """ @@ -3494,7 +3495,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): """ @@ -3558,7 +3559,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): """ @@ -3622,7 +3623,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): """ @@ -3686,7 +3687,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): """ @@ -3750,7 +3751,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): """ @@ -3814,7 +3815,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): """ @@ -3878,7 +3879,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): """ @@ -3942,7 +3943,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): """ @@ -4010,7 +4011,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): """ @@ -4074,7 +4075,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): """ @@ -4128,7 +4129,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): """ @@ -4186,7 +4187,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): """ @@ -4246,7 +4247,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): """ @@ -4324,7 +4325,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): """ @@ -4379,7 +4380,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): """ @@ -4455,7 +4456,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): """ @@ -4531,7 +4532,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): """ @@ -4736,7 +4737,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): """ @@ -4869,7 +4870,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): """ @@ -4925,7 +4926,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): """ @@ -4981,7 +4982,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): """ @@ -5037,7 +5038,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): """ @@ -5093,7 +5094,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): """ @@ -5176,7 +5177,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): """ @@ -5303,7 +5304,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): """ @@ -5353,7 +5354,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): """ @@ -5408,7 +5409,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): """ @@ -5449,7 +5450,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): """ @@ -5499,7 +5500,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): """ @@ -5551,7 +5552,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): """ @@ -5601,7 +5602,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): """ @@ -5656,7 +5657,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): """ @@ -5706,7 +5707,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): """ @@ -5753,7 +5754,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): """ @@ -5803,7 +5804,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): """ @@ -5855,7 +5856,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): """ @@ -5906,7 +5907,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): """ @@ -5962,7 +5963,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): """ @@ -6013,7 +6014,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): """ @@ -6061,7 +6062,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): """ @@ -6109,7 +6110,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): """ @@ -6159,7 +6160,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): """ @@ -6209,7 +6210,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): """ @@ -6260,7 +6261,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): """ @@ -6310,7 +6311,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): """ @@ -6360,7 +6361,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): """ @@ -6405,7 +6406,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): """ @@ -6460,7 +6461,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): """ @@ -6510,7 +6511,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): """ @@ -6560,7 +6561,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): """ @@ -6610,7 +6611,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): """ @@ -6655,7 +6656,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): """ @@ -6710,7 +6711,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): """ @@ -6760,7 +6761,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): """ @@ -6821,7 +6822,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): """ @@ -6876,7 +6877,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): """ @@ -6923,7 +6924,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): """ @@ -6984,7 +6985,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): """ @@ -7045,7 +7046,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): """ @@ -7092,7 +7093,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): """ @@ -7153,7 +7154,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): """ @@ -7200,7 +7201,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): """ @@ -7261,7 +7262,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): """ @@ -7308,7 +7309,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): """ @@ -7363,7 +7364,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): """ @@ -7418,7 +7419,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): """ @@ -7474,7 +7475,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): """ @@ -7541,7 +7542,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): """ @@ -7597,7 +7598,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): """ @@ -7647,7 +7648,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): """ @@ -7710,7 +7711,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): """ @@ -7766,7 +7767,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): """ @@ -7816,7 +7817,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): """ @@ -7879,7 +7880,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): """ @@ -7936,7 +7937,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): """ @@ -7986,7 +7987,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): """ @@ -8053,7 +8054,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): """ @@ -8110,7 +8111,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): """ @@ -8160,7 +8161,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): """ @@ -8216,7 +8217,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): """ @@ -8272,7 +8273,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): """ @@ -8322,7 +8323,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): """ @@ -8373,7 +8374,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): """ @@ -8426,7 +8427,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): """ @@ -8479,7 +8480,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): """ @@ -8520,7 +8521,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): """ @@ -8563,7 +8564,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): """ @@ -8604,7 +8605,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): """ @@ -8645,7 +8646,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): """ @@ -8701,7 +8702,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): """ @@ -8753,7 +8754,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): """ @@ -8803,7 +8804,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): """ @@ -8858,7 +8859,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): """ @@ -8908,7 +8909,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): """ @@ -8969,7 +8970,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): """ @@ -9014,7 +9015,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): """ @@ -9069,7 +9070,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): """ @@ -9112,7 +9113,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): """ @@ -9162,7 +9163,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): """ @@ -9203,7 +9204,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): """ @@ -9245,7 +9246,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): """ @@ -9305,7 +9306,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): """ @@ -9350,7 +9351,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): """ @@ -9405,7 +9406,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): """ @@ -9448,7 +9449,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): """ @@ -9489,7 +9490,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): """ @@ -9530,7 +9531,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): """ @@ -9612,7 +9613,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): """ @@ -9694,7 +9695,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): """ @@ -9735,7 +9736,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): """ @@ -9779,7 +9780,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): """ @@ -9898,7 +9899,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") def copyDataResource(self, authzToken, resourceId, destStorageResourceId, destinationParentPath): """ @@ -9943,7 +9944,7 @@ class Client(Iface): raise result.ase if result.ae is not None: raise result.ae - raise TApplicationException(TApplicationException.MISSING_RESULT, "copyDataResource failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "copyDataResource failed: unknown result") class Processor(Iface, TProcessor): @@ -10110,15 +10111,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() @@ -10130,15 +10142,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() @@ -10150,15 +10173,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() @@ -10170,15 +10204,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() @@ -10190,15 +10235,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() @@ -10210,15 +10266,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() @@ -10230,15 +10297,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() @@ -10250,13 +10328,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() @@ -10268,13 +10356,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() @@ -10286,13 +10384,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() @@ -10304,13 +10412,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() @@ -10322,13 +10440,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() @@ -10340,15 +10468,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() @@ -10360,17 +10499,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() @@ -10382,17 +10533,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() @@ -10404,17 +10567,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 = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("deleteProject", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -10426,15 +10601,26 @@ class Processor(Iface, TProcessor): result = getUserProjects_result() try: result.success = self._handler.getUserProjects(args.authzToken, args.gatewayId, args.userName, args.limit, args.offset) - 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("getUserProjects", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getUserProjects", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -10446,15 +10632,26 @@ class Processor(Iface, TProcessor): result = searchProjectsByProjectName_result() try: result.success = self._handler.searchProjectsByProjectName(args.authzToken, args.gatewayId, args.userName, args.projectName, args.limit, args.offset) - 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("searchProjectsByProjectName", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("searchProjectsByProjectName", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -10466,15 +10663,26 @@ class Processor(Iface, TProcessor): result = searchProjectsByProjectDesc_result() try: result.success = self._handler.searchProjectsByProjectDesc(args.authzToken, args.gatewayId, args.userName, args.description, args.limit, args.offset) - 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("searchProjectsByProjectDesc", TMessageType.REPLY, seqid) + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("searchProjectsByProjectDesc", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -10486,15 +10694,26 @@ class Processor(Iface, TProcessor): result = searchExperimentsByName_result() try: result.success = self._handler.searchExperimentsByName(args.authzToken, args.gatewayId, args.userName, args.expName, args.limit, args.offset) - 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 -
<TRUNCATED>
