http://git-wip-us.apache.org/repos/asf/airavata/blob/a5cb91f0/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 cd0638c..cf685ed 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.1) +# Autogenerated by Thrift Compiler (0.9.2) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -112,7 +112,7 @@ class Iface: The identifier for the requested gateway. @param Project - The Project Object described in the workspaceModel + The Project Object described in the workspace_model Parameters: @@ -157,7 +157,7 @@ class Iface: * The identifier for the requested gateway. * * @param userName - * The Project Object described in the workspaceModel + * The Project Object described in the workspace_model * @deprecated Instead use getAllUserProjectsWithPagination * @@ -534,6 +534,24 @@ class Iface: """ pass + def getExperimentStatistics(self, gatewayId, fromTime, toTime): + """ + Get Experiment Statisitics for the given gateway for a specific time period + @param gatewayId + Identifier of the requested gateway + @param fromTime + Starting date time + @param toTime + Ending data time + + + Parameters: + - gatewayId + - fromTime + - toTime + """ + pass + def getAllExperimentsInProject(self, projectId): """ Get all Experiments within a Project @@ -1223,7 +1241,7 @@ class Iface: @param appInterfaceId The identifier for the requested application interface - @return list<applicationInterfaceModel.InputDataObjectType> + @return list<application_interface_model.InputDataObjectType> Returns a list of application inputs. @@ -1239,7 +1257,7 @@ class Iface: @param appInterfaceId The identifier for the requested application interface - @return list<applicationInterfaceModel.OutputDataObjectType> + @return list<application_interface_model.OutputDataObjectType> Returns a list of application outputs. @@ -2166,15 +2184,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAPIVersion(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAPIVersion_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2204,15 +2223,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addGateway(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addGateway_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2242,15 +2262,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateGateway(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateGateway_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.ire is not None: raise result.ire if result.ace is not None: @@ -2276,15 +2297,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getGateway(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getGateway_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2312,15 +2334,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteGateway(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteGateway_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2343,15 +2366,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllGateways(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllGateways_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2379,15 +2403,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_isGatewayExist(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = isGatewayExist_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2432,15 +2457,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_generateAndRegisterSSHKeys(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = generateAndRegisterSSHKeys_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2468,15 +2494,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getSSHPubKey(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getSSHPubKey_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2504,15 +2531,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllUserSSHPubKeys(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllUserSSHPubKeys_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2532,7 +2560,7 @@ class Client(Iface): The identifier for the requested gateway. @param Project - The Project Object described in the workspaceModel + The Project Object described in the workspace_model Parameters: @@ -2552,15 +2580,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_createProject(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = createProject_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2593,15 +2622,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateProject(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateProject_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.ire is not None: raise result.ire if result.ace is not None: @@ -2632,15 +2662,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getProject(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getProject_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2670,15 +2701,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteProject(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteProject_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2699,7 +2731,7 @@ class Client(Iface): * The identifier for the requested gateway. * * @param userName - * The Project Object described in the workspaceModel + * The Project Object described in the workspace_model * @deprecated Instead use getAllUserProjectsWithPagination * @@ -2720,15 +2752,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllUserProjects(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllUserProjects_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2775,15 +2808,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllUserProjectsWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllUserProjectsWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2825,15 +2859,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchProjectsByProjectName(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchProjectsByProjectName_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2883,15 +2918,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchProjectsByProjectNameWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchProjectsByProjectNameWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2932,15 +2968,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchProjectsByProjectDesc(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchProjectsByProjectDesc_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -2990,15 +3027,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchProjectsByProjectDescWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchProjectsByProjectDescWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3042,15 +3080,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByName(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByName_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3100,15 +3139,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByNameWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByNameWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3151,15 +3191,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByDesc(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByDesc_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3209,15 +3250,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByDescWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByDescWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3260,15 +3302,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByApplication(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByApplication_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3318,15 +3361,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByApplicationWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByApplicationWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3369,15 +3413,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByStatus(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByStatus_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3427,15 +3472,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByStatusWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByStatusWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3482,15 +3528,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByCreationTime(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByCreationTime_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3544,15 +3591,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperimentsByCreationTimeWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperimentsByCreationTimeWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3602,15 +3650,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_searchExperiments(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = searchExperiments_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3621,6 +3670,56 @@ class Client(Iface): raise result.ase raise TApplicationException(TApplicationException.MISSING_RESULT, "searchExperiments failed: unknown result"); + def getExperimentStatistics(self, gatewayId, fromTime, toTime): + """ + Get Experiment Statisitics for the given gateway for a specific time period + @param gatewayId + Identifier of the requested gateway + @param fromTime + Starting date time + @param toTime + Ending data time + + + Parameters: + - gatewayId + - fromTime + - toTime + """ + self.send_getExperimentStatistics(gatewayId, fromTime, toTime) + return self.recv_getExperimentStatistics() + + def send_getExperimentStatistics(self, gatewayId, fromTime, toTime): + self._oprot.writeMessageBegin('getExperimentStatistics', TMessageType.CALL, self._seqid) + args = getExperimentStatistics_args() + args.gatewayId = gatewayId + args.fromTime = fromTime + args.toTime = toTime + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getExperimentStatistics(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getExperimentStatistics_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + raise TApplicationException(TApplicationException.MISSING_RESULT, "getExperimentStatistics failed: unknown result"); + def getAllExperimentsInProject(self, projectId): """ Get all Experiments within a Project @@ -3645,15 +3744,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllExperimentsInProject(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllExperimentsInProject_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3697,15 +3797,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllExperimentsInProjectWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllExperimentsInProjectWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3746,15 +3847,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllUserExperiments(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllUserExperiments_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3800,15 +3902,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllUserExperimentsWithPagination(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllUserExperimentsWithPagination_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3872,15 +3975,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_createExperiment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = createExperiment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -3940,15 +4044,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getExperiment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getExperiment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4018,15 +4123,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateExperiment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateExperiment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.ire is not None: raise result.ire if result.enf is not None: @@ -4056,15 +4162,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateExperimentConfiguration(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateExperimentConfiguration_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() return def updateResourceScheduleing(self, airavataExperimentId, resourceScheduling): @@ -4086,15 +4193,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateResourceScheduleing(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateResourceScheduleing_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() return def validateExperiment(self, airavataExperimentId): @@ -4122,15 +4230,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_validateExperiment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = validateExperiment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4204,15 +4313,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_launchExperiment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = launchExperiment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.ire is not None: raise result.ire if result.enf is not None: @@ -4242,15 +4352,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getExperimentStatus(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getExperimentStatus_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4280,15 +4391,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getExperimentOutputs(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getExperimentOutputs_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4318,15 +4430,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getIntermediateOutputs(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getIntermediateOutputs_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4356,15 +4469,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getJobStatuses(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getJobStatuses_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4394,15 +4508,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getJobDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getJobDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4432,15 +4547,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getDataTransferDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getDataTransferDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4510,15 +4626,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_cloneExperiment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = cloneExperiment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4582,15 +4699,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_terminateExperiment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = terminateExperiment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.ire is not None: raise result.ire if result.enf is not None: @@ -4629,15 +4747,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_registerApplicationModule(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = registerApplicationModule_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4674,15 +4793,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getApplicationModule(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getApplicationModule_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4724,15 +4844,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateApplicationModule(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateApplicationModule_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4760,15 +4881,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllAppModules(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllAppModules_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4805,15 +4927,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteApplicationModule(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteApplicationModule_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4852,15 +4975,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_registerApplicationDeployment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = registerApplicationDeployment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4897,15 +5021,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getApplicationDeployment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getApplicationDeployment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4947,15 +5072,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateApplicationDeployment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateApplicationDeployment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -4992,15 +5118,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteApplicationDeployment(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteApplicationDeployment_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5034,15 +5161,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllApplicationDeployments(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllApplicationDeployments_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5079,15 +5207,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAppModuleDeployedResources(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAppModuleDeployedResources_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5126,15 +5255,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_registerApplicationInterface(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = registerApplicationInterface_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5172,15 +5302,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getApplicationInterface(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getApplicationInterface_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5223,15 +5354,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateApplicationInterface(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateApplicationInterface_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5269,15 +5401,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteApplicationInterface(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteApplicationInterface_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5312,15 +5445,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllApplicationInterfaceNames(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllApplicationInterfaceNames_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5355,15 +5489,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllApplicationInterfaces(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllApplicationInterfaces_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5381,7 +5516,7 @@ class Client(Iface): @param appInterfaceId The identifier for the requested application interface - @return list<applicationInterfaceModel.InputDataObjectType> + @return list<application_interface_model.InputDataObjectType> Returns a list of application inputs. @@ -5400,15 +5535,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getApplicationInputs(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getApplicationInputs_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5426,7 +5562,7 @@ class Client(Iface): @param appInterfaceId The identifier for the requested application interface - @return list<applicationInterfaceModel.OutputDataObjectType> + @return list<application_interface_model.OutputDataObjectType> Returns a list of application outputs. @@ -5445,15 +5581,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getApplicationOutputs(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getApplicationOutputs_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5491,15 +5628,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAvailableAppInterfaceComputeResources(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAvailableAppInterfaceComputeResources_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5536,15 +5674,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_registerComputeResource(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = registerComputeResource_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5581,15 +5720,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getComputeResource(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getComputeResource_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5619,15 +5759,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getAllComputeResourceNames(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getAllComputeResourceNames_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5669,15 +5810,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateComputeResource(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateComputeResource_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5714,15 +5856,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteComputeResource(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteComputeResource_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5770,15 +5913,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addLocalSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addLocalSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5820,15 +5964,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateLocalSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateLocalSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5862,15 +6007,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getLocalJobSubmission(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getLocalJobSubmission_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5918,15 +6064,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addSSHJobSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addSSHJobSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -5960,15 +6107,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getSSHJobSubmission(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getSSHJobSubmission_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6016,15 +6164,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addUNICOREJobSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addUNICOREJobSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6058,15 +6207,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getUnicoreJobSubmission(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getUnicoreJobSubmission_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6114,15 +6264,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addCloudJobSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addCloudJobSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6156,15 +6307,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getCloudJobSubmission(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getCloudJobSubmission_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6206,15 +6358,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateSSHJobSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateSSHJobSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6256,15 +6409,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateCloudJobSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateCloudJobSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6294,15 +6448,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateUnicoreJobSubmissionDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateUnicoreJobSubmissionDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6350,15 +6505,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addLocalDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addLocalDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6400,15 +6556,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateLocalDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateLocalDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6442,15 +6599,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getLocalDataMovement(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getLocalDataMovement_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6498,15 +6656,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addSCPDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addSCPDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6549,15 +6708,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateSCPDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateSCPDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6591,15 +6751,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getSCPDataMovement(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getSCPDataMovement_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6631,15 +6792,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addUnicoreDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addUnicoreDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6669,15 +6831,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateUnicoreDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateUnicoreDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6705,15 +6868,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getUnicoreDataMovement(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getUnicoreDataMovement_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6761,15 +6925,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addGridFTPDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addGridFTPDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6812,15 +6977,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateGridFTPDataMovementDetails(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateGridFTPDataMovementDetails_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6854,15 +7020,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getGridFTPDataMovement(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getGridFTPDataMovement_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6904,15 +7071,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_changeJobSubmissionPriority(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = changeJobSubmissionPriority_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6954,15 +7122,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_changeDataMovementPriority(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = changeDataMovementPriority_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -6999,15 +7168,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_changeJobSubmissionPriorities(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = changeJobSubmissionPriorities_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7044,15 +7214,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_changeDataMovementPriorities(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = changeDataMovementPriorities_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7091,15 +7262,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteJobSubmissionInterface(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteJobSubmissionInterface_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7138,15 +7310,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteDataMovementInterface(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteDataMovementInterface_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7174,15 +7347,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_registerResourceJobManager(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = registerResourceJobManager_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7212,15 +7386,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateResourceJobManager(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateResourceJobManager_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7248,15 +7423,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getResourceJobManager(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getResourceJobManager_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7284,15 +7460,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteResourceJobManager(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteResourceJobManager_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7322,15 +7499,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteBatchQueue(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteBatchQueue_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7369,15 +7547,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_registerGatewayResourceProfile(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = registerGatewayResourceProfile_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7414,15 +7593,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_getGatewayResourceProfile(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = getGatewayResourceProfile_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7464,15 +7644,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_updateGatewayResourceProfile(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = updateGatewayResourceProfile_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7509,15 +7690,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_deleteGatewayResourceProfile(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = deleteGatewayResourceProfile_result() - result.read(self._iprot) - self._iprot.readMessageEnd() + result.read(iprot) + iprot.readMessageEnd() if result.success is not None: return result.success if result.ire is not None: @@ -7565,15 +7747,16 @@ class Client(Iface): self._oprot.trans.flush() def recv_addGatewayComputeResourcePreference(self): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() + x.read(iprot) + iprot.readMessageEnd() raise x result = addGatewayComputeResourcePreference_result() - result.read(self._iprot) -
<TRUNCATED>
