http://git-wip-us.apache.org/repos/asf/airavata/blob/325d1630/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 e868a3c..e0188bf 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 @@ -241,6 +241,34 @@ class Iface: """ pass + def generateAndRegisterSSHKeysWithDescription(self, authzToken, gatewayId, userName, description): + """ + Generate and Register SSH Key Pair with Airavata Credential Store. + + @param gatewayId + The identifier for the requested Gateway. + + @param userName + The User for which the credential should be registered. For community accounts, this user is the name of the + community user name. For computational resources, this user name need not be the same user name on resoruces. + + @param description + The description field for a credential type, all type of credential can have a description. + + @return airavataCredStoreToken + An SSH Key pair is generated and stored in the credential store and associated with users or community account + belonging to a Gateway. + + + + Parameters: + - authzToken + - gatewayId + - userName + - description + """ + pass + def registerPwdCredential(self, authzToken, gatewayId, portalUserName, loginUserName, password, description): """ Generate and Register Username PWD Pair with Airavata Credential Store. @@ -314,6 +342,52 @@ class Iface: """ pass + def getAllGatewaySSHPubKeysSummary(self, authzToken, gatewayId): + """ + + Get all Public Keys of the Gateway + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return publicKey + + + + Parameters: + - authzToken + - gatewayId + """ + pass + + def getAllSSHPubKeysSummaryForUserInGateway(self, authzToken, gatewayId, userId): + """ + + Get all Public Key summaries for user in a Gateway + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @param userId + This is the unique identifier of user whose public keys are to be fetched. + + @return CredentialSummary + + + + Parameters: + - authzToken + - gatewayId + - userId + """ + pass + def getAllGatewayPWDCredentials(self, authzToken, gatewayId): """ Parameters: @@ -4000,6 +4074,67 @@ class Client(Iface): raise result.ase raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result") + def generateAndRegisterSSHKeysWithDescription(self, authzToken, gatewayId, userName, description): + """ + Generate and Register SSH Key Pair with Airavata Credential Store. + + @param gatewayId + The identifier for the requested Gateway. + + @param userName + The User for which the credential should be registered. For community accounts, this user is the name of the + community user name. For computational resources, this user name need not be the same user name on resoruces. + + @param description + The description field for a credential type, all type of credential can have a description. + + @return airavataCredStoreToken + An SSH Key pair is generated and stored in the credential store and associated with users or community account + belonging to a Gateway. + + + + Parameters: + - authzToken + - gatewayId + - userName + - description + """ + self.send_generateAndRegisterSSHKeysWithDescription(authzToken, gatewayId, userName, description) + return self.recv_generateAndRegisterSSHKeysWithDescription() + + def send_generateAndRegisterSSHKeysWithDescription(self, authzToken, gatewayId, userName, description): + self._oprot.writeMessageBegin('generateAndRegisterSSHKeysWithDescription', TMessageType.CALL, self._seqid) + args = generateAndRegisterSSHKeysWithDescription_args() + args.authzToken = authzToken + args.gatewayId = gatewayId + args.userName = userName + args.description = description + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_generateAndRegisterSSHKeysWithDescription(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = generateAndRegisterSSHKeysWithDescription_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndRegisterSSHKeysWithDescription failed: unknown result") + def registerPwdCredential(self, authzToken, gatewayId, portalUserName, loginUserName, password, description): """ Generate and Register Username PWD Pair with Airavata Credential Store. @@ -4171,6 +4306,115 @@ class Client(Iface): raise result.ase raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result") + def getAllGatewaySSHPubKeysSummary(self, authzToken, gatewayId): + """ + + Get all Public Keys of the Gateway + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @return publicKey + + + + Parameters: + - authzToken + - gatewayId + """ + self.send_getAllGatewaySSHPubKeysSummary(authzToken, gatewayId) + return self.recv_getAllGatewaySSHPubKeysSummary() + + def send_getAllGatewaySSHPubKeysSummary(self, authzToken, gatewayId): + self._oprot.writeMessageBegin('getAllGatewaySSHPubKeysSummary', TMessageType.CALL, self._seqid) + args = getAllGatewaySSHPubKeysSummary_args() + args.authzToken = authzToken + args.gatewayId = gatewayId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllGatewaySSHPubKeysSummary(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getAllGatewaySSHPubKeysSummary_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllGatewaySSHPubKeysSummary failed: unknown result") + + def getAllSSHPubKeysSummaryForUserInGateway(self, authzToken, gatewayId, userId): + """ + + Get all Public Key summaries for user in a Gateway + + @param CredStoreToken + Credential Store Token which you want to find the Public Key for. + + @param gatewayId + This is the unique identifier of your gateway where the token and public key was generated from. + + @param userId + This is the unique identifier of user whose public keys are to be fetched. + + @return CredentialSummary + + + + Parameters: + - authzToken + - gatewayId + - userId + """ + self.send_getAllSSHPubKeysSummaryForUserInGateway(authzToken, gatewayId, userId) + return self.recv_getAllSSHPubKeysSummaryForUserInGateway() + + def send_getAllSSHPubKeysSummaryForUserInGateway(self, authzToken, gatewayId, userId): + self._oprot.writeMessageBegin('getAllSSHPubKeysSummaryForUserInGateway', TMessageType.CALL, self._seqid) + args = getAllSSHPubKeysSummaryForUserInGateway_args() + args.authzToken = authzToken + args.gatewayId = gatewayId + args.userId = userId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllSSHPubKeysSummaryForUserInGateway(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getAllSSHPubKeysSummaryForUserInGateway_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ire is not None: + raise result.ire + if result.ace is not None: + raise result.ace + if result.ase is not None: + raise result.ase + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllSSHPubKeysSummaryForUserInGateway failed: unknown result") + def getAllGatewayPWDCredentials(self, authzToken, gatewayId): """ Parameters: @@ -12089,9 +12333,12 @@ class Processor(Iface, TProcessor): self._processMap["getNotification"] = Processor.process_getNotification self._processMap["getAllNotifications"] = Processor.process_getAllNotifications self._processMap["generateAndRegisterSSHKeys"] = Processor.process_generateAndRegisterSSHKeys + self._processMap["generateAndRegisterSSHKeysWithDescription"] = Processor.process_generateAndRegisterSSHKeysWithDescription self._processMap["registerPwdCredential"] = Processor.process_registerPwdCredential self._processMap["getSSHPubKey"] = Processor.process_getSSHPubKey self._processMap["getAllGatewaySSHPubKeys"] = Processor.process_getAllGatewaySSHPubKeys + self._processMap["getAllGatewaySSHPubKeysSummary"] = Processor.process_getAllGatewaySSHPubKeysSummary + self._processMap["getAllSSHPubKeysSummaryForUserInGateway"] = Processor.process_getAllSSHPubKeysSummaryForUserInGateway self._processMap["getAllGatewayPWDCredentials"] = Processor.process_getAllGatewayPWDCredentials self._processMap["deleteSSHPubKey"] = Processor.process_deleteSSHPubKey self._processMap["deletePWDCredential"] = Processor.process_deletePWDCredential @@ -12716,6 +12963,34 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_generateAndRegisterSSHKeysWithDescription(self, seqid, iprot, oprot): + args = generateAndRegisterSSHKeysWithDescription_args() + args.read(iprot) + iprot.readMessageEnd() + result = generateAndRegisterSSHKeysWithDescription_result() + try: + result.success = self._handler.generateAndRegisterSSHKeysWithDescription(args.authzToken, args.gatewayId, args.userName, args.description) + 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 Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("generateAndRegisterSSHKeysWithDescription", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_registerPwdCredential(self, seqid, iprot, oprot): args = registerPwdCredential_args() args.read(iprot) @@ -12800,6 +13075,62 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_getAllGatewaySSHPubKeysSummary(self, seqid, iprot, oprot): + args = getAllGatewaySSHPubKeysSummary_args() + args.read(iprot) + iprot.readMessageEnd() + result = getAllGatewaySSHPubKeysSummary_result() + try: + result.success = self._handler.getAllGatewaySSHPubKeysSummary(args.authzToken, args.gatewayId) + 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 Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAllGatewaySSHPubKeysSummary", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_getAllSSHPubKeysSummaryForUserInGateway(self, seqid, iprot, oprot): + args = getAllSSHPubKeysSummaryForUserInGateway_args() + args.read(iprot) + iprot.readMessageEnd() + result = getAllSSHPubKeysSummaryForUserInGateway_result() + try: + result.success = self._handler.getAllSSHPubKeysSummaryForUserInGateway(args.authzToken, args.gatewayId, args.userId) + 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 Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("getAllSSHPubKeysSummaryForUserInGateway", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_getAllGatewayPWDCredentials(self, seqid, iprot, oprot): args = getAllGatewayPWDCredentials_args() args.read(iprot) @@ -20458,6 +20789,225 @@ class generateAndRegisterSSHKeys_result: def __ne__(self, other): return not (self == other) +class generateAndRegisterSSHKeysWithDescription_args: + """ + Attributes: + - authzToken + - gatewayId + - userName + - description + """ + + 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.STRING, 'userName', None, None, ), # 3 + (4, TType.STRING, 'description', None, None, ), # 4 + ) + + def __init__(self, authzToken=None, gatewayId=None, userName=None, description=None,): + self.authzToken = authzToken + self.gatewayId = gatewayId + self.userName = userName + self.description = description + + 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.STRING: + self.userName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.description = 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('generateAndRegisterSSHKeysWithDescription_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.userName is not None: + oprot.writeFieldBegin('userName', TType.STRING, 3) + oprot.writeString(self.userName) + oprot.writeFieldEnd() + if self.description is not None: + oprot.writeFieldBegin('description', TType.STRING, 4) + oprot.writeString(self.description) + 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.userName is None: + raise TProtocol.TProtocolException(message='Required field userName is unset!') + if self.description is None: + raise TProtocol.TProtocolException(message='Required field description 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.userName) + value = (value * 31) ^ hash(self.description) + 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 generateAndRegisterSSHKeysWithDescription_result: + """ + Attributes: + - success + - ire + - ace + - ase + """ + + 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 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + + 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) + 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('generateAndRegisterSSHKeysWithDescription_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() + 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) + 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 registerPwdCredential_args: """ Attributes: @@ -21110,7 +21660,7 @@ class getAllGatewaySSHPubKeys_result: def __ne__(self, other): return not (self == other) -class getAllGatewayPWDCredentials_args: +class getAllGatewaySSHPubKeysSummary_args: """ Attributes: - authzToken @@ -21156,7 +21706,7 @@ class getAllGatewayPWDCredentials_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('getAllGatewayPWDCredentials_args') + oprot.writeStructBegin('getAllGatewaySSHPubKeysSummary_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -21193,7 +21743,7 @@ class getAllGatewayPWDCredentials_args: def __ne__(self, other): return not (self == other) -class getAllGatewayPWDCredentials_result: +class getAllGatewaySSHPubKeysSummary_result: """ Attributes: - success @@ -21203,7 +21753,7 @@ class getAllGatewayPWDCredentials_result: """ thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.STRING,None), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.credentialsummary.ttypes.CredentialSummary, apache.airavata.model.appcatalog.credentialsummary.ttypes.CredentialSummary.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 @@ -21225,14 +21775,14 @@ class getAllGatewayPWDCredentials_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.MAP: - self.success = {} - (_ktype31, _vtype32, _size30 ) = iprot.readMapBegin() + if ftype == TType.LIST: + self.success = [] + (_etype33, _size30) = iprot.readListBegin() for _i34 in xrange(_size30): - _key35 = iprot.readString() - _val36 = iprot.readString() - self.success[_key35] = _val36 - iprot.readMapEnd() + _elem35 = apache.airavata.model.appcatalog.credentialsummary.ttypes.CredentialSummary() + _elem35.read(iprot) + self.success.append(_elem35) + iprot.readListEnd() else: iprot.skip(ftype) elif fid == 1: @@ -21262,14 +21812,13 @@ class getAllGatewayPWDCredentials_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('getAllGatewayPWDCredentials_result') + oprot.writeStructBegin('getAllGatewaySSHPubKeysSummary_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.MAP, 0) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter37,viter38 in self.success.items(): - oprot.writeString(kiter37) - oprot.writeString(viter38) - oprot.writeMapEnd() + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter36 in self.success: + iter36.write(oprot) + oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: oprot.writeFieldBegin('ire', TType.STRUCT, 1) @@ -21309,25 +21858,25 @@ class getAllGatewayPWDCredentials_result: def __ne__(self, other): return not (self == other) -class deleteSSHPubKey_args: +class getAllSSHPubKeysSummaryForUserInGateway_args: """ Attributes: - authzToken - - airavataCredStoreToken - gatewayId + - userId """ 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, 'airavataCredStoreToken', None, None, ), # 2 - (3, TType.STRING, 'gatewayId', None, None, ), # 3 + (2, TType.STRING, 'gatewayId', None, None, ), # 2 + (3, TType.STRING, 'userId', None, None, ), # 3 ) - def __init__(self, authzToken=None, airavataCredStoreToken=None, gatewayId=None,): + def __init__(self, authzToken=None, gatewayId=None, userId=None,): self.authzToken = authzToken - self.airavataCredStoreToken = airavataCredStoreToken self.gatewayId = gatewayId + self.userId = userId 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: @@ -21346,12 +21895,12 @@ class deleteSSHPubKey_args: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.airavataCredStoreToken = iprot.readString() + self.gatewayId = iprot.readString() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.STRING: - self.gatewayId = iprot.readString() + self.userId = iprot.readString() else: iprot.skip(ftype) else: @@ -21363,37 +21912,37 @@ class deleteSSHPubKey_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('deleteSSHPubKey_args') + oprot.writeStructBegin('getAllSSHPubKeysSummaryForUserInGateway_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) oprot.writeFieldEnd() - if self.airavataCredStoreToken is not None: - oprot.writeFieldBegin('airavataCredStoreToken', TType.STRING, 2) - oprot.writeString(self.airavataCredStoreToken) - oprot.writeFieldEnd() if self.gatewayId is not None: - oprot.writeFieldBegin('gatewayId', TType.STRING, 3) + oprot.writeFieldBegin('gatewayId', TType.STRING, 2) oprot.writeString(self.gatewayId) oprot.writeFieldEnd() + if self.userId is not None: + oprot.writeFieldBegin('userId', TType.STRING, 3) + oprot.writeString(self.userId) + 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.airavataCredStoreToken is None: - raise TProtocol.TProtocolException(message='Required field airavataCredStoreToken is unset!') if self.gatewayId is None: raise TProtocol.TProtocolException(message='Required field gatewayId is unset!') + if self.userId is None: + raise TProtocol.TProtocolException(message='Required field userId is unset!') return def __hash__(self): value = 17 value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.airavataCredStoreToken) value = (value * 31) ^ hash(self.gatewayId) + value = (value * 31) ^ hash(self.userId) return value def __repr__(self): @@ -21407,7 +21956,7 @@ class deleteSSHPubKey_args: def __ne__(self, other): return not (self == other) -class deleteSSHPubKey_result: +class getAllSSHPubKeysSummaryForUserInGateway_result: """ Attributes: - success @@ -21417,7 +21966,419 @@ class deleteSSHPubKey_result: """ thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.appcatalog.credentialsummary.ttypes.CredentialSummary, apache.airavata.model.appcatalog.credentialsummary.ttypes.CredentialSummary.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 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + + 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 = [] + (_etype40, _size37) = iprot.readListBegin() + for _i41 in xrange(_size37): + _elem42 = apache.airavata.model.appcatalog.credentialsummary.ttypes.CredentialSummary() + _elem42.read(iprot) + self.success.append(_elem42) + 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) + 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('getAllSSHPubKeysSummaryForUserInGateway_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter43 in self.success: + iter43.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() + 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) + 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 getAllGatewayPWDCredentials_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('getAllGatewayPWDCredentials_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 getAllGatewayPWDCredentials_result: + """ + Attributes: + - success + - ire + - ace + - ase + """ + + thrift_spec = ( + (0, TType.MAP, 'success', (TType.STRING,None,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 + ) + + def __init__(self, success=None, ire=None, ace=None, ase=None,): + self.success = success + self.ire = ire + self.ace = ace + self.ase = ase + + 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.MAP: + self.success = {} + (_ktype45, _vtype46, _size44 ) = iprot.readMapBegin() + for _i48 in xrange(_size44): + _key49 = iprot.readString() + _val50 = iprot.readString() + self.success[_key49] = _val50 + iprot.readMapEnd() + 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) + 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('getAllGatewayPWDCredentials_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.MAP, 0) + oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) + for kiter51,viter52 in self.success.items(): + oprot.writeString(kiter51) + oprot.writeString(viter52) + oprot.writeMapEnd() + 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() + 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) + 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 deleteSSHPubKey_args: + """ + Attributes: + - authzToken + - airavataCredStoreToken + - 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, 'airavataCredStoreToken', None, None, ), # 2 + (3, TType.STRING, 'gatewayId', None, None, ), # 3 + ) + + def __init__(self, authzToken=None, airavataCredStoreToken=None, gatewayId=None,): + self.authzToken = authzToken + self.airavataCredStoreToken = airavataCredStoreToken + 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.airavataCredStoreToken = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + 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('deleteSSHPubKey_args') + if self.authzToken is not None: + oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) + self.authzToken.write(oprot) + oprot.writeFieldEnd() + if self.airavataCredStoreToken is not None: + oprot.writeFieldBegin('airavataCredStoreToken', TType.STRING, 2) + oprot.writeString(self.airavataCredStoreToken) + oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 3) + 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.airavataCredStoreToken is None: + raise TProtocol.TProtocolException(message='Required field airavataCredStoreToken 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.airavataCredStoreToken) + 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 deleteSSHPubKey_result: + """ + Attributes: + - success + - ire + - ace + - ase + """ + + 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 @@ -22757,11 +23718,11 @@ class getUserProjects_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype42, _size39) = iprot.readListBegin() - for _i43 in xrange(_size39): - _elem44 = apache.airavata.model.workspace.ttypes.Project() - _elem44.read(iprot) - self.success.append(_elem44) + (_etype56, _size53) = iprot.readListBegin() + for _i57 in xrange(_size53): + _elem58 = apache.airavata.model.workspace.ttypes.Project() + _elem58.read(iprot) + self.success.append(_elem58) iprot.readListEnd() else: iprot.skip(ftype) @@ -22802,8 +23763,8 @@ class getUserProjects_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter45 in self.success: - iter45.write(oprot) + for iter59 in self.success: + iter59.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22906,11 +23867,11 @@ class searchProjects_args: elif fid == 4: if ftype == TType.MAP: self.filters = {} - (_ktype47, _vtype48, _size46 ) = iprot.readMapBegin() - for _i50 in xrange(_size46): - _key51 = iprot.readI32() - _val52 = iprot.readString() - self.filters[_key51] = _val52 + (_ktype61, _vtype62, _size60 ) = iprot.readMapBegin() + for _i64 in xrange(_size60): + _key65 = iprot.readI32() + _val66 = iprot.readString() + self.filters[_key65] = _val66 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22949,9 +23910,9 @@ class searchProjects_args: if self.filters is not None: oprot.writeFieldBegin('filters', TType.MAP, 4) oprot.writeMapBegin(TType.I32, TType.STRING, len(self.filters)) - for kiter53,viter54 in self.filters.items(): - oprot.writeI32(kiter53) - oprot.writeString(viter54) + for kiter67,viter68 in self.filters.items(): + oprot.writeI32(kiter67) + oprot.writeString(viter68) oprot.writeMapEnd() oprot.writeFieldEnd() if self.limit is not None: @@ -23037,11 +23998,11 @@ class searchProjects_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype58, _size55) = iprot.readListBegin() - for _i59 in xrange(_size55): - _elem60 = apache.airavata.model.workspace.ttypes.Project() - _elem60.read(iprot) - self.success.append(_elem60) + (_etype72, _size69) = iprot.readListBegin() + for _i73 in xrange(_size69): + _elem74 = apache.airavata.model.workspace.ttypes.Project() + _elem74.read(iprot) + self.success.append(_elem74) iprot.readListEnd() else: iprot.skip(ftype) @@ -23082,8 +24043,8 @@ class searchProjects_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter61 in self.success: - iter61.write(oprot) + for iter75 in self.success: + iter75.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -23186,11 +24147,11 @@ class searchExperiments_args: elif fid == 4: if ftype == TType.MAP: self.filters = {} - (_ktype63, _vtype64, _size62 ) = iprot.readMapBegin() - for _i66 in xrange(_size62): - _key67 = iprot.readI32() - _val68 = iprot.readString() - self.filters[_key67] = _val68 + (_ktype77, _vtype78, _size76 ) = iprot.readMapBegin() + for _i80 in xrange(_size76): + _key81 = iprot.readI32() + _val82 = iprot.readString() + self.filters[_key81] = _val82 iprot.readMapEnd() else: iprot.skip(ftype) @@ -23229,9 +24190,9 @@ class searchExperiments_args: if self.filters is not None: oprot.writeFieldBegin('filters', TType.MAP, 4) oprot.writeMapBegin(TType.I32, TType.STRING, len(self.filters)) - for kiter69,viter70 in self.filters.items(): - oprot.writeI32(kiter69) - oprot.writeString(viter70) + for kiter83,viter84 in self.filters.items(): + oprot.writeI32(kiter83) + oprot.writeString(viter84) oprot.writeMapEnd() oprot.writeFieldEnd() if self.limit is not None: @@ -23317,11 +24278,11 @@ class searchExperiments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype74, _size71) = iprot.readListBegin() - for _i75 in xrange(_size71): - _elem76 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem76.read(iprot) - self.success.append(_elem76) + (_etype88, _size85) = iprot.readListBegin() + for _i89 in xrange(_size85): + _elem90 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem90.read(iprot) + self.success.append(_elem90) iprot.readListEnd() else: iprot.skip(ftype) @@ -23362,8 +24323,8 @@ class searchExperiments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter77 in self.success: - iter77.write(oprot) + for iter91 in self.success: + iter91.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -23796,11 +24757,11 @@ class getExperimentsInProject_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype81, _size78) = iprot.readListBegin() - for _i82 in xrange(_size78): - _elem83 = apache.airavata.model.experiment.ttypes.ExperimentModel() - _elem83.read(iprot) - self.success.append(_elem83) + (_etype95, _size92) = iprot.readListBegin() + for _i96 in xrange(_size92): + _elem97 = apache.airavata.model.experiment.ttypes.ExperimentModel() + _elem97.read(iprot) + self.success.append(_elem97) iprot.readListEnd() else: iprot.skip(ftype) @@ -23847,8 +24808,8 @@ class getExperimentsInProject_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter84 in self.success: - iter84.write(oprot) + for iter98 in self.success: + iter98.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -24064,11 +25025,11 @@ class getUserExperiments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype88, _size85) = iprot.readListBegin() - for _i89 in xrange(_size85): - _elem90 = apache.airavata.model.experiment.ttypes.ExperimentModel() - _elem90.read(iprot) - self.success.append(_elem90) + (_etype102, _size99) = iprot.readListBegin() + for _i103 in xrange(_size99): + _elem104 = apache.airavata.model.experiment.ttypes.ExperimentModel() + _elem104.read(iprot) + self.success.append(_elem104) iprot.readListEnd() else: iprot.skip(ftype) @@ -24109,8 +25070,8 @@ class getUserExperiments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter91 in self.success: - iter91.write(oprot) + for iter105 in self.success: + iter105.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26343,11 +27304,11 @@ class getExperimentOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype95, _size92) = iprot.readListBegin() - for _i96 in xrange(_size92): - _elem97 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem97.read(iprot) - self.success.append(_elem97) + (_etype109, _size106) = iprot.readListBegin() + for _i110 in xrange(_size106): + _elem111 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem111.read(iprot) + self.success.append(_elem111) iprot.readListEnd() else: iprot.skip(ftype) @@ -26394,8 +27355,8 @@ class getExperimentOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter98 in self.success: - iter98.write(oprot) + for iter112 in self.success: + iter112.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26569,11 +27530,11 @@ class getIntermediateOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype102, _size99) = iprot.readListBegin() - for _i103 in xrange(_size99): - _elem104 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem104.read(iprot) - self.success.append(_elem104) + (_etype116, _size113) = iprot.readListBegin() + for _i117 in xrange(_size113): + _elem118 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem118.read(iprot) + self.success.append(_elem118) iprot.readListEnd() else: iprot.skip(ftype) @@ -26620,8 +27581,8 @@ class getIntermediateOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter105 in self.success: - iter105.write(oprot) + for iter119 in self.success: + iter119.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26795,12 +27756,12 @@ class getJobStatuses_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype107, _vtype108, _size106 ) = iprot.readMapBegin() - for _i110 in xrange(_size106): - _key111 = iprot.readString() - _val112 = apache.airavata.model.status.ttypes.JobStatus() - _val112.read(iprot) - self.success[_key111] = _val112 + (_ktype121, _vtype122, _size120 ) = iprot.readMapBegin() + for _i124 in xrange(_size120): + _key125 = iprot.readString() + _val126 = apache.airavata.model.status.ttypes.JobStatus() + _val126.read(iprot) + self.success[_key125] = _val126 iprot.readMapEnd() else: iprot.skip(ftype) @@ -26847,9 +27808,9 @@ class getJobStatuses_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter113,viter114 in self.success.items(): - oprot.writeString(kiter113) - viter114.write(oprot) + for kiter127,viter128 in self.success.items(): + oprot.writeString(kiter127) + viter128.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -27023,11 +27984,11 @@ class getJobDetails_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype118, _size115) = iprot.readListBegin() - for _i119 in xrange(_size115): - _elem120 = apache.airavata.model.job.ttypes.JobModel() - _elem120.read(iprot) - self.success.append(_elem120) + (_etype132, _size129) = iprot.readListBegin() + for _i133 in xrange(_size129): + _elem134 = apache.airavata.model.job.ttypes.JobModel() + _elem134.read(iprot) + self.success.append(_elem134) iprot.readListEnd() else: iprot.skip(ftype) @@ -27074,8 +28035,8 @@ class getJobDetails_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter121 in self.success: - iter121.write(oprot) + for iter135 in self.success: + iter135.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -28332,11 +29293,11 @@ class getAllAppModules_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype125, _size122) = iprot.readListBegin() - for _i126 in xrange(_size122): - _elem127 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() - _elem127.read(iprot) - self.success.append(_elem127) + (_etype139, _size136) = iprot.readListBegin() + for _i140 in xrange(_size136): + _elem141 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + _elem141.read(iprot) + self.success.append(_elem141) iprot.readListEnd() else: iprot.skip(ftype) @@ -28377,8 +29338,8 @@ class getAllAppModules_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter128 in self.success: - iter128.write(oprot) + for iter142 in self.success: + iter142.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -29592,11 +30553,11 @@ class getAllApplicationDeployments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype132, _size129) = iprot.readListBegin() - for _i133 in xrange(_size129): - _elem134 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() - _elem134.read(iprot) - self.success.append(_elem134) + (_etype146, _size143) = iprot.readListBegin() + for _i147 in xrange(_size143): + _elem148 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + _elem148.read(iprot) + self.success.append(_elem148) iprot.readListEnd() else: iprot.skip(ftype) @@ -29637,8 +30598,8 @@ class getAllApplicationDeployments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter135 in self.success: - iter135.write(oprot) + for iter149 in self.success: + iter149.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -29804,10 +30765,10 @@ class getAppModuleDeployedResources_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype139, _size136) = iprot.readListBegin() - for _i140 in xrange(_size136): - _elem141 = iprot.readString() - self.success.append(_elem141) + (_etype153, _size150) = iprot.readListBegin() + for _i154 in xrange(_size150): + _elem155 = iprot.readString() + self.success.append(_elem155) iprot.readListEnd() else: iprot.skip(ftype) @@ -29848,8 +30809,8 @@ class getAppModuleDeployedResources_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter142 in self.success: - oprot.writeString(iter142) + for iter156 in self.success: + oprot.writeString(iter156) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31087,11 +32048,11 @@ class getAllApplicationInterfaceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype144, _vtype145, _size143 ) = iprot.readMapBegin() - for _i147 in xrange(_size143): - _key148 = iprot.readString() - _val149 = iprot.readString() - self.success[_key148] = _val149 + (_ktype158, _vtype159, _size157 ) = iprot.readMapBegin() + for _i161 in xrange(_size157): + _key162 = iprot.readString() + _val163 = iprot.readString() + self.success[_key162] = _val163 iprot.readMapEnd() else: iprot.skip(ftype) @@ -31132,9 +32093,9 @@ class getAllApplicationInterfaceNames_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter150,viter151 in self.success.items(): - oprot.writeString(kiter150) - oprot.writeString(viter151) + for kiter164,viter165 in self.success.items(): + oprot.writeString(kiter164) + oprot.writeString(viter165) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31300,11 +32261,11 @@ class getAllApplicationInterfaces_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype155, _size152) = iprot.readListBegin() - for _i156 in xrange(_size152): - _elem157 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() - _elem157.read(iprot) - self.success.append(_elem157) + (_etype169, _size166) = iprot.readListBegin() + for _i170 in xrange(_size166): + _elem171 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() + _elem171.read(iprot) + self.success.append(_elem171) iprot.readListEnd() else: iprot.skip(ftype) @@ -31345,8 +32306,8 @@ class getAllApplicationInterfaces_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter158 in self.success: - iter158.write(oprot) + for iter172 in self.success: + iter172.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31512,11 +32473,11 @@ class getApplicationInputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype162, _size159) = iprot.readListBegin() - for _i163 in xrange(_size159): - _elem164 = apache.airavata.model.application.io.ttypes.InputDataObjectType() - _elem164.read(iprot) - self.success.append(_elem164) + (_etype176, _size173) = iprot.readListBegin() + for _i177 in xrange(_size173): + _elem178 = apache.airavata.model.application.io.ttypes.InputDataObjectType() + _elem178.read(iprot) + self.success.append(_elem178) iprot.readListEnd() else: iprot.skip(ftype) @@ -31557,8 +32518,8 @@ class getApplicationInputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter165 in self.success: - iter165.write(oprot) + for iter179 in self.success: + iter179.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31724,11 +32685,11 @@ class getApplicationOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype169, _size166) = iprot.readListBegin() - for _i170 in xrange(_size166): - _elem171 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem171.read(iprot) - self.success.append(_elem171) + (_etype183, _size180) = iprot.readListBegin() + for _i184 in xrange(_size180): + _elem185 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem185.read(iprot) + self.success.append(_elem185) iprot.readListEnd() else: iprot.skip(ftype) @@ -31769,8 +32730,8 @@ class getApplicationOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter172 in self.success: - iter172.write(oprot) + for iter186 in self.success: + iter186.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31936,11 +32897,11 @@ class getAvailableAppInterfaceComputeResources_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype174, _vtype175, _size173 ) = iprot.readMapBegin() - for _i177 in xrange(_size173): - _key178 = iprot.readString() - _val179 = iprot.readString() - self.success[_key178] = _val179 + (_ktype188, _vtype189, _size187 ) = iprot.readMapBegin() + for _i191 in xrange(_size187): + _key192 = iprot.readString() + _val193 = iprot.readString() + self.success[_key192] = _val193 iprot.readMapEnd() else: iprot.skip(ftype) @@ -31981,9 +32942,9 @@ class getAvailableAppInterfaceComputeResources_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter180,viter181 in self.success.items(): - oprot.writeString(kiter180) - oprot.writeString(viter181) + for kiter194,viter195 in self.success.items(): + oprot.writeString(kiter194) + oprot.writeString(viter195) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -32542,11 +33503,11 @@ class getAllComputeResourceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype183, _vtype184, _size182 ) = iprot.readMapBegin() - for _i186 in xrange(_size182): - _key187 = iprot.readString() - _val188 = iprot.readString() - self.success[_key187] = _val188 + (_ktype197, _vtype198, _size196 ) = iprot.readMapBegin() + for _i200 in xrange(_size196): + _key201 = iprot.readString() + _val202 = iprot.readString() + self.success[_key201] = _val202 iprot.readMapEnd() else: iprot.skip(ftype) @@ -32587,9 +33548,9 @@ class getAllComputeResourceNames_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter189,viter190 in self.success.items(): - oprot.writeString(kiter189) - oprot.writeString(viter190) + for kiter203,viter204 in self.success.items(): + oprot.writeString(kiter203) + oprot.writeString(viter204) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -33570,11 +34531,11 @@ class getAllStorageResourceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype192, _vtype193, _size191 ) = iprot.readMapBegin() - for _i195 in xrange(_size191): - _key196 = iprot.readString() - _val197 = iprot.readString() - self.success[_key196] = _val197 + (_ktype206, _vtype207, _size205 ) = iprot.readMapBegin() + for _i209 in xrange(_size205): + _key210 = iprot.readString() + _val211 = iprot.readString() + self.success[_key210] = _val211 iprot.readMapEnd() else: iprot.skip(ftype) @@ -33615,9 +34576,9 @@ class getAllStorageResourceNames_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter198,viter199 in self.success.items(): - oprot.writeString(kiter198) - oprot.writeString(viter199) + for kiter212,viter213 in self.success.items(): + oprot.writeString(kiter212) + oprot.writeString(viter213) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -40106,11 +41067,11 @@ class changeJobSubmissionPriorities_args: elif fid == 2: if ftype == TType.MAP: self.jobSubmissionPriorityMap = {} - (_ktype201, _vtype202, _size200 ) = iprot.readMapBegin() - for _i204 in xrange(_size200): - _key205 = iprot.readString() - _val206 = iprot.readI32() - self.jobSubmissionPriorityMap[_key205] = _val206 + (_ktype215, _vtype216, _size214 ) = iprot.readMapBegin() + for _i218 in xrange(_size214): + _key219 = iprot.readString() + _val220 = iprot.readI32() + self.jobSubmissionPriorityMap[_key219] = _val220 iprot.readMapEnd() else: iprot.skip(ftype) @@ -40131,9 +41092,9 @@ class changeJobSubmissionPriorities_args: if self.jobSubmissionPriorityMap is not None: oprot.writeFieldBegin('jobSubmissionPriorityMap', TType.MAP, 2) oprot.writeMapBegin(TType.STRING, TType.I32, len(self.jobSubmissionPriorityMap)) - for kiter207,viter208 in self.jobSubmissionPriorityMap.items(): - oprot.writeString(kiter207) - oprot.writeI32(viter208) + for kiter221,viter222 in self.jobSubmissionPriorityMap.items(): + oprot.writeString(kiter221) + oprot.writeI32(viter222) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -40319,11 +41280,11 @@ class changeDataMovementPriorities_args: elif fid == 2: if ftype == TType.MAP: self.dataMovementPriorityMap = {} - (_ktype210, _vtype211, _size209 ) = iprot.readMapBegin() - for _i213 in xrange(_size209): - _key214 = iprot.readString() - _val215 = iprot.readI32() - self.dataMovementPriorityMap[_key214] = _val215 + (_ktype224, _vtype225, _size223 ) = iprot.readMapBegin() + for _i227 in xrange(_size223): + _key228 = iprot.readString() + _val229 = iprot.readI32() + self.dataMovementPriorityMap[_key228] = _val229 iprot.readMapEnd() else: iprot.skip(ftype) @@ -40344,9 +41305,9 @@ class changeDataMovementPriorities_args: if self.dataMovementPriorityMap is not None: oprot.writeFieldBegin('dataMovementPriorityMap', TType.MAP, 2) oprot.writeMapBegin(TType.STRING, TType.I32, len(self.dataMovementPriorityMap)) - for kiter216,viter217 in self.dataMovementPriorityMap.items(): - oprot.writeString(kiter216) - oprot.writeI32(viter217) + for kiter230,viter231 in self.dataMovementPriorityMap.items(): + oprot.writeString(kiter230) + oprot.writeI32(viter231) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -43852,11 +44813,11 @@ class getAllGatewayComputeResourcePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype221, _size218) = iprot.readListBegin() - for _i222 in xrange(_size218): - _elem223 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference() - _elem223.read(iprot) - self.success.append(_elem223) + (_etype235, _size232) = iprot.readListBegin() + for _i236 in xrange(_size232): + _elem237 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference() + _elem237.read(iprot) + self.success.append(_elem237) iprot.readListEnd() else: iprot.skip(ftype) @@ -43897,8 +44858,8 @@ class getAllGatewayComputeResourcePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter224 in self.success: - iter224.write(oprot) + for iter238 in self.success: + iter238.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -44064,11 +45025,11 @@ class getAllGatewayStoragePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype228, _size225) = iprot.readListBegin() - for _i229 in xrange(_size225): - _elem230 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() - _elem230.read(iprot) - self.success.append(_elem230) + (_etype242, _size239) = iprot.readListBegin() + for _i243 in xrange(_size239): + _elem244 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() + _elem244.read(iprot) + self.success.append(_elem244) iprot.readListEnd() else: iprot.skip(ftype) @@ -44109,8 +45070,8 @@ class getAllGatewayStoragePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter231 in self.success: - iter231.write(oprot) + for iter245 in self.success: + iter245.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -44261,11 +45222,11 @@ class getAllGatewayResourceProfiles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype235, _size232) = iprot.readListBegin() - for _i236 in xrange(_size232): - _elem237 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile() - _elem237.read(iprot) - self.success.append(_elem237) + (_etype249, _size246) = iprot.readListBegin() + for _i250 in xrange(_size246): + _elem251 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile() + _elem251.read(iprot) + self.success.append(_elem251) iprot.readListEnd() else: iprot.skip(ftype) @@ -44306,8 +45267,8 @@ class getAllGatewayResourceProfiles_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter238 in self.success: - iter238.write(oprot) + for iter252 in self.success: + iter252.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -47233,11 +48194,11 @@ class getAllUserComputeResourcePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype242, _size239) = iprot.readListBegin() - for _i243 in xrange(_size239): - _elem244 = apache.airavata.model.appcatalog.userresourceprofile.ttypes.UserComputeResourcePreference() - _elem244.read(iprot) - self.success.append(_elem244) + (_etype256, _size253) = iprot.readListBegin() + for _i257 in xrange(_size253): + _elem258 = apache.airavata.model.appcatalog.userresourceprofile.ttypes.UserComputeResourcePreference() + _elem258.read(iprot) + self.success.append(_elem258) iprot.readListEnd() else: iprot.skip(ftype) @@ -47278,8 +48239,8 @@ class getAllUserComputeResourcePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter245 in self.success: - iter245.write(oprot) + for iter259 in self.success: + iter259.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -47460,11 +48421,11 @@ class getAllUserStoragePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype249, _size246) = iprot.readListBegin() - for _i250 in xrange(_size246): - _elem251 = apache.airavata.model.appcatalog.userresourceprofile.ttypes.UserStoragePreference() - _elem251.read(iprot) - self.success.append(_elem251) + (_etype263, _size260) = iprot.readListBegin() + for _i264 in xrange(_size260): + _elem265 = apache.airavata.model.appcatalog.userresourceprofile.ttypes.UserStoragePreference() + _elem265.read(iprot) + self.success.append(_elem265) iprot.readListEnd() else: iprot.skip(ftype) @@ -47505,8 +48466,8 @@ class getAllUserStoragePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter252 in self.success: - iter252.write(oprot) + for iter266 in self.success: + iter266.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -47657,11 +48618,11 @@ class getAllUserResourceProfiles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype256, _size253) = iprot.readListBegin() - for _i257 in xrange(_size253): - _elem258 = apache.airavata.model.appcatalog.userresourceprofile.ttypes.UserResourceProfile() - _elem258.read(iprot) - self.success.append(_elem258) + (_etype270, _size267) = iprot.readListBegin() + for _i271 in xrange(_size267): + _elem272 = apache.airavata.model.appcatalog.userresourceprofile.ttypes.UserResourceProfile() + _elem272.read(iprot) + self.success.append(_elem272) iprot.readListEnd() else: iprot.skip(ftype) @@ -47702,8 +48663,8 @@ class getAllUserResourceProfiles_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter259 in self.success: - iter259.write(oprot) + for iter273 in self.success: + iter273.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -48833,10 +49794,10 @@ class getAllWorkflows_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype263, _size260) = iprot.readListBegin() - for _i264 in xrange(_size260): - _elem265 = iprot.readString() - self.success.append(_elem265) + (_etype277, _size274) = iprot.readListBegin() + for _i278 in xrange(_size274): + _elem279 = iprot.readString() + self.success.append(_elem279) iprot.readListEnd() else: iprot.skip(ftype) @@ -48877,8 +49838,8 @@ class getAllWorkflows_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter266 in self.success: - oprot.writeString(iter266) + for iter280 in self.success: + oprot.writeString(iter280) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -51087,11 +52048,11 @@ class getChildDataProducts_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype270, _size267) = iprot.readListBegin() - for _i271 in xrange(_size267): - _elem272 = apache.airavata.model.data.replica.ttypes.DataProductModel() - _elem272.read(iprot) - self.success.append(_elem272) + (_etype284, _size281) = iprot.readListBegin() + for _i285 in xrange(_size281): + _elem286 = apache.airavata.model.data.replica.ttypes.DataProductModel() + _elem286.read(iprot) + self.success.append(_elem286) iprot.readListEnd() else: iprot.skip(ftype) @@ -51132,8 +52093,8 @@ class getChildDataProducts_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter273 in self.success: - iter273.write(oprot) + for iter287 in self.success: + iter287.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -51230,11 +52191,11 @@ class shareResourceWithUsers_args: elif fid == 4: if ftype == TType.MAP: self.userPermissionList = {} - (_ktype275, _vtype276, _size274 ) = iprot.readMapBegin() - for _i278 in xrange(_size274): - _key279 = iprot.readString() - _val280 = iprot.readI32() - self.userPermissionList[_key279] = _val280 + (_ktype289, _vtype290, _size288 ) = iprot.readMapBegin() + for _i292 in xrange(_size288): + _key293 = iprot.readString() + _val294 = iprot.readI32() + self.userPermissionList[_key293] = _val294 iprot.readMapEnd() else: iprot.skip(ftype) @@ -51263,9 +52224,9 @@ class shareResourceWithUsers_args: if self.userPermissionList is not None: oprot.writeFieldBegin('userPermissionList', TType.MAP, 4) oprot.writeMapBegin(TType.STRING, TType.I32, len(self.userPermissionList)) - for kiter281,viter282 in self.userPermissionList.items(): - oprot.writeString(kiter281) - oprot.writeI32(viter282) + for kiter295,viter296 in self.userPermissionList.items(): + oprot.writeString(kiter295) + oprot.writeI32(viter296) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -51471,11 +52432,11 @@ class revokeSharingOfResourceFromUsers_args: elif fid == 4: if ftype == TType.MAP: self.userPermissionList = {} - (_ktype284, _vtype285, _size283 ) = iprot.readMapBegin() - for _i287 in xrange(_size283): - _key288 = iprot.readString() - _val289 = iprot.readI32() - self.userPermissionList[_key288] = _val289 + (_ktype298, _vtype299, _size297 ) = iprot.readMapBegin() + for _i301 in xrange(_size297): + _key302 = iprot.readString() + _val303 = iprot.readI32() + self.userPermissionList[_key302] = _val303 iprot.readMapEnd() else: iprot.skip(ftype) @@ -51504,9 +52465,9 @@ class revokeSharingOfResourceFromUsers_args: if self.userPermissionList is not None: oprot.writeFieldBegin('userPermissionList', TType.MAP, 4) oprot.writeMapBegin(TType.STRING, TType.I32, len(self.userPermissionList)) - for kiter290,viter291 in self.userPermissionList.items(): - oprot.writeString(kiter290) - oprot.writeI32(viter291) + for kiter304,viter305 in self.userPermissionList.items(): + oprot.writeString(kiter304) + oprot.writeI32(viter305) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -51811,10 +52772,10 @@ class getAllAccessibleUsers_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype295, _size292) = iprot.readListBegin() - for _i296 in xrange(_size292): - _elem297 = iprot.readString() - self.success.append(_elem297) + (_etype309, _size306) = iprot.readListBegin() + for _i310 in xrange(_size306): + _elem311 = iprot.readString() + self.success.append(_elem311) iprot.readListEnd() else: iprot.skip(ftype) @@ -51855,8 +52816,8 @@ class getAllAccessibleUsers_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter298 in self.success: - oprot.writeString(iter298) + for iter312 in self.success: + oprot.writeString(iter312) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -52882,11 +53843,11 @@ class getAllGroupsUserBelongs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype302, _size299) = iprot.readListBegin() - for _i303 in xrange(_size299): - _elem304 = apache.airavata.model.group.ttypes.GroupModel() - _elem304.read(iprot) - self.success.append(_elem304) + (_etype316, _size313) = iprot.readListBegin() + for _i317 in xrange(_size313): + _elem318 = apache.airavata.model.group.ttypes.GroupModel() + _elem318.read(iprot) + self.success.append(_elem318) iprot.readListEnd() else: iprot.skip(ftype) @@ -52927,8 +53888,8 @@ class getAllGroupsUserBelongs_result: if self.success is n
<TRUNCATED>
