http://git-wip-us.apache.org/repos/asf/airavata/blob/d84783da/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 505e10b..6cd34d3 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 @@ -1958,6 +1958,16 @@ class Iface: """ pass + def addGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + - dataStoragePreference + """ + pass + def getGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ Fetch a Compute Resource Preference of a registered gateway profile. @@ -1979,6 +1989,15 @@ class Iface: """ pass + def getGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + """ + pass + def getAllGatewayComputeResourcePreferences(self, authzToken, gatewayID): """ Fetch all Compute Resource Preferences of a registered gateway profile. @@ -1996,6 +2015,14 @@ class Iface: """ pass + def getAllGatewayDataStoragePreferences(self, authzToken, gatewayID): + """ + Parameters: + - authzToken + - gatewayID + """ + pass + def getAllGatewayComputeResources(self, authzToken): """ Fetch all gateway profiles registered @@ -2031,6 +2058,16 @@ class Iface: """ pass + def updateGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + - dataStoragePreference + """ + pass + def deleteGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ Delete the Compute Resource Preference of a registered gateway profile. @@ -2052,6 +2089,15 @@ class Iface: """ pass + def deleteGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + """ + pass + def getAllWorkflows(self, authzToken, gatewayId): """ Parameters: @@ -7648,6 +7694,51 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayComputeResourcePreference failed: unknown result"); + def addGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + - dataStoragePreference + """ + self.send_addGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId, dataStoragePreference) + return self.recv_addGatewayDataStoragePreference() + + def send_addGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + self._oprot.writeMessageBegin('addGatewayDataStoragePreference', TMessageType.CALL, self._seqid) + args = addGatewayDataStoragePreference_args() + args.authzToken = authzToken + args.gatewayID = gatewayID + args.dataMoveId = dataMoveId + args.dataStoragePreference = dataStoragePreference + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_addGatewayDataStoragePreference(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = addGatewayDataStoragePreference_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 + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "addGatewayDataStoragePreference failed: unknown result"); + def getGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ Fetch a Compute Resource Preference of a registered gateway profile. @@ -7703,6 +7794,49 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayComputeResourcePreference failed: unknown result"); + def getGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + """ + self.send_getGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId) + return self.recv_getGatewayDataStoragePreference() + + def send_getGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + self._oprot.writeMessageBegin('getGatewayDataStoragePreference', TMessageType.CALL, self._seqid) + args = getGatewayDataStoragePreference_args() + args.authzToken = authzToken + args.gatewayID = gatewayID + args.dataMoveId = dataMoveId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getGatewayDataStoragePreference(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getGatewayDataStoragePreference_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 + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGatewayDataStoragePreference failed: unknown result"); + def getAllGatewayComputeResourcePreferences(self, authzToken, gatewayID): """ Fetch all Compute Resource Preferences of a registered gateway profile. @@ -7753,6 +7887,47 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayComputeResourcePreferences failed: unknown result"); + def getAllGatewayDataStoragePreferences(self, authzToken, gatewayID): + """ + Parameters: + - authzToken + - gatewayID + """ + self.send_getAllGatewayDataStoragePreferences(authzToken, gatewayID) + return self.recv_getAllGatewayDataStoragePreferences() + + def send_getAllGatewayDataStoragePreferences(self, authzToken, gatewayID): + self._oprot.writeMessageBegin('getAllGatewayDataStoragePreferences', TMessageType.CALL, self._seqid) + args = getAllGatewayDataStoragePreferences_args() + args.authzToken = authzToken + args.gatewayID = gatewayID + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllGatewayDataStoragePreferences(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getAllGatewayDataStoragePreferences_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 + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewayDataStoragePreferences failed: unknown result"); + def getAllGatewayComputeResources(self, authzToken): """ Fetch all gateway profiles registered @@ -7855,6 +8030,51 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayComputeResourcePreference failed: unknown result"); + def updateGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + - dataStoragePreference + """ + self.send_updateGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId, dataStoragePreference) + return self.recv_updateGatewayDataStoragePreference() + + def send_updateGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId, dataStoragePreference): + self._oprot.writeMessageBegin('updateGatewayDataStoragePreference', TMessageType.CALL, self._seqid) + args = updateGatewayDataStoragePreference_args() + args.authzToken = authzToken + args.gatewayID = gatewayID + args.dataMoveId = dataMoveId + args.dataStoragePreference = dataStoragePreference + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_updateGatewayDataStoragePreference(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = updateGatewayDataStoragePreference_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 + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "updateGatewayDataStoragePreference failed: unknown result"); + def deleteGatewayComputeResourcePreference(self, authzToken, gatewayID, computeResourceId): """ Delete the Compute Resource Preference of a registered gateway profile. @@ -7910,6 +8130,49 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayComputeResourcePreference failed: unknown result"); + def deleteGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + """ + Parameters: + - authzToken + - gatewayID + - dataMoveId + """ + self.send_deleteGatewayDataStoragePreference(authzToken, gatewayID, dataMoveId) + return self.recv_deleteGatewayDataStoragePreference() + + def send_deleteGatewayDataStoragePreference(self, authzToken, gatewayID, dataMoveId): + self._oprot.writeMessageBegin('deleteGatewayDataStoragePreference', TMessageType.CALL, self._seqid) + args = deleteGatewayDataStoragePreference_args() + args.authzToken = authzToken + args.gatewayID = gatewayID + args.dataMoveId = dataMoveId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deleteGatewayDataStoragePreference(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = deleteGatewayDataStoragePreference_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 + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteGatewayDataStoragePreference failed: unknown result"); + def getAllWorkflows(self, authzToken, gatewayId): """ Parameters: @@ -8308,11 +8571,16 @@ class Processor(Iface, TProcessor): self._processMap["updateGatewayResourceProfile"] = Processor.process_updateGatewayResourceProfile self._processMap["deleteGatewayResourceProfile"] = Processor.process_deleteGatewayResourceProfile self._processMap["addGatewayComputeResourcePreference"] = Processor.process_addGatewayComputeResourcePreference + self._processMap["addGatewayDataStoragePreference"] = Processor.process_addGatewayDataStoragePreference self._processMap["getGatewayComputeResourcePreference"] = Processor.process_getGatewayComputeResourcePreference + self._processMap["getGatewayDataStoragePreference"] = Processor.process_getGatewayDataStoragePreference self._processMap["getAllGatewayComputeResourcePreferences"] = Processor.process_getAllGatewayComputeResourcePreferences + self._processMap["getAllGatewayDataStoragePreferences"] = Processor.process_getAllGatewayDataStoragePreferences self._processMap["getAllGatewayComputeResources"] = Processor.process_getAllGatewayComputeResources self._processMap["updateGatewayComputeResourcePreference"] = Processor.process_updateGatewayComputeResourcePreference + self._processMap["updateGatewayDataStoragePreference"] = Processor.process_updateGatewayDataStoragePreference self._processMap["deleteGatewayComputeResourcePreference"] = Processor.process_deleteGatewayComputeResourcePreference + self._processMap["deleteGatewayDataStoragePreference"] = Processor.process_deleteGatewayDataStoragePreference self._processMap["getAllWorkflows"] = Processor.process_getAllWorkflows self._processMap["getWorkflow"] = Processor.process_getWorkflow self._processMap["deleteWorkflow"] = Processor.process_deleteWorkflow @@ -10468,6 +10736,26 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_addGatewayDataStoragePreference(self, seqid, iprot, oprot): + args = addGatewayDataStoragePreference_args() + args.read(iprot) + iprot.readMessageEnd() + result = addGatewayDataStoragePreference_result() + try: + result.success = self._handler.addGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference) + except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException, ace: + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException, ae: + result.ae = ae + oprot.writeMessageBegin("addGatewayDataStoragePreference", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_getGatewayComputeResourcePreference(self, seqid, iprot, oprot): args = getGatewayComputeResourcePreference_args() args.read(iprot) @@ -10488,6 +10776,26 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_getGatewayDataStoragePreference(self, seqid, iprot, oprot): + args = getGatewayDataStoragePreference_args() + args.read(iprot) + iprot.readMessageEnd() + result = getGatewayDataStoragePreference_result() + try: + result.success = self._handler.getGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId) + except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException, ace: + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException, ae: + result.ae = ae + oprot.writeMessageBegin("getGatewayDataStoragePreference", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_getAllGatewayComputeResourcePreferences(self, seqid, iprot, oprot): args = getAllGatewayComputeResourcePreferences_args() args.read(iprot) @@ -10508,6 +10816,26 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_getAllGatewayDataStoragePreferences(self, seqid, iprot, oprot): + args = getAllGatewayDataStoragePreferences_args() + args.read(iprot) + iprot.readMessageEnd() + result = getAllGatewayDataStoragePreferences_result() + try: + result.success = self._handler.getAllGatewayDataStoragePreferences(args.authzToken, args.gatewayID) + except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException, ace: + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException, ae: + result.ae = ae + oprot.writeMessageBegin("getAllGatewayDataStoragePreferences", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_getAllGatewayComputeResources(self, seqid, iprot, oprot): args = getAllGatewayComputeResources_args() args.read(iprot) @@ -10548,6 +10876,26 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_updateGatewayDataStoragePreference(self, seqid, iprot, oprot): + args = updateGatewayDataStoragePreference_args() + args.read(iprot) + iprot.readMessageEnd() + result = updateGatewayDataStoragePreference_result() + try: + result.success = self._handler.updateGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId, args.dataStoragePreference) + except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException, ace: + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException, ae: + result.ae = ae + oprot.writeMessageBegin("updateGatewayDataStoragePreference", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_deleteGatewayComputeResourcePreference(self, seqid, iprot, oprot): args = deleteGatewayComputeResourcePreference_args() args.read(iprot) @@ -10568,6 +10916,26 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_deleteGatewayDataStoragePreference(self, seqid, iprot, oprot): + args = deleteGatewayDataStoragePreference_args() + args.read(iprot) + iprot.readMessageEnd() + result = deleteGatewayDataStoragePreference_result() + try: + result.success = self._handler.deleteGatewayDataStoragePreference(args.authzToken, args.gatewayID, args.dataMoveId) + except apache.airavata.api.error.ttypes.InvalidRequestException, ire: + result.ire = ire + except apache.airavata.api.error.ttypes.AiravataClientException, ace: + result.ace = ace + except apache.airavata.api.error.ttypes.AiravataSystemException, ase: + result.ase = ase + except apache.airavata.api.error.ttypes.AuthorizationException, ae: + result.ae = ae + oprot.writeMessageBegin("deleteGatewayDataStoragePreference", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_getAllWorkflows(self, seqid, iprot, oprot): args = getAllWorkflows_args() args.read(iprot) @@ -20218,25 +20586,1298 @@ class getApplicationModule_result: def __ne__(self, other): return not (self == other) -class updateApplicationModule_args: +class updateApplicationModule_args: + """ + Attributes: + - authzToken + - appModuleId + - applicationModule + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'appModuleId', None, None, ), # 2 + (3, TType.STRUCT, 'applicationModule', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule.thrift_spec), None, ), # 3 + ) + + def __init__(self, authzToken=None, appModuleId=None, applicationModule=None,): + self.authzToken = authzToken + self.appModuleId = appModuleId + self.applicationModule = applicationModule + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.appModuleId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.applicationModule = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + self.applicationModule.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('updateApplicationModule_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.appModuleId is not None: + oprot.writeFieldBegin('appModuleId', TType.STRING, 2) + oprot.writeString(self.appModuleId) + oprot.writeFieldEnd() + if self.applicationModule is not None: + oprot.writeFieldBegin('applicationModule', TType.STRUCT, 3) + self.applicationModule.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.appModuleId is None: + raise TProtocol.TProtocolException(message='Required field appModuleId is unset!') + if self.applicationModule is None: + raise TProtocol.TProtocolException(message='Required field applicationModule is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.appModuleId) + value = (value * 31) ^ hash(self.applicationModule) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class updateApplicationModule_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + self.ae = ae + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.BOOL: + self.success = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('updateApplicationModule_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 4) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class getAllAppModules_args: + """ + Attributes: + - authzToken + - gatewayId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'gatewayId', None, None, ), # 2 + ) + + def __init__(self, authzToken=None, gatewayId=None,): + self.authzToken = authzToken + self.gatewayId = gatewayId + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.gatewayId = iprot.readString(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getAllAppModules_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 2) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.gatewayId) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class getAllAppModules_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule.thrift_spec)), None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + self.ae = ae + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.LIST: + self.success = [] + (_etype135, _size132) = iprot.readListBegin() + for _i136 in xrange(_size132): + _elem137 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + _elem137.read(iprot) + self.success.append(_elem137) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getAllAppModules_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter138 in self.success: + iter138.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 4) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class deleteApplicationModule_args: + """ + Attributes: + - authzToken + - appModuleId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'appModuleId', None, None, ), # 2 + ) + + def __init__(self, authzToken=None, appModuleId=None,): + self.authzToken = authzToken + self.appModuleId = appModuleId + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.appModuleId = iprot.readString(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('deleteApplicationModule_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.appModuleId is not None: + oprot.writeFieldBegin('appModuleId', TType.STRING, 2) + oprot.writeString(self.appModuleId) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.appModuleId is None: + raise TProtocol.TProtocolException(message='Required field appModuleId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.appModuleId) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class deleteApplicationModule_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + self.ae = ae + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.BOOL: + self.success = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('deleteApplicationModule_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 4) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class registerApplicationDeployment_args: + """ + Attributes: + - authzToken + - gatewayId + - applicationDeployment + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'gatewayId', None, None, ), # 2 + (3, TType.STRUCT, 'applicationDeployment', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription.thrift_spec), None, ), # 3 + ) + + def __init__(self, authzToken=None, gatewayId=None, applicationDeployment=None,): + self.authzToken = authzToken + self.gatewayId = gatewayId + self.applicationDeployment = applicationDeployment + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.gatewayId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.applicationDeployment = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + self.applicationDeployment.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('registerApplicationDeployment_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 2) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() + if self.applicationDeployment is not None: + oprot.writeFieldBegin('applicationDeployment', TType.STRUCT, 3) + self.applicationDeployment.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.gatewayId is None: + raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + if self.applicationDeployment is None: + raise TProtocol.TProtocolException(message='Required field applicationDeployment is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.gatewayId) + value = (value * 31) ^ hash(self.applicationDeployment) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class registerApplicationDeployment_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.STRING, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + self.ae = ae + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.STRING: + self.success = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('registerApplicationDeployment_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 4) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class getApplicationDeployment_args: + """ + Attributes: + - authzToken + - appDeploymentId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'appDeploymentId', None, None, ), # 2 + ) + + def __init__(self, authzToken=None, appDeploymentId=None,): + self.authzToken = authzToken + self.appDeploymentId = appDeploymentId + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.appDeploymentId = iprot.readString(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getApplicationDeployment_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.appDeploymentId is not None: + oprot.writeFieldBegin('appDeploymentId', TType.STRING, 2) + oprot.writeString(self.appDeploymentId) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.appDeploymentId is None: + raise TProtocol.TProtocolException(message='Required field appDeploymentId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.appDeploymentId) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class getApplicationDeployment_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + self.ae = ae + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.STRUCT: + self.success = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + self.success.read(iprot) + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getApplicationDeployment_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 4) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class updateApplicationDeployment_args: + """ + Attributes: + - authzToken + - appDeploymentId + - applicationDeployment + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'appDeploymentId', None, None, ), # 2 + (3, TType.STRUCT, 'applicationDeployment', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription.thrift_spec), None, ), # 3 + ) + + def __init__(self, authzToken=None, appDeploymentId=None, applicationDeployment=None,): + self.authzToken = authzToken + self.appDeploymentId = appDeploymentId + self.applicationDeployment = applicationDeployment + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.authzToken = apache.airavata.model.security.ttypes.AuthzToken() + self.authzToken.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.appDeploymentId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.applicationDeployment = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + self.applicationDeployment.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('updateApplicationDeployment_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.appDeploymentId is not None: + oprot.writeFieldBegin('appDeploymentId', TType.STRING, 2) + oprot.writeString(self.appDeploymentId) + oprot.writeFieldEnd() + if self.applicationDeployment is not None: + oprot.writeFieldBegin('applicationDeployment', TType.STRUCT, 3) + self.applicationDeployment.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.authzToken is None: + raise TProtocol.TProtocolException(message='Required field authzToken is unset!') + if self.appDeploymentId is None: + raise TProtocol.TProtocolException(message='Required field appDeploymentId is unset!') + if self.applicationDeployment is None: + raise TProtocol.TProtocolException(message='Required field applicationDeployment is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.appDeploymentId) + value = (value * 31) ^ hash(self.applicationDeployment) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class updateApplicationDeployment_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'ae', (apache.airavata.api.error.ttypes.AuthorizationException, apache.airavata.api.error.ttypes.AuthorizationException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None, ae=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + self.ae = ae + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.BOOL: + self.success = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ire = apache.airavata.api.error.ttypes.InvalidRequestException() + self.ire.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.ace = apache.airavata.api.error.ttypes.AiravataClientException() + self.ace.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.ase = apache.airavata.api.error.ttypes.AiravataSystemException() + self.ase.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.ae = apache.airavata.api.error.ttypes.AuthorizationException() + self.ae.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('updateApplicationDeployment_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + if self.ire is not None: + oprot.writeFieldBegin('ire', TType.STRUCT, 1) + self.ire.write(oprot) + oprot.writeFieldEnd() + if self.ace is not None: + oprot.writeFieldBegin('ace', TType.STRUCT, 2) + self.ace.write(oprot) + oprot.writeFieldEnd() + if self.ase is not None: + oprot.writeFieldBegin('ase', TType.STRUCT, 3) + self.ase.write(oprot) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 4) + self.ae.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.ire) + value = (value * 31) ^ hash(self.ace) + value = (value * 31) ^ hash(self.ase) + value = (value * 31) ^ hash(self.ae) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class deleteApplicationDeployment_args: """ Attributes: - authzToken - - appModuleId - - applicationModule + - appDeploymentId """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 - (2, TType.STRING, 'appModuleId', None, None, ), # 2 - (3, TType.STRUCT, 'applicationModule', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule.thrift_spec), None, ), # 3 + (2, TType.STRING, 'appDeploymentId', None, None, ), # 2 ) - def __init__(self, authzToken=None, appModuleId=None, applicationModule=None,): + def __init__(self, authzToken=None, appDeploymentId=None,): self.authzToken = authzToken - self.appModuleId = appModuleId - self.applicationModule = applicationModule + self.appDeploymentId = appDeploymentId def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -20255,13 +21896,7 @@ class updateApplicationModule_args: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.appModuleId = iprot.readString(); - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.applicationModule = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() - self.applicationModule.read(iprot) + self.appDeploymentId = iprot.readString(); else: iprot.skip(ftype) else: @@ -20273,18 +21908,14 @@ class updateApplicationModule_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('updateApplicationModule_args') + oprot.writeStructBegin('deleteApplicationDeployment_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) oprot.writeFieldEnd() - if self.appModuleId is not None: - oprot.writeFieldBegin('appModuleId', TType.STRING, 2) - oprot.writeString(self.appModuleId) - oprot.writeFieldEnd() - if self.applicationModule is not None: - oprot.writeFieldBegin('applicationModule', TType.STRUCT, 3) - self.applicationModule.write(oprot) + if self.appDeploymentId is not None: + oprot.writeFieldBegin('appDeploymentId', TType.STRING, 2) + oprot.writeString(self.appDeploymentId) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -20292,18 +21923,15 @@ class updateApplicationModule_args: def validate(self): if self.authzToken is None: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') - if self.appModuleId is None: - raise TProtocol.TProtocolException(message='Required field appModuleId is unset!') - if self.applicationModule is None: - raise TProtocol.TProtocolException(message='Required field applicationModule is unset!') + if self.appDeploymentId is None: + raise TProtocol.TProtocolException(message='Required field appDeploymentId is unset!') return def __hash__(self): value = 17 value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.appModuleId) - value = (value * 31) ^ hash(self.applicationModule) + value = (value * 31) ^ hash(self.appDeploymentId) return value def __repr__(self): @@ -20317,7 +21945,7 @@ class updateApplicationModule_args: def __ne__(self, other): return not (self == other) -class updateApplicationModule_result: +class deleteApplicationDeployment_result: """ Attributes: - success @@ -20389,7 +22017,7 @@ class updateApplicationModule_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('updateApplicationModule_result') + oprot.writeStructBegin('deleteApplicationDeployment_result') if self.success is not None: oprot.writeFieldBegin('success', TType.BOOL, 0) oprot.writeBool(self.success) @@ -20437,7 +22065,7 @@ class updateApplicationModule_result: def __ne__(self, other): return not (self == other) -class getAllAppModules_args: +class getAllApplicationDeployments_args: """ Attributes: - authzToken @@ -20483,7 +22111,7 @@ class getAllAppModules_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getAllAppModules_args') + oprot.writeStructBegin('getAllApplicationDeployments_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -20520,7 +22148,7 @@ class getAllAppModules_args: def __ne__(self, other): return not (self == other) -class getAllAppModules_result: +class getAllApplicationDeployments_result: """ Attributes: - success @@ -20531,7 +22159,7 @@ class getAllAppModules_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule.thrift_spec)), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription.thrift_spec)), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 @@ -20557,11 +22185,11 @@ class getAllAppModules_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype135, _size132) = iprot.readListBegin() - for _i136 in xrange(_size132): - _elem137 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() - _elem137.read(iprot) - self.success.append(_elem137) + (_etype142, _size139) = iprot.readListBegin() + for _i143 in xrange(_size139): + _elem144 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + _elem144.read(iprot) + self.success.append(_elem144) iprot.readListEnd() else: iprot.skip(ftype) @@ -20598,12 +22226,12 @@ class getAllAppModules_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getAllAppModules_result') + oprot.writeStructBegin('getAllApplicationDeployments_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter138 in self.success: - iter138.write(oprot) + for iter145 in self.success: + iter145.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -20649,7 +22277,7 @@ class getAllAppModules_result: def __ne__(self, other): return not (self == other) -class deleteApplicationModule_args: +class getAppModuleDeployedResources_args: """ Attributes: - authzToken @@ -20695,7 +22323,7 @@ class deleteApplicationModule_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('deleteApplicationModule_args') + oprot.writeStructBegin('getAppModuleDeployedResources_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -20732,7 +22360,7 @@ class deleteApplicationModule_args: def __ne__(self, other): return not (self == other) -class deleteApplicationModule_result: +class getAppModuleDeployedResources_result: """ Attributes: - success @@ -20743,7 +22371,7 @@ class deleteApplicationModule_result: """ thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 @@ -20767,8 +22395,13 @@ class deleteApplicationModule_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.BOOL: - self.success = iprot.readBool(); + if ftype == TType.LIST: + self.success = [] + (_etype149, _size146) = iprot.readListBegin() + for _i150 in xrange(_size146): + _elem151 = iprot.readString(); + self.success.append(_elem151) + iprot.readListEnd() else: iprot.skip(ftype) elif fid == 1: @@ -20804,10 +22437,13 @@ class deleteApplicationModule_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('deleteApplicationModule_result') + oprot.writeStructBegin('getAppModuleDeployedResources_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.BOOL, 0) - oprot.writeBool(self.success) + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRING, len(self.success)) + for iter152 in self.success: + oprot.writeString(iter152) + oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -20852,25 +22488,25 @@ class deleteApplicationModule_result: def __ne__(self, other): return not (self == other) -class registerApplicationDeployment_args: +class registerApplicationInterface_args: """ Attributes: - authzToken - gatewayId - - applicationDeployment + - applicationInterface """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 (2, TType.STRING, 'gatewayId', None, None, ), # 2 - (3, TType.STRUCT, 'applicationDeployment', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription.thrift_spec), None, ), # 3 + (3, TType.STRUCT, 'applicationInterface', (apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription, apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription.thrift_spec), None, ), # 3 ) - def __init__(self, authzToken=None, gatewayId=None, applicationDeployment=None,): + def __init__(self, authzToken=None, gatewayId=None, applicationInterface=None,): self.authzToken = authzToken self.gatewayId = gatewayId - self.applicationDeployment = applicationDeployment + self.applicationInterface = applicationInterface def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -20894,8 +22530,8 @@ class registerApplicationDeployment_args: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRUCT: - self.applicationDeployment = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() - self.applicationDeployment.read(iprot) + self.applicationInterface = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() + self.applicationInterface.read(iprot) else: iprot.skip(ftype) else: @@ -20907,7 +22543,7 @@ class registerApplicationDeployment_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('registerApplicationDeployment_args') + oprot.writeStructBegin('registerApplicationInterface_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -20916,9 +22552,9 @@ class registerApplicationDeployment_args: oprot.writeFieldBegin('gatewayId', TType.STRING, 2) oprot.writeString(self.gatewayId) oprot.writeFieldEnd() - if self.applicationDeployment is not None: - oprot.writeFieldBegin('applicationDeployment', TType.STRUCT, 3) - self.applicationDeployment.write(oprot) + if self.applicationInterface is not None: + oprot.writeFieldBegin('applicationInterface', TType.STRUCT, 3) + self.applicationInterface.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -20928,8 +22564,8 @@ class registerApplicationDeployment_args: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') if self.gatewayId is None: raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') - if self.applicationDeployment is None: - raise TProtocol.TProtocolException(message='Required field applicationDeployment is unset!') + if self.applicationInterface is None: + raise TProtocol.TProtocolException(message='Required field applicationInterface is unset!') return @@ -20937,7 +22573,7 @@ class registerApplicationDeployment_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.applicationDeployment) + value = (value * 31) ^ hash(self.applicationInterface) return value def __repr__(self): @@ -20951,7 +22587,7 @@ class registerApplicationDeployment_args: def __ne__(self, other): return not (self == other) -class registerApplicationDeployment_result: +class registerApplicationInterface_result: """ Attributes: - success @@ -21023,7 +22659,7 @@ class registerApplicationDeployment_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('registerApplicationDeployment_result') + oprot.writeStructBegin('registerApplicationInterface_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRING, 0) oprot.writeString(self.success) @@ -21071,22 +22707,22 @@ class registerApplicationDeployment_result: def __ne__(self, other): return not (self == other) -class getApplicationDeployment_args: +class getApplicationInterface_args: """ Attributes: - authzToken - - appDeploymentId + - appInterfaceId """ thrift_spec = ( None, # 0 (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 - (2, TType.STRING, 'appDeploymentId', None, None, ), # 2 + (2, TType.STRING, 'appInterfaceId', None, None, ), # 2 ) - def __init__(self, authzToken=None, appDeploymentId=None,): + def __init__(self, authzToken=None, appInterfaceId=None,): self.authzToken = authzToken - self.appDeploymentId = appDeploymentId + self.appInterfaceId = appInterfaceId def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -21105,7 +22741,7 @@ class getApplicationDeployment_args: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.appDeploymentId = iprot.readString(); + self.appInterfaceId = iprot.readString(); else: iprot.skip(ftype) else: @@ -21117,14 +22753,14 @@ class getApplicationDeployment_args: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('getApplicationDeployment_args') + oprot.writeStructBegin('getApplicationInterface_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) oprot.writeFieldEnd() - if self.appDeploymentId is not None: - oprot.writeFieldBegin('appDeploymentId', TType.STRING, 2) - oprot.writeString(self.appDeploymentId) + if self.appInterfaceId is not None: + oprot.writeFieldBegin('appInterfaceId', TType.STRING, 2) + oprot.writeString(self.appInterfaceId) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -21132,15 +22768,15 @@ class getApplicationDeployment_args: def validate(self): if self.authzToken is None: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') - if self.appDeploymentId is None: - raise TProtocol.TProtocolException(message='Required field appDeploymentId is unset!') + if self.appInterfaceId is None: + raise TProtocol.TProtocolException(message='Required field appInterfaceId is unset!') return def __hash__(self): value = 17 value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.appDeploymentId) + value = (value * 31) ^ hash(self.appInterfaceId) return value def __repr__(self): @@ -21154,7 +22790,7 @@ class getApplicationDeployment_args: def __ne__(self, other): return not (self == other) -class getApplicationDeployment_result: +class getApplicationInterface_result: """ Attributes: - success @@ -21165,7 +22801,7 @@ class getApplicationDeployment_result: """ thrift_spec = ( - (0, TType.STRUCT, 'success', (apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription.thrift_spec), None, ), # 0 + (0, TType.STRUCT, 'success', (apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription, apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription.thrift_spec), None, ), # 0 (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 @@ -21190,7 +22826,7 @@ class getApplicationDeployment_result: break
<TRUNCATED>
