http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/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 6d24166..2161889 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 @@ -2623,62 +2623,6 @@ class Iface: """ pass - def registerDataResource(self, authzToken, dataResourceModel): - """ - * Data Manager Related API Methods - * - - Parameters: - - authzToken - - dataResourceModel - """ - pass - - def updateDataResource(self, authzToken, dataResourceModel): - """ - Parameters: - - authzToken - - dataResourceModel - """ - pass - - def removeDataResource(self, authzToken, resourceId): - """ - Parameters: - - authzToken - - resourceId - """ - pass - - def getDataResource(self, authzToken, resourceId): - """ - Parameters: - - authzToken - - resourceId - """ - pass - - def copyDataResource(self, authzToken, resourceId, destStorageResourceId, destinationParentPath): - """ - Parameters: - - authzToken - - resourceId - - destStorageResourceId - - destinationParentPath - """ - pass - - def copyDataReplica(self, authzToken, resourceId, replicaId, destStorageResourceId, destinationParentPath): - """ - Parameters: - - authzToken - - resourceId - - replicaId - - destStorageResourceId - - destinationParentPath - """ - pass - class Client(Iface): def __init__(self, iprot, oprot=None): @@ -9749,261 +9693,6 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "isWorkflowExistWithName failed: unknown result") - def registerDataResource(self, authzToken, dataResourceModel): - """ - * Data Manager Related API Methods - * - - Parameters: - - authzToken - - dataResourceModel - """ - self.send_registerDataResource(authzToken, dataResourceModel) - return self.recv_registerDataResource() - - def send_registerDataResource(self, authzToken, dataResourceModel): - self._oprot.writeMessageBegin('registerDataResource', TMessageType.CALL, self._seqid) - args = registerDataResource_args() - args.authzToken = authzToken - args.dataResourceModel = dataResourceModel - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_registerDataResource(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = registerDataResource_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, "registerDataResource failed: unknown result") - - def updateDataResource(self, authzToken, dataResourceModel): - """ - Parameters: - - authzToken - - dataResourceModel - """ - self.send_updateDataResource(authzToken, dataResourceModel) - self.recv_updateDataResource() - - def send_updateDataResource(self, authzToken, dataResourceModel): - self._oprot.writeMessageBegin('updateDataResource', TMessageType.CALL, self._seqid) - args = updateDataResource_args() - args.authzToken = authzToken - args.dataResourceModel = dataResourceModel - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_updateDataResource(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = updateDataResource_result() - result.read(iprot) - iprot.readMessageEnd() - 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 - return - - def removeDataResource(self, authzToken, resourceId): - """ - Parameters: - - authzToken - - resourceId - """ - self.send_removeDataResource(authzToken, resourceId) - self.recv_removeDataResource() - - def send_removeDataResource(self, authzToken, resourceId): - self._oprot.writeMessageBegin('removeDataResource', TMessageType.CALL, self._seqid) - args = removeDataResource_args() - args.authzToken = authzToken - args.resourceId = resourceId - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_removeDataResource(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = removeDataResource_result() - result.read(iprot) - iprot.readMessageEnd() - 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 - return - - def getDataResource(self, authzToken, resourceId): - """ - Parameters: - - authzToken - - resourceId - """ - self.send_getDataResource(authzToken, resourceId) - return self.recv_getDataResource() - - def send_getDataResource(self, authzToken, resourceId): - self._oprot.writeMessageBegin('getDataResource', TMessageType.CALL, self._seqid) - args = getDataResource_args() - args.authzToken = authzToken - args.resourceId = resourceId - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_getDataResource(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = getDataResource_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, "getDataResource failed: unknown result") - - def copyDataResource(self, authzToken, resourceId, destStorageResourceId, destinationParentPath): - """ - Parameters: - - authzToken - - resourceId - - destStorageResourceId - - destinationParentPath - """ - self.send_copyDataResource(authzToken, resourceId, destStorageResourceId, destinationParentPath) - return self.recv_copyDataResource() - - def send_copyDataResource(self, authzToken, resourceId, destStorageResourceId, destinationParentPath): - self._oprot.writeMessageBegin('copyDataResource', TMessageType.CALL, self._seqid) - args = copyDataResource_args() - args.authzToken = authzToken - args.resourceId = resourceId - args.destStorageResourceId = destStorageResourceId - args.destinationParentPath = destinationParentPath - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_copyDataResource(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = copyDataResource_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, "copyDataResource failed: unknown result") - - def copyDataReplica(self, authzToken, resourceId, replicaId, destStorageResourceId, destinationParentPath): - """ - Parameters: - - authzToken - - resourceId - - replicaId - - destStorageResourceId - - destinationParentPath - """ - self.send_copyDataReplica(authzToken, resourceId, replicaId, destStorageResourceId, destinationParentPath) - return self.recv_copyDataReplica() - - def send_copyDataReplica(self, authzToken, resourceId, replicaId, destStorageResourceId, destinationParentPath): - self._oprot.writeMessageBegin('copyDataReplica', TMessageType.CALL, self._seqid) - args = copyDataReplica_args() - args.authzToken = authzToken - args.resourceId = resourceId - args.replicaId = replicaId - args.destStorageResourceId = destStorageResourceId - args.destinationParentPath = destinationParentPath - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_copyDataReplica(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = copyDataReplica_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, "copyDataReplica failed: unknown result") - class Processor(Iface, TProcessor): def __init__(self, handler): @@ -10141,12 +9830,6 @@ class Processor(Iface, TProcessor): self._processMap["updateWorkflow"] = Processor.process_updateWorkflow self._processMap["getWorkflowTemplateId"] = Processor.process_getWorkflowTemplateId self._processMap["isWorkflowExistWithName"] = Processor.process_isWorkflowExistWithName - self._processMap["registerDataResource"] = Processor.process_registerDataResource - self._processMap["updateDataResource"] = Processor.process_updateDataResource - self._processMap["removeDataResource"] = Processor.process_removeDataResource - self._processMap["getDataResource"] = Processor.process_getDataResource - self._processMap["copyDataResource"] = Processor.process_copyDataResource - self._processMap["copyDataReplica"] = Processor.process_copyDataReplica def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -14270,192 +13953,6 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_registerDataResource(self, seqid, iprot, oprot): - args = registerDataResource_args() - args.read(iprot) - iprot.readMessageEnd() - result = registerDataResource_result() - try: - result.success = self._handler.registerDataResource(args.authzToken, args.dataResourceModel) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except apache.airavata.api.error.ttypes.InvalidRequestException as ire: - msg_type = TMessageType.REPLY - result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException as ace: - msg_type = TMessageType.REPLY - result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException as ase: - msg_type = TMessageType.REPLY - result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException as ae: - msg_type = TMessageType.REPLY - result.ae = ae - except Exception as ex: - msg_type = TMessageType.EXCEPTION - logging.exception(ex) - result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') - oprot.writeMessageBegin("registerDataResource", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_updateDataResource(self, seqid, iprot, oprot): - args = updateDataResource_args() - args.read(iprot) - iprot.readMessageEnd() - result = updateDataResource_result() - try: - self._handler.updateDataResource(args.authzToken, args.dataResourceModel) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except apache.airavata.api.error.ttypes.InvalidRequestException as ire: - msg_type = TMessageType.REPLY - result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException as ace: - msg_type = TMessageType.REPLY - result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException as ase: - msg_type = TMessageType.REPLY - result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException as ae: - msg_type = TMessageType.REPLY - result.ae = ae - except Exception as ex: - msg_type = TMessageType.EXCEPTION - logging.exception(ex) - result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') - oprot.writeMessageBegin("updateDataResource", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_removeDataResource(self, seqid, iprot, oprot): - args = removeDataResource_args() - args.read(iprot) - iprot.readMessageEnd() - result = removeDataResource_result() - try: - self._handler.removeDataResource(args.authzToken, args.resourceId) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except apache.airavata.api.error.ttypes.InvalidRequestException as ire: - msg_type = TMessageType.REPLY - result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException as ace: - msg_type = TMessageType.REPLY - result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException as ase: - msg_type = TMessageType.REPLY - result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException as ae: - msg_type = TMessageType.REPLY - result.ae = ae - except Exception as ex: - msg_type = TMessageType.EXCEPTION - logging.exception(ex) - result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') - oprot.writeMessageBegin("removeDataResource", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_getDataResource(self, seqid, iprot, oprot): - args = getDataResource_args() - args.read(iprot) - iprot.readMessageEnd() - result = getDataResource_result() - try: - result.success = self._handler.getDataResource(args.authzToken, args.resourceId) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except apache.airavata.api.error.ttypes.InvalidRequestException as ire: - msg_type = TMessageType.REPLY - result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException as ace: - msg_type = TMessageType.REPLY - result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException as ase: - msg_type = TMessageType.REPLY - result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException as ae: - msg_type = TMessageType.REPLY - result.ae = ae - except Exception as ex: - msg_type = TMessageType.EXCEPTION - logging.exception(ex) - result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') - oprot.writeMessageBegin("getDataResource", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_copyDataResource(self, seqid, iprot, oprot): - args = copyDataResource_args() - args.read(iprot) - iprot.readMessageEnd() - result = copyDataResource_result() - try: - result.success = self._handler.copyDataResource(args.authzToken, args.resourceId, args.destStorageResourceId, args.destinationParentPath) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except apache.airavata.api.error.ttypes.InvalidRequestException as ire: - msg_type = TMessageType.REPLY - result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException as ace: - msg_type = TMessageType.REPLY - result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException as ase: - msg_type = TMessageType.REPLY - result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException as ae: - msg_type = TMessageType.REPLY - result.ae = ae - except Exception as ex: - msg_type = TMessageType.EXCEPTION - logging.exception(ex) - result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') - oprot.writeMessageBegin("copyDataResource", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_copyDataReplica(self, seqid, iprot, oprot): - args = copyDataReplica_args() - args.read(iprot) - iprot.readMessageEnd() - result = copyDataReplica_result() - try: - result.success = self._handler.copyDataReplica(args.authzToken, args.resourceId, args.replicaId, args.destStorageResourceId, args.destinationParentPath) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except apache.airavata.api.error.ttypes.InvalidRequestException as ire: - msg_type = TMessageType.REPLY - result.ire = ire - except apache.airavata.api.error.ttypes.AiravataClientException as ace: - msg_type = TMessageType.REPLY - result.ace = ace - except apache.airavata.api.error.ttypes.AiravataSystemException as ase: - msg_type = TMessageType.REPLY - result.ase = ase - except apache.airavata.api.error.ttypes.AuthorizationException as ae: - msg_type = TMessageType.REPLY - result.ae = ae - except Exception as ex: - msg_type = TMessageType.EXCEPTION - logging.exception(ex) - result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') - oprot.writeMessageBegin("copyDataReplica", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - # HELPER FUNCTIONS AND STRUCTURES @@ -24790,1082 +24287,25 @@ class getApplicationModule_result: def __ne__(self, other): return not (self == other) -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 = [] - (_etype144, _size141) = iprot.readListBegin() - for _i145 in xrange(_size141): - _elem146 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() - _elem146.read(iprot) - self.success.append(_elem146) - 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 iter147 in self.success: - iter147.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: +class updateApplicationModule_args: """ Attributes: - authzToken - - appDeploymentId - - applicationDeployment + - 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, '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 + (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, appDeploymentId=None, applicationDeployment=None,): + def __init__(self, authzToken=None, appModuleId=None, applicationModule=None,): self.authzToken = authzToken - self.appDeploymentId = appDeploymentId - self.applicationDeployment = applicationDeployment + 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: @@ -25884,13 +24324,13 @@ class updateApplicationDeployment_args: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.appDeploymentId = iprot.readString() + self.appModuleId = 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) + self.applicationModule = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + self.applicationModule.read(iprot) else: iprot.skip(ftype) else: @@ -25902,224 +24342,18 @@ class updateApplicationDeployment_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('updateApplicationDeployment_args') + oprot.writeStructBegin('updateApplicationModule_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 - - 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('deleteApplicationDeployment_args') - if self.authzToken is not None: - oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) - self.authzToken.write(oprot) + if self.appModuleId is not None: + oprot.writeFieldBegin('appModuleId', TType.STRING, 2) + oprot.writeString(self.appModuleId) oprot.writeFieldEnd() - if self.appDeploymentId is not None: - oprot.writeFieldBegin('appDeploymentId', TType.STRING, 2) - oprot.writeString(self.appDeploymentId) + if self.applicationModule is not None: + oprot.writeFieldBegin('applicationModule', TType.STRUCT, 3) + self.applicationModule.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -26127,15 +24361,18 @@ class deleteApplicationDeployment_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.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.appDeploymentId) + value = (value * 31) ^ hash(self.appModuleId) + value = (value * 31) ^ hash(self.applicationModule) return value def __repr__(self): @@ -26149,7 +24386,7 @@ class deleteApplicationDeployment_args: def __ne__(self, other): return not (self == other) -class deleteApplicationDeployment_result: +class updateApplicationModule_result: """ Attributes: - success @@ -26221,7 +24458,7 @@ class deleteApplicationDeployment_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('deleteApplicationDeployment_result') + oprot.writeStructBegin('updateApplicationModule_result') if self.success is not None: oprot.writeFieldBegin('success', TType.BOOL, 0) oprot.writeBool(self.success) @@ -26269,7 +24506,7 @@ class deleteApplicationDeployment_result: def __ne__(self, other): return not (self == other) -class getAllApplicationDeployments_args: +class getAllAppModules_args: """ Attributes: - authzToken @@ -26315,7 +24552,7 @@ class getAllApplicationDeployments_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('getAllApplicationDeployments_args') + oprot.writeStructBegin('getAllAppModules_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -26352,7 +24589,7 @@ class getAllApplicationDeployments_args: def __ne__(self, other): return not (self == other) -class getAllApplicationDeployments_result: +class getAllAppModules_result: """ Attributes: - success @@ -26363,7 +24600,7 @@ class getAllApplicationDeployments_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription, apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription.thrift_spec)), None, ), # 0 + (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 @@ -26389,11 +24626,11 @@ class getAllApplicationDeployments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype151, _size148) = iprot.readListBegin() - for _i152 in xrange(_size148): - _elem153 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() - _elem153.read(iprot) - self.success.append(_elem153) + (_etype144, _size141) = iprot.readListBegin() + for _i145 in xrange(_size141): + _elem146 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + _elem146.read(iprot) + self.success.append(_elem146) iprot.readListEnd() else: iprot.skip(ftype) @@ -26430,12 +24667,12 @@ class getAllApplicationDeployments_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('getAllApplicationDeployments_result') + oprot.writeStructBegin('getAllAppModules_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter154 in self.success: - iter154.write(oprot) + for iter147 in self.success: + iter147.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26481,7 +24718,7 @@ class getAllApplicationDeployments_result: def __ne__(self, other): return not (self == other) -class getAppModuleDeployedResources_args: +class deleteApplicationModule_args: """ Attributes: - authzToken @@ -26527,7 +24764,7 @@ class getAppModuleDeployedResources_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('getAppModuleDeployedResources_args') + oprot.writeStructBegin('deleteApplicationModule_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -26564,7 +24801,7 @@ class getAppModuleDeployedResources_args: def __ne__(self, other): return not (self == other) -class getAppModuleDeployedResources_result: +class deleteApplicationModule_result: """ Attributes: - success @@ -26575,7 +24812,7 @@ class getAppModuleDeployedResources_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 + (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 @@ -26599,13 +24836,8 @@ class getAppModuleDeployedResources_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype158, _size155) = iprot.readListBegin() - for _i159 in xrange(_size155): - _elem160 = iprot.readString() - self.success.append(_elem160) - iprot.readListEnd() + if ftype == TType.BOOL: + self.success = iprot.readBool() else: iprot.skip(ftype) elif fid == 1: @@ -26641,13 +24873,10 @@ class getAppModuleDeployedResources_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('getAppModuleDeployedResources_result') + oprot.writeStructBegin('deleteApplicationModule_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRING, len(self.success)) - for iter161 in self.success: - oprot.writeString(iter161) - oprot.writeListEnd() + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -26692,25 +24921,25 @@ class getAppModuleDeployedResources_result: def __ne__(self, other): return not (self == other) -class registerApplicationInterface_args: +class registerApplicationDeployment_args: """ Attributes: - authzToken - gatewayId - - applicationInterface + - 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, 'applicationInterface', (apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription, apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription.thrift_spec), None, ), # 3 + (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, applicationInterface=None,): + def __init__(self, authzToken=None, gatewayId=None, applicationDeployment=None,): self.authzToken = authzToken self.gatewayId = gatewayId - self.applicationInterface = applicationInterface + 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: @@ -26734,8 +24963,8 @@ class registerApplicationInterface_args: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRUCT: - self.applicationInterface = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() - self.applicationInterface.read(iprot) + self.applicationDeployment = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + self.applicationDeployment.read(iprot) else: iprot.skip(ftype) else: @@ -26747,7 +24976,7 @@ class registerApplicationInterface_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('registerApplicationInterface_args') + oprot.writeStructBegin('registerApplicationDeployment_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -26756,9 +24985,9 @@ class registerApplicationInterface_args: oprot.writeFieldBegin('gatewayId', TType.STRING, 2) oprot.writeString(self.gatewayId) oprot.writeFieldEnd() - if self.applicationInterface is not None: - oprot.writeFieldBegin('applicationInterface', TType.STRUCT, 3) - self.applicationInterface.write(oprot) + if self.applicationDeployment is not None: + oprot.writeFieldBegin('applicationDeployment', TType.STRUCT, 3) + self.applicationDeployment.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -26768,8 +24997,8 @@ class registerApplicationInterface_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.applicationInterface is None: - raise TProtocol.TProtocolException(message='Required field applicationInterface is unset!') + if self.applicationDeployment is None: + raise TProtocol.TProtocolException(message='Required field applicationDeployment is unset!') return @@ -26777,7 +25006,7 @@ class registerApplicationInterface_args: value = 17 value = (value * 31) ^ hash(self.authzToken) value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.applicationInterface) + value = (value * 31) ^ hash(self.applicationDeployment) return value def __repr__(self): @@ -26791,7 +25020,7 @@ class registerApplicationInterface_args: def __ne__(self, other): return not (self == other) -class registerApplicationInterface_result: +class registerApplicationDeployment_result: """ Attributes: - success @@ -26863,7 +25092,7 @@ class registerApplicationInterface_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('registerApplicationInterface_result') + oprot.writeStructBegin('registerApplicationDeployment_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRING, 0) oprot.writeString(self.success) @@ -26911,22 +25140,22 @@ class registerApplicationInterface_result: def __ne__(self, other): return not (self == other) -class getApplicationInterface_args: +class getApplicationDeployment_args: """ Attributes: - authzToken - - appInterfaceId + - 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, 'appInterfaceId', None, None, ), # 2 + (2, TType.STRING, 'appDeploymentId', None, None, ), # 2 ) - def __init__(self, authzToken=None, appInterfaceId=None,): + def __init__(self, authzToken=None, appDeploymentId=None,): self.authzToken = authzToken - self.appInterfaceId = appInterfaceId + 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: @@ -26945,7 +25174,7 @@ class getApplicationInterface_args: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.appInterfaceId = iprot.readString() + self.appDeploymentId = iprot.readString() else: iprot.skip(ftype) else: @@ -26957,14 +25186,14 @@ class getApplicationInterface_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('getApplicationInterface_args') + oprot.writeStructBegin('getApplicationDeployment_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) oprot.writeFieldEnd() - if self.appInterfaceId is not None: - oprot.writeFieldBegin('appInterfaceId', TType.STRING, 2) - oprot.writeString(self.appInterfaceId) + if self.appDeploymentId is not None: + oprot.writeFieldBegin('appDeploymentId', TType.STRING, 2) + oprot.writeString(self.appDeploymentId) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -26972,15 +25201,15 @@ class getApplicationInterface_args: def validate(self): if self.authzToken is None: raise TProtocol.TProtocolException(message='Required field authzToken is unset!') - if self.appInterfaceId is None: - raise TProtocol.TProtocolException(message='Required field appInterfaceId 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.appInterfaceId) + value = (value * 31) ^ hash(self.appDeploymentId) return value def __repr__(self): @@ -26994,7 +25223,7 @@ class getApplicationInterface_args: def __ne__(self, other): return not (self == other) -class getApplicationInterface_result: +class getApplicationDeployment_result: """ Attributes: - success @@ -27005,7 +25234,7 @@ class getApplicationInterface_result: """ thrift_spec = ( - (0, TType.STRUCT, 'success', (apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription, apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription.thrift_spec), None, ), # 0 + (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 @@ -27030,7 +25259,7 @@ class getApplicationInterface_result: break if fid == 0: if ftype == TType.STRUCT: - self.success = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() + self.success = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() self.success.read(iprot) else: iprot.skip(ftype) @@ -27067,7 +25296,7 @@ class getApplicationInterface_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: o
<TRUNCATED>
