http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote index 9389597..8de0958 100755 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/Airavata-remote @@ -27,6 +27,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' string getAPIVersion(AuthzToken authzToken)') print(' bool isUserExists(AuthzToken authzToken, string gatewayId, string userName)') print(' string addGateway(AuthzToken authzToken, Gateway gateway)') + print(' getAllUsersInGateway(AuthzToken authzToken, string gatewayId)') print(' void updateGateway(AuthzToken authzToken, string gatewayId, Gateway updatedGateway)') print(' Gateway getGateway(AuthzToken authzToken, string gatewayId)') print(' bool deleteGateway(AuthzToken authzToken, string gatewayId)') @@ -244,6 +245,12 @@ elif cmd == 'addGateway': sys.exit(1) pp.pprint(client.addGateway(eval(args[0]),eval(args[1]),)) +elif cmd == 'getAllUsersInGateway': + if len(args) != 2: + print('getAllUsersInGateway requires 2 args') + sys.exit(1) + pp.pprint(client.getAllUsersInGateway(eval(args[0]),args[1],)) + elif cmd == 'updateGateway': if len(args) != 3: print('updateGateway requires 3 args')
http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/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 7c9488a..8794b23 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 @@ -66,6 +66,24 @@ class Iface: """ pass + def getAllUsersInGateway(self, authzToken, gatewayId): + """ + Get all users in the gateway + + @param gatewayId + The gateway data model. + + @return users + list of usernames of the users in the gateway + + + + Parameters: + - authzToken + - gatewayId + """ + pass + def updateGateway(self, authzToken, gatewayId, updatedGateway): """ Update previously registered Gateway metadata. @@ -3186,6 +3204,57 @@ class Client(Iface): raise result.ae raise TApplicationException(TApplicationException.MISSING_RESULT, "addGateway failed: unknown result") + def getAllUsersInGateway(self, authzToken, gatewayId): + """ + Get all users in the gateway + + @param gatewayId + The gateway data model. + + @return users + list of usernames of the users in the gateway + + + + Parameters: + - authzToken + - gatewayId + """ + self.send_getAllUsersInGateway(authzToken, gatewayId) + return self.recv_getAllUsersInGateway() + + def send_getAllUsersInGateway(self, authzToken, gatewayId): + self._oprot.writeMessageBegin('getAllUsersInGateway', TMessageType.CALL, self._seqid) + args = getAllUsersInGateway_args() + args.authzToken = authzToken + args.gatewayId = gatewayId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllUsersInGateway(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = getAllUsersInGateway_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, "getAllUsersInGateway failed: unknown result") + def updateGateway(self, authzToken, gatewayId, updatedGateway): """ Update previously registered Gateway metadata. @@ -10988,6 +11057,7 @@ class Processor(Iface, TProcessor): self._processMap["getAPIVersion"] = Processor.process_getAPIVersion self._processMap["isUserExists"] = Processor.process_isUserExists self._processMap["addGateway"] = Processor.process_addGateway + self._processMap["getAllUsersInGateway"] = Processor.process_getAllUsersInGateway self._processMap["updateGateway"] = Processor.process_updateGateway self._processMap["getGateway"] = Processor.process_getGateway self._processMap["deleteGateway"] = Processor.process_deleteGateway @@ -11240,6 +11310,37 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_getAllUsersInGateway(self, seqid, iprot, oprot): + args = getAllUsersInGateway_args() + args.read(iprot) + iprot.readMessageEnd() + result = getAllUsersInGateway_result() + try: + result.success = self._handler.getAllUsersInGateway(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 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("getAllUsersInGateway", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_updateGateway(self, seqid, iprot, oprot): args = updateGateway_args() args.read(iprot) @@ -16295,6 +16396,217 @@ class addGateway_result: def __ne__(self, other): return not (self == other) +class getAllUsersInGateway_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('getAllUsersInGateway_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 getAllUsersInGateway_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 + (1, TType.STRUCT, 'ire', (apache.airavata.api.error.ttypes.InvalidRequestException, apache.airavata.api.error.ttypes.InvalidRequestException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ace', (apache.airavata.api.error.ttypes.AiravataClientException, apache.airavata.api.error.ttypes.AiravataClientException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'ase', (apache.airavata.api.error.ttypes.AiravataSystemException, apache.airavata.api.error.ttypes.AiravataSystemException.thrift_spec), None, ), # 3 + (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 = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in xrange(_size0): + _elem5 = iprot.readString() + self.success.append(_elem5) + 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('getAllUsersInGateway_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRING, len(self.success)) + for iter6 in self.success: + oprot.writeString(iter6) + 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 updateGateway_args: """ Attributes: @@ -17014,11 +17326,11 @@ class getAllGateways_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype3, _size0) = iprot.readListBegin() - for _i4 in xrange(_size0): - _elem5 = apache.airavata.model.workspace.ttypes.Gateway() - _elem5.read(iprot) - self.success.append(_elem5) + (_etype10, _size7) = iprot.readListBegin() + for _i11 in xrange(_size7): + _elem12 = apache.airavata.model.workspace.ttypes.Gateway() + _elem12.read(iprot) + self.success.append(_elem12) iprot.readListEnd() else: iprot.skip(ftype) @@ -17059,8 +17371,8 @@ class getAllGateways_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter6 in self.success: - iter6.write(oprot) + for iter13 in self.success: + iter13.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -18274,11 +18586,11 @@ class getAllNotifications_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype10, _size7) = iprot.readListBegin() - for _i11 in xrange(_size7): - _elem12 = apache.airavata.model.workspace.ttypes.Notification() - _elem12.read(iprot) - self.success.append(_elem12) + (_etype17, _size14) = iprot.readListBegin() + for _i18 in xrange(_size14): + _elem19 = apache.airavata.model.workspace.ttypes.Notification() + _elem19.read(iprot) + self.success.append(_elem19) iprot.readListEnd() else: iprot.skip(ftype) @@ -18319,8 +18631,8 @@ class getAllNotifications_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter13 in self.success: - iter13.write(oprot) + for iter20 in self.success: + iter20.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -19140,11 +19452,11 @@ class getAllGatewaySSHPubKeys_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype15, _vtype16, _size14 ) = iprot.readMapBegin() - for _i18 in xrange(_size14): - _key19 = iprot.readString() - _val20 = iprot.readString() - self.success[_key19] = _val20 + (_ktype22, _vtype23, _size21 ) = iprot.readMapBegin() + for _i25 in xrange(_size21): + _key26 = iprot.readString() + _val27 = iprot.readString() + self.success[_key26] = _val27 iprot.readMapEnd() else: iprot.skip(ftype) @@ -19179,9 +19491,9 @@ class getAllGatewaySSHPubKeys_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter21,viter22 in self.success.items(): - oprot.writeString(kiter21) - oprot.writeString(viter22) + for kiter28,viter29 in self.success.items(): + oprot.writeString(kiter28) + oprot.writeString(viter29) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -19339,11 +19651,11 @@ class getAllGatewayPWDCredentials_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype24, _vtype25, _size23 ) = iprot.readMapBegin() - for _i27 in xrange(_size23): - _key28 = iprot.readString() - _val29 = iprot.readString() - self.success[_key28] = _val29 + (_ktype31, _vtype32, _size30 ) = iprot.readMapBegin() + for _i34 in xrange(_size30): + _key35 = iprot.readString() + _val36 = iprot.readString() + self.success[_key35] = _val36 iprot.readMapEnd() else: iprot.skip(ftype) @@ -19378,9 +19690,9 @@ class getAllGatewayPWDCredentials_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter30,viter31 in self.success.items(): - oprot.writeString(kiter30) - oprot.writeString(viter31) + for kiter37,viter38 in self.success.items(): + oprot.writeString(kiter37) + oprot.writeString(viter38) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -20869,11 +21181,11 @@ class getUserProjects_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype35, _size32) = iprot.readListBegin() - for _i36 in xrange(_size32): - _elem37 = apache.airavata.model.workspace.ttypes.Project() - _elem37.read(iprot) - self.success.append(_elem37) + (_etype42, _size39) = iprot.readListBegin() + for _i43 in xrange(_size39): + _elem44 = apache.airavata.model.workspace.ttypes.Project() + _elem44.read(iprot) + self.success.append(_elem44) iprot.readListEnd() else: iprot.skip(ftype) @@ -20914,8 +21226,8 @@ class getUserProjects_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter38 in self.success: - iter38.write(oprot) + for iter45 in self.success: + iter45.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21141,11 +21453,11 @@ class searchProjectsByProjectName_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) + (_etype49, _size46) = iprot.readListBegin() + for _i50 in xrange(_size46): + _elem51 = apache.airavata.model.workspace.ttypes.Project() + _elem51.read(iprot) + self.success.append(_elem51) iprot.readListEnd() else: iprot.skip(ftype) @@ -21186,8 +21498,8 @@ class searchProjectsByProjectName_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 iter52 in self.success: + iter52.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21413,11 +21725,11 @@ class searchProjectsByProjectDesc_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype49, _size46) = iprot.readListBegin() - for _i50 in xrange(_size46): - _elem51 = apache.airavata.model.workspace.ttypes.Project() - _elem51.read(iprot) - self.success.append(_elem51) + (_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) @@ -21458,8 +21770,8 @@ class searchProjectsByProjectDesc_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter52 in self.success: - iter52.write(oprot) + for iter59 in self.success: + iter59.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21685,11 +21997,11 @@ class searchExperimentsByName_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype56, _size53) = iprot.readListBegin() - for _i57 in xrange(_size53): - _elem58 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem58.read(iprot) - self.success.append(_elem58) + (_etype63, _size60) = iprot.readListBegin() + for _i64 in xrange(_size60): + _elem65 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem65.read(iprot) + self.success.append(_elem65) iprot.readListEnd() else: iprot.skip(ftype) @@ -21730,8 +22042,8 @@ class searchExperimentsByName_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter59 in self.success: - iter59.write(oprot) + for iter66 in self.success: + iter66.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -21957,11 +22269,11 @@ class searchExperimentsByDesc_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype63, _size60) = iprot.readListBegin() - for _i64 in xrange(_size60): - _elem65 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem65.read(iprot) - self.success.append(_elem65) + (_etype70, _size67) = iprot.readListBegin() + for _i71 in xrange(_size67): + _elem72 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem72.read(iprot) + self.success.append(_elem72) iprot.readListEnd() else: iprot.skip(ftype) @@ -22002,8 +22314,8 @@ class searchExperimentsByDesc_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter66 in self.success: - iter66.write(oprot) + for iter73 in self.success: + iter73.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22229,11 +22541,11 @@ class searchExperimentsByApplication_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype70, _size67) = iprot.readListBegin() - for _i71 in xrange(_size67): - _elem72 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem72.read(iprot) - self.success.append(_elem72) + (_etype77, _size74) = iprot.readListBegin() + for _i78 in xrange(_size74): + _elem79 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem79.read(iprot) + self.success.append(_elem79) iprot.readListEnd() else: iprot.skip(ftype) @@ -22274,8 +22586,8 @@ class searchExperimentsByApplication_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter73 in self.success: - iter73.write(oprot) + for iter80 in self.success: + iter80.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22501,11 +22813,11 @@ class searchExperimentsByStatus_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype77, _size74) = iprot.readListBegin() - for _i78 in xrange(_size74): - _elem79 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem79.read(iprot) - self.success.append(_elem79) + (_etype84, _size81) = iprot.readListBegin() + for _i85 in xrange(_size81): + _elem86 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem86.read(iprot) + self.success.append(_elem86) iprot.readListEnd() else: iprot.skip(ftype) @@ -22546,8 +22858,8 @@ class searchExperimentsByStatus_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter80 in self.success: - iter80.write(oprot) + for iter87 in self.success: + iter87.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22788,11 +23100,11 @@ class searchExperimentsByCreationTime_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype84, _size81) = iprot.readListBegin() - for _i85 in xrange(_size81): - _elem86 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem86.read(iprot) - self.success.append(_elem86) + (_etype91, _size88) = iprot.readListBegin() + for _i92 in xrange(_size88): + _elem93 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem93.read(iprot) + self.success.append(_elem93) iprot.readListEnd() else: iprot.skip(ftype) @@ -22833,8 +23145,8 @@ class searchExperimentsByCreationTime_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter87 in self.success: - iter87.write(oprot) + for iter94 in self.success: + iter94.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -22937,11 +23249,11 @@ class searchExperiments_args: elif fid == 4: if ftype == TType.MAP: self.filters = {} - (_ktype89, _vtype90, _size88 ) = iprot.readMapBegin() - for _i92 in xrange(_size88): - _key93 = iprot.readI32() - _val94 = iprot.readString() - self.filters[_key93] = _val94 + (_ktype96, _vtype97, _size95 ) = iprot.readMapBegin() + for _i99 in xrange(_size95): + _key100 = iprot.readI32() + _val101 = iprot.readString() + self.filters[_key100] = _val101 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22980,9 +23292,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 kiter95,viter96 in self.filters.items(): - oprot.writeI32(kiter95) - oprot.writeString(viter96) + for kiter102,viter103 in self.filters.items(): + oprot.writeI32(kiter102) + oprot.writeString(viter103) oprot.writeMapEnd() oprot.writeFieldEnd() if self.limit is not None: @@ -23068,11 +23380,11 @@ class searchExperiments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype100, _size97) = iprot.readListBegin() - for _i101 in xrange(_size97): - _elem102 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() - _elem102.read(iprot) - self.success.append(_elem102) + (_etype107, _size104) = iprot.readListBegin() + for _i108 in xrange(_size104): + _elem109 = apache.airavata.model.experiment.ttypes.ExperimentSummaryModel() + _elem109.read(iprot) + self.success.append(_elem109) iprot.readListEnd() else: iprot.skip(ftype) @@ -23113,8 +23425,8 @@ class searchExperiments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter103 in self.success: - iter103.write(oprot) + for iter110 in self.success: + iter110.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -23547,11 +23859,11 @@ class getExperimentsInProject_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype107, _size104) = iprot.readListBegin() - for _i108 in xrange(_size104): - _elem109 = apache.airavata.model.experiment.ttypes.ExperimentModel() - _elem109.read(iprot) - self.success.append(_elem109) + (_etype114, _size111) = iprot.readListBegin() + for _i115 in xrange(_size111): + _elem116 = apache.airavata.model.experiment.ttypes.ExperimentModel() + _elem116.read(iprot) + self.success.append(_elem116) iprot.readListEnd() else: iprot.skip(ftype) @@ -23598,8 +23910,8 @@ class getExperimentsInProject_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter110 in self.success: - iter110.write(oprot) + for iter117 in self.success: + iter117.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -23815,11 +24127,11 @@ class getUserExperiments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype114, _size111) = iprot.readListBegin() - for _i115 in xrange(_size111): - _elem116 = apache.airavata.model.experiment.ttypes.ExperimentModel() - _elem116.read(iprot) - self.success.append(_elem116) + (_etype121, _size118) = iprot.readListBegin() + for _i122 in xrange(_size118): + _elem123 = apache.airavata.model.experiment.ttypes.ExperimentModel() + _elem123.read(iprot) + self.success.append(_elem123) iprot.readListEnd() else: iprot.skip(ftype) @@ -23860,8 +24172,8 @@ class getUserExperiments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter117 in self.success: - iter117.write(oprot) + for iter124 in self.success: + iter124.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26094,11 +26406,11 @@ class getExperimentOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype121, _size118) = iprot.readListBegin() - for _i122 in xrange(_size118): - _elem123 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem123.read(iprot) - self.success.append(_elem123) + (_etype128, _size125) = iprot.readListBegin() + for _i129 in xrange(_size125): + _elem130 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem130.read(iprot) + self.success.append(_elem130) iprot.readListEnd() else: iprot.skip(ftype) @@ -26145,8 +26457,8 @@ class getExperimentOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter124 in self.success: - iter124.write(oprot) + for iter131 in self.success: + iter131.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26320,11 +26632,11 @@ class getIntermediateOutputs_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype128, _size125) = iprot.readListBegin() - for _i129 in xrange(_size125): - _elem130 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() - _elem130.read(iprot) - self.success.append(_elem130) + (_etype135, _size132) = iprot.readListBegin() + for _i136 in xrange(_size132): + _elem137 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem137.read(iprot) + self.success.append(_elem137) iprot.readListEnd() else: iprot.skip(ftype) @@ -26371,8 +26683,8 @@ class getIntermediateOutputs_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter131 in self.success: - iter131.write(oprot) + for iter138 in self.success: + iter138.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26546,12 +26858,12 @@ class getJobStatuses_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype133, _vtype134, _size132 ) = iprot.readMapBegin() - for _i136 in xrange(_size132): - _key137 = iprot.readString() - _val138 = apache.airavata.model.status.ttypes.JobStatus() - _val138.read(iprot) - self.success[_key137] = _val138 + (_ktype140, _vtype141, _size139 ) = iprot.readMapBegin() + for _i143 in xrange(_size139): + _key144 = iprot.readString() + _val145 = apache.airavata.model.status.ttypes.JobStatus() + _val145.read(iprot) + self.success[_key144] = _val145 iprot.readMapEnd() else: iprot.skip(ftype) @@ -26598,9 +26910,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 kiter139,viter140 in self.success.items(): - oprot.writeString(kiter139) - viter140.write(oprot) + for kiter146,viter147 in self.success.items(): + oprot.writeString(kiter146) + viter147.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -26774,11 +27086,11 @@ class getJobDetails_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype144, _size141) = iprot.readListBegin() - for _i145 in xrange(_size141): - _elem146 = apache.airavata.model.job.ttypes.JobModel() - _elem146.read(iprot) - self.success.append(_elem146) + (_etype151, _size148) = iprot.readListBegin() + for _i152 in xrange(_size148): + _elem153 = apache.airavata.model.job.ttypes.JobModel() + _elem153.read(iprot) + self.success.append(_elem153) iprot.readListEnd() else: iprot.skip(ftype) @@ -26825,8 +27137,8 @@ class getJobDetails_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) + for iter154 in self.success: + iter154.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -28083,11 +28395,11 @@ class getAllAppModules_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.ApplicationModule() - _elem153.read(iprot) - self.success.append(_elem153) + (_etype158, _size155) = iprot.readListBegin() + for _i159 in xrange(_size155): + _elem160 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationModule() + _elem160.read(iprot) + self.success.append(_elem160) iprot.readListEnd() else: iprot.skip(ftype) @@ -28128,8 +28440,8 @@ class 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 iter161 in self.success: + iter161.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -29343,11 +29655,11 @@ class getAllApplicationDeployments_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype158, _size155) = iprot.readListBegin() - for _i159 in xrange(_size155): - _elem160 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() - _elem160.read(iprot) - self.success.append(_elem160) + (_etype165, _size162) = iprot.readListBegin() + for _i166 in xrange(_size162): + _elem167 = apache.airavata.model.appcatalog.appdeployment.ttypes.ApplicationDeploymentDescription() + _elem167.read(iprot) + self.success.append(_elem167) iprot.readListEnd() else: iprot.skip(ftype) @@ -29388,8 +29700,8 @@ class getAllApplicationDeployments_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter161 in self.success: - iter161.write(oprot) + for iter168 in self.success: + iter168.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -29555,10 +29867,10 @@ class getAppModuleDeployedResources_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype165, _size162) = iprot.readListBegin() - for _i166 in xrange(_size162): - _elem167 = iprot.readString() - self.success.append(_elem167) + (_etype172, _size169) = iprot.readListBegin() + for _i173 in xrange(_size169): + _elem174 = iprot.readString() + self.success.append(_elem174) iprot.readListEnd() else: iprot.skip(ftype) @@ -29599,8 +29911,8 @@ class getAppModuleDeployedResources_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter168 in self.success: - oprot.writeString(iter168) + for iter175 in self.success: + oprot.writeString(iter175) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -30838,11 +31150,11 @@ class getAllApplicationInterfaceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype170, _vtype171, _size169 ) = iprot.readMapBegin() - for _i173 in xrange(_size169): - _key174 = iprot.readString() - _val175 = iprot.readString() - self.success[_key174] = _val175 + (_ktype177, _vtype178, _size176 ) = iprot.readMapBegin() + for _i180 in xrange(_size176): + _key181 = iprot.readString() + _val182 = iprot.readString() + self.success[_key181] = _val182 iprot.readMapEnd() else: iprot.skip(ftype) @@ -30883,9 +31195,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 kiter176,viter177 in self.success.items(): - oprot.writeString(kiter176) - oprot.writeString(viter177) + for kiter183,viter184 in self.success.items(): + oprot.writeString(kiter183) + oprot.writeString(viter184) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -31051,221 +31363,9 @@ class getAllApplicationInterfaces_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype181, _size178) = iprot.readListBegin() - for _i182 in xrange(_size178): - _elem183 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() - _elem183.read(iprot) - self.success.append(_elem183) - 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('getAllApplicationInterfaces_result') - if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter184 in self.success: - iter184.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 getApplicationInputs_args: - """ - Attributes: - - authzToken - - appInterfaceId - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 - (2, TType.STRING, 'appInterfaceId', None, None, ), # 2 - ) - - def __init__(self, authzToken=None, appInterfaceId=None,): - self.authzToken = authzToken - self.appInterfaceId = appInterfaceId - - def read(self, iprot): - if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: - 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.appInterfaceId = 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('getApplicationInputs_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) - 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.appInterfaceId is None: - raise TProtocol.TProtocolException(message='Required field appInterfaceId is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.authzToken) - value = (value * 31) ^ hash(self.appInterfaceId) - 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 getApplicationInputs_result: - """ - Attributes: - - success - - ire - - ace - - ase - - ae - """ - - thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.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 = [] (_etype188, _size185) = iprot.readListBegin() for _i189 in xrange(_size185): - _elem190 = apache.airavata.model.application.io.ttypes.InputDataObjectType() + _elem190 = apache.airavata.model.appcatalog.appinterface.ttypes.ApplicationInterfaceDescription() _elem190.read(iprot) self.success.append(_elem190) iprot.readListEnd() @@ -31304,7 +31404,7 @@ class getApplicationInputs_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('getApplicationInputs_result') + oprot.writeStructBegin('getAllApplicationInterfaces_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) @@ -31355,7 +31455,7 @@ class getApplicationInputs_result: def __ne__(self, other): return not (self == other) -class getApplicationOutputs_args: +class getApplicationInputs_args: """ Attributes: - authzToken @@ -31401,7 +31501,7 @@ class getApplicationOutputs_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('getApplicationOutputs_args') + oprot.writeStructBegin('getApplicationInputs_args') if self.authzToken is not None: oprot.writeFieldBegin('authzToken', TType.STRUCT, 1) self.authzToken.write(oprot) @@ -31438,7 +31538,7 @@ class getApplicationOutputs_args: def __ne__(self, other): return not (self == other) -class getApplicationOutputs_result: +class getApplicationInputs_result: """ Attributes: - success @@ -31449,7 +31549,7 @@ class getApplicationOutputs_result: """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec)), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.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 @@ -31477,7 +31577,7 @@ class getApplicationOutputs_result: self.success = [] (_etype195, _size192) = iprot.readListBegin() for _i196 in xrange(_size192): - _elem197 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem197 = apache.airavata.model.application.io.ttypes.InputDataObjectType() _elem197.read(iprot) self.success.append(_elem197) iprot.readListEnd() @@ -31516,7 +31616,7 @@ class getApplicationOutputs_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('getApplicationOutputs_result') + oprot.writeStructBegin('getApplicationInputs_result') if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) @@ -31567,6 +31667,218 @@ class getApplicationOutputs_result: def __ne__(self, other): return not (self == other) +class getApplicationOutputs_args: + """ + Attributes: + - authzToken + - appInterfaceId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'authzToken', (apache.airavata.model.security.ttypes.AuthzToken, apache.airavata.model.security.ttypes.AuthzToken.thrift_spec), None, ), # 1 + (2, TType.STRING, 'appInterfaceId', None, None, ), # 2 + ) + + def __init__(self, authzToken=None, appInterfaceId=None,): + self.authzToken = authzToken + self.appInterfaceId = appInterfaceId + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + 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.appInterfaceId = 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('getApplicationOutputs_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) + 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.appInterfaceId is None: + raise TProtocol.TProtocolException(message='Required field appInterfaceId is unset!') + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.authzToken) + value = (value * 31) ^ hash(self.appInterfaceId) + 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 getApplicationOutputs_result: + """ + Attributes: + - success + - ire + - ace + - ase + - ae + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.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 = [] + (_etype202, _size199) = iprot.readListBegin() + for _i203 in xrange(_size199): + _elem204 = apache.airavata.model.application.io.ttypes.OutputDataObjectType() + _elem204.read(iprot) + self.success.append(_elem204) + 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('getApplicationOutputs_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter205 in self.success: + iter205.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 getAvailableAppInterfaceComputeResources_args: """ Attributes: @@ -31687,11 +31999,11 @@ class getAvailableAppInterfaceComputeResources_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype200, _vtype201, _size199 ) = iprot.readMapBegin() - for _i203 in xrange(_size199): - _key204 = iprot.readString() - _val205 = iprot.readString() - self.success[_key204] = _val205 + (_ktype207, _vtype208, _size206 ) = iprot.readMapBegin() + for _i210 in xrange(_size206): + _key211 = iprot.readString() + _val212 = iprot.readString() + self.success[_key211] = _val212 iprot.readMapEnd() else: iprot.skip(ftype) @@ -31732,9 +32044,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 kiter206,viter207 in self.success.items(): - oprot.writeString(kiter206) - oprot.writeString(viter207) + for kiter213,viter214 in self.success.items(): + oprot.writeString(kiter213) + oprot.writeString(viter214) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -32293,11 +32605,11 @@ class getAllComputeResourceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype209, _vtype210, _size208 ) = iprot.readMapBegin() - for _i212 in xrange(_size208): - _key213 = iprot.readString() - _val214 = iprot.readString() - self.success[_key213] = _val214 + (_ktype216, _vtype217, _size215 ) = iprot.readMapBegin() + for _i219 in xrange(_size215): + _key220 = iprot.readString() + _val221 = iprot.readString() + self.success[_key220] = _val221 iprot.readMapEnd() else: iprot.skip(ftype) @@ -32338,9 +32650,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 kiter215,viter216 in self.success.items(): - oprot.writeString(kiter215) - oprot.writeString(viter216) + for kiter222,viter223 in self.success.items(): + oprot.writeString(kiter222) + oprot.writeString(viter223) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -33321,11 +33633,11 @@ class getAllStorageResourceNames_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype218, _vtype219, _size217 ) = iprot.readMapBegin() - for _i221 in xrange(_size217): - _key222 = iprot.readString() - _val223 = iprot.readString() - self.success[_key222] = _val223 + (_ktype225, _vtype226, _size224 ) = iprot.readMapBegin() + for _i228 in xrange(_size224): + _key229 = iprot.readString() + _val230 = iprot.readString() + self.success[_key229] = _val230 iprot.readMapEnd() else: iprot.skip(ftype) @@ -33366,9 +33678,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 kiter224,viter225 in self.success.items(): - oprot.writeString(kiter224) - oprot.writeString(viter225) + for kiter231,viter232 in self.success.items(): + oprot.writeString(kiter231) + oprot.writeString(viter232) oprot.writeMapEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -39857,11 +40169,11 @@ class changeJobSubmissionPriorities_args: elif fid == 2: if ftype == TType.MAP: self.jobSubmissionPriorityMap = {} - (_ktype227, _vtype228, _size226 ) = iprot.readMapBegin() - for _i230 in xrange(_size226): - _key231 = iprot.readString() - _val232 = iprot.readI32() - self.jobSubmissionPriorityMap[_key231] = _val232 + (_ktype234, _vtype235, _size233 ) = iprot.readMapBegin() + for _i237 in xrange(_size233): + _key238 = iprot.readString() + _val239 = iprot.readI32() + self.jobSubmissionPriorityMap[_key238] = _val239 iprot.readMapEnd() else: iprot.skip(ftype) @@ -39882,9 +40194,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 kiter233,viter234 in self.jobSubmissionPriorityMap.items(): - oprot.writeString(kiter233) - oprot.writeI32(viter234) + for kiter240,viter241 in self.jobSubmissionPriorityMap.items(): + oprot.writeString(kiter240) + oprot.writeI32(viter241) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -40070,11 +40382,11 @@ class changeDataMovementPriorities_args: elif fid == 2: if ftype == TType.MAP: self.dataMovementPriorityMap = {} - (_ktype236, _vtype237, _size235 ) = iprot.readMapBegin() - for _i239 in xrange(_size235): - _key240 = iprot.readString() - _val241 = iprot.readI32() - self.dataMovementPriorityMap[_key240] = _val241 + (_ktype243, _vtype244, _size242 ) = iprot.readMapBegin() + for _i246 in xrange(_size242): + _key247 = iprot.readString() + _val248 = iprot.readI32() + self.dataMovementPriorityMap[_key247] = _val248 iprot.readMapEnd() else: iprot.skip(ftype) @@ -40095,9 +40407,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 kiter242,viter243 in self.dataMovementPriorityMap.items(): - oprot.writeString(kiter242) - oprot.writeI32(viter243) + for kiter249,viter250 in self.dataMovementPriorityMap.items(): + oprot.writeString(kiter249) + oprot.writeI32(viter250) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -43603,11 +43915,11 @@ class getAllGatewayComputeResourcePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype247, _size244) = iprot.readListBegin() - for _i248 in xrange(_size244): - _elem249 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference() - _elem249.read(iprot) - self.success.append(_elem249) + (_etype254, _size251) = iprot.readListBegin() + for _i255 in xrange(_size251): + _elem256 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.ComputeResourcePreference() + _elem256.read(iprot) + self.success.append(_elem256) iprot.readListEnd() else: iprot.skip(ftype) @@ -43648,8 +43960,8 @@ class getAllGatewayComputeResourcePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter250 in self.success: - iter250.write(oprot) + for iter257 in self.success: + iter257.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -43815,11 +44127,11 @@ class getAllGatewayStoragePreferences_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype254, _size251) = iprot.readListBegin() - for _i255 in xrange(_size251): - _elem256 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() - _elem256.read(iprot) - self.success.append(_elem256) + (_etype261, _size258) = iprot.readListBegin() + for _i262 in xrange(_size258): + _elem263 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.StoragePreference() + _elem263.read(iprot) + self.success.append(_elem263) iprot.readListEnd() else: iprot.skip(ftype) @@ -43860,8 +44172,8 @@ class getAllGatewayStoragePreferences_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter257 in self.success: - iter257.write(oprot) + for iter264 in self.success: + iter264.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -44012,11 +44324,11 @@ class getAllGatewayResourceProfiles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype261, _size258) = iprot.readListBegin() - for _i262 in xrange(_size258): - _elem263 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile() - _elem263.read(iprot) - self.success.append(_elem263) + (_etype268, _size265) = iprot.readListBegin() + for _i269 in xrange(_size265): + _elem270 = apache.airavata.model.appcatalog.gatewayprofile.ttypes.GatewayResourceProfile() + _elem270.read(iprot) + self.success.append(_elem270) iprot.readListEnd() else: iprot.skip(ftype) @@ -44057,8 +44369,8 @@ class getAllGatewayResourceProfiles_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter264 in self.success: - iter264.write(oprot) + for iter271 in self.success: + iter271.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -45128,10 +45440,10 @@ class getAllWorkflows_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype268, _size265) = iprot.readListBegin() - for _i269 in xrange(_size265): - _elem270 = iprot.readString() - self.success.append(_elem270) + (_etype275, _size272) = iprot.readListBegin() + for _i276 in xrange(_size272): + _elem277 = iprot.readString() + self.success.append(_elem277) iprot.readListEnd() else: iprot.skip(ftype) @@ -45172,8 +45484,8 @@ class getAllWorkflows_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter271 in self.success: - oprot.writeString(iter271) + for iter278 in self.success: + oprot.writeString(iter278) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: @@ -47382,11 +47694,11 @@ class getChildDataProducts_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype275, _size272) = iprot.readListBegin() - for _i276 in xrange(_size272): - _elem277 = apache.airavata.model.data.replica.ttypes.DataProductModel() - _elem277.read(iprot) - self.success.append(_elem277) + (_etype282, _size279) = iprot.readListBegin() + for _i283 in xrange(_size279): + _elem284 = apache.airavata.model.data.replica.ttypes.DataProductModel() + _elem284.read(iprot) + self.success.append(_elem284) iprot.readListEnd() else: iprot.skip(ftype) @@ -47427,8 +47739,8 @@ class getChildDataProducts_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter278 in self.success: - iter278.write(oprot) + for iter285 in self.success: + iter285.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.ire is not None: http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java index c6ecee3..900bf6d 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/ComponentStatus.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class ComponentStatus implements org.apache.thrift.TBase<ComponentStatus, ComponentStatus._Fields>, java.io.Serializable, Cloneable, Comparable<ComponentStatus> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ComponentStatus"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java index 6921217..ce38569 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/EdgeModel.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class EdgeModel implements org.apache.thrift.TBase<EdgeModel, EdgeModel._Fields>, java.io.Serializable, Cloneable, Comparable<EdgeModel> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("EdgeModel"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java index fb21093..282ca7c 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/NodeModel.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class NodeModel implements org.apache.thrift.TBase<NodeModel, NodeModel._Fields>, java.io.Serializable, Cloneable, Comparable<NodeModel> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("NodeModel"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java index 0c1b0aa..9900063 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/PortModel.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class PortModel implements org.apache.thrift.TBase<PortModel, PortModel._Fields>, java.io.Serializable, Cloneable, Comparable<PortModel> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PortModel"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowModel.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowModel.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowModel.java index cf537cc..572cd40 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowModel.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowModel.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class WorkflowModel implements org.apache.thrift.TBase<WorkflowModel, WorkflowModel._Fields>, java.io.Serializable, Cloneable, Comparable<WorkflowModel> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WorkflowModel"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowStatus.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowStatus.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowStatus.java index 4f71797..cb119c7 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowStatus.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/WorkflowStatus.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class WorkflowStatus implements org.apache.thrift.TBase<WorkflowStatus, WorkflowStatus._Fields>, java.io.Serializable, Cloneable, Comparable<WorkflowStatus> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("WorkflowStatus"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java index 7a4f8f3..e95ee37 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationDeploymentDescription.java @@ -77,7 +77,7 @@ import org.slf4j.LoggerFactory; * assigns to the environment variable "NAME" the value * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class ApplicationDeploymentDescription implements org.apache.thrift.TBase<ApplicationDeploymentDescription, ApplicationDeploymentDescription._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationDeploymentDescription> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationDeploymentDescription"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java index 448280c..acb89d3 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/ApplicationModule.java @@ -66,7 +66,7 @@ import org.slf4j.LoggerFactory; * Descriprion of the Module * */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class ApplicationModule implements org.apache.thrift.TBase<ApplicationModule, ApplicationModule._Fields>, java.io.Serializable, Cloneable, Comparable<ApplicationModule> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ApplicationModule"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java index 6530adb..4e4db6b 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/CommandObject.java @@ -60,7 +60,7 @@ import org.slf4j.LoggerFactory; * commandOrder: * Order of the command in the multiple command situation */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class CommandObject implements org.apache.thrift.TBase<CommandObject, CommandObject._Fields>, java.io.Serializable, Cloneable, Comparable<CommandObject> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("CommandObject"); http://git-wip-us.apache.org/repos/asf/airavata/blob/9dd7c14a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java index efe82b6..b6491da 100644 --- a/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java +++ b/airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/appcatalog/appdeployment/SetEnvPaths.java @@ -63,7 +63,7 @@ import org.slf4j.LoggerFactory; * envPathOrder: * The order of the setting of the env variables when there are multiple env variables */ -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-25") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-06-27") public class SetEnvPaths implements org.apache.thrift.TBase<SetEnvPaths, SetEnvPaths._Fields>, java.io.Serializable, Cloneable, Comparable<SetEnvPaths> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("SetEnvPaths");
