Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 87483200D05 for ; Mon, 7 Aug 2017 16:00:48 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 85D81165611; Mon, 7 Aug 2017 14:00:48 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 364A4165607 for ; Mon, 7 Aug 2017 16:00:43 +0200 (CEST) Received: (qmail 85723 invoked by uid 500); 7 Aug 2017 14:00:42 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 83820 invoked by uid 99); 7 Aug 2017 14:00:41 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 07 Aug 2017 14:00:41 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 823E1F5ED4; Mon, 7 Aug 2017 14:00:37 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: machristie@apache.org To: commits@airavata.apache.org Date: Mon, 07 Aug 2017 14:01:16 -0000 Message-Id: <7aff5a5c45974edc9a9400972e13c8c0@git.apache.org> In-Reply-To: <4c732a38ed394fc5b4e7972ef04142ad@git.apache.org> References: <4c732a38ed394fc5b4e7972ef04142ad@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [40/51] [abbrv] [partial] airavata git commit: AIRAVATA-2505 Upgrade Airavata to Thrift 0.10.0 archived-at: Mon, 07 Aug 2017 14:00:48 -0000 http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py index 5903ba0..1ce8736 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/appcatalog/userresourceprofile/ttypes.py @@ -1,538 +1,498 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.10.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # # options string: py # -from thrift.Thrift import TType, TMessageType, TException, TApplicationException +from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException +from thrift.protocol.TProtocol import TProtocolException +import sys import apache.airavata.model.appcatalog.computeresource.ttypes import apache.airavata.model.data.movement.ttypes import apache.airavata.model.user.ttypes - from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None - - - -class UserComputeResourcePreference: - """ - User specific preferences for a Computer Resource - - computeResourceId: - Corelate the preference to a compute resource. - - - loginUserName: - If turned true, Airavata will override the preferences of better alternatives exist. - - - preferredBatchQueue: - Gateways can choose a defualt batch queue based on average job dimention, reservations or other metrics. - - scratchLocation: - Path to the local scratch space on a HPC cluster. Typically used to create working directory for job execution. - - allocationProjectNumber: - Typically used on HPC machines to charge computing usage to a account number. For instance, on XSEDE once an - allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the - account to be used has to be added to the allocation. - - resourceSpecificCredentialStoreToken: - Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's - default credential store. - - - Attributes: - - computeResourceId - - loginUserName - - preferredBatchQueue - - scratchLocation - - allocationProjectNumber - - resourceSpecificCredentialStoreToken - - qualityOfService - - reservation - - reservationStartTime - - reservationEndTime - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'computeResourceId', None, None, ), # 1 - (2, TType.STRING, 'loginUserName', None, None, ), # 2 - (3, TType.STRING, 'preferredBatchQueue', None, None, ), # 3 - (4, TType.STRING, 'scratchLocation', None, None, ), # 4 - (5, TType.STRING, 'allocationProjectNumber', None, None, ), # 5 - (6, TType.STRING, 'resourceSpecificCredentialStoreToken', None, None, ), # 6 - (7, TType.STRING, 'qualityOfService', None, None, ), # 7 - (8, TType.STRING, 'reservation', None, None, ), # 8 - (9, TType.I64, 'reservationStartTime', None, None, ), # 9 - (10, TType.I64, 'reservationEndTime', None, None, ), # 10 - ) - - def __init__(self, computeResourceId=None, loginUserName=None, preferredBatchQueue=None, scratchLocation=None, allocationProjectNumber=None, resourceSpecificCredentialStoreToken=None, qualityOfService=None, reservation=None, reservationStartTime=None, reservationEndTime=None,): - self.computeResourceId = computeResourceId - self.loginUserName = loginUserName - self.preferredBatchQueue = preferredBatchQueue - self.scratchLocation = scratchLocation - self.allocationProjectNumber = allocationProjectNumber - self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken - self.qualityOfService = qualityOfService - self.reservation = reservation - self.reservationStartTime = reservationStartTime - self.reservationEndTime = reservationEndTime - - 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.STRING: - self.computeResourceId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.loginUserName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.preferredBatchQueue = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.scratchLocation = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRING: - self.allocationProjectNumber = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.STRING: - self.resourceSpecificCredentialStoreToken = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.STRING: - self.qualityOfService = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.STRING: - self.reservation = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.I64: - self.reservationStartTime = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.I64: - self.reservationEndTime = iprot.readI64() - 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('UserComputeResourcePreference') - if self.computeResourceId is not None: - oprot.writeFieldBegin('computeResourceId', TType.STRING, 1) - oprot.writeString(self.computeResourceId) - oprot.writeFieldEnd() - if self.loginUserName is not None: - oprot.writeFieldBegin('loginUserName', TType.STRING, 2) - oprot.writeString(self.loginUserName) - oprot.writeFieldEnd() - if self.preferredBatchQueue is not None: - oprot.writeFieldBegin('preferredBatchQueue', TType.STRING, 3) - oprot.writeString(self.preferredBatchQueue) - oprot.writeFieldEnd() - if self.scratchLocation is not None: - oprot.writeFieldBegin('scratchLocation', TType.STRING, 4) - oprot.writeString(self.scratchLocation) - oprot.writeFieldEnd() - if self.allocationProjectNumber is not None: - oprot.writeFieldBegin('allocationProjectNumber', TType.STRING, 5) - oprot.writeString(self.allocationProjectNumber) - oprot.writeFieldEnd() - if self.resourceSpecificCredentialStoreToken is not None: - oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 6) - oprot.writeString(self.resourceSpecificCredentialStoreToken) - oprot.writeFieldEnd() - if self.qualityOfService is not None: - oprot.writeFieldBegin('qualityOfService', TType.STRING, 7) - oprot.writeString(self.qualityOfService) - oprot.writeFieldEnd() - if self.reservation is not None: - oprot.writeFieldBegin('reservation', TType.STRING, 8) - oprot.writeString(self.reservation) - oprot.writeFieldEnd() - if self.reservationStartTime is not None: - oprot.writeFieldBegin('reservationStartTime', TType.I64, 9) - oprot.writeI64(self.reservationStartTime) - oprot.writeFieldEnd() - if self.reservationEndTime is not None: - oprot.writeFieldBegin('reservationEndTime', TType.I64, 10) - oprot.writeI64(self.reservationEndTime) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - if self.computeResourceId is None: - raise TProtocol.TProtocolException(message='Required field computeResourceId is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.computeResourceId) - value = (value * 31) ^ hash(self.loginUserName) - value = (value * 31) ^ hash(self.preferredBatchQueue) - value = (value * 31) ^ hash(self.scratchLocation) - value = (value * 31) ^ hash(self.allocationProjectNumber) - value = (value * 31) ^ hash(self.resourceSpecificCredentialStoreToken) - value = (value * 31) ^ hash(self.qualityOfService) - value = (value * 31) ^ hash(self.reservation) - value = (value * 31) ^ hash(self.reservationStartTime) - value = (value * 31) ^ hash(self.reservationEndTime) - 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 UserStoragePreference: - """ - Attributes: - - storageResourceId - - loginUserName - - fileSystemRootLocation - - resourceSpecificCredentialStoreToken - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'storageResourceId', None, None, ), # 1 - (2, TType.STRING, 'loginUserName', None, None, ), # 2 - (3, TType.STRING, 'fileSystemRootLocation', None, None, ), # 3 - (4, TType.STRING, 'resourceSpecificCredentialStoreToken', None, None, ), # 4 - ) - - def __init__(self, storageResourceId=None, loginUserName=None, fileSystemRootLocation=None, resourceSpecificCredentialStoreToken=None,): - self.storageResourceId = storageResourceId - self.loginUserName = loginUserName - self.fileSystemRootLocation = fileSystemRootLocation - self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken - - 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.STRING: - self.storageResourceId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.loginUserName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.fileSystemRootLocation = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.resourceSpecificCredentialStoreToken = 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('UserStoragePreference') - if self.storageResourceId is not None: - oprot.writeFieldBegin('storageResourceId', TType.STRING, 1) - oprot.writeString(self.storageResourceId) - oprot.writeFieldEnd() - if self.loginUserName is not None: - oprot.writeFieldBegin('loginUserName', TType.STRING, 2) - oprot.writeString(self.loginUserName) - oprot.writeFieldEnd() - if self.fileSystemRootLocation is not None: - oprot.writeFieldBegin('fileSystemRootLocation', TType.STRING, 3) - oprot.writeString(self.fileSystemRootLocation) - oprot.writeFieldEnd() - if self.resourceSpecificCredentialStoreToken is not None: - oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 4) - oprot.writeString(self.resourceSpecificCredentialStoreToken) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - if self.storageResourceId is None: - raise TProtocol.TProtocolException(message='Required field storageResourceId is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.storageResourceId) - value = (value * 31) ^ hash(self.loginUserName) - value = (value * 31) ^ hash(self.fileSystemRootLocation) - value = (value * 31) ^ hash(self.resourceSpecificCredentialStoreToken) - 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 UserResourceProfile: - """ - User Resource Profile - - userId: - Unique identifier used to link user to corresponding user data model - - gatewayID: - Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration. - - credentialStoreToken: - Gateway's defualt credential store token. - - computeResourcePreferences: - List of resource preferences for each of the registered compute resources. - - identityServerTenant: - - identityServerPwdCredToken: - - isNull: - Indicates that this instance is just a container for a null value. - - - Attributes: - - userId - - gatewayID - - credentialStoreToken - - userComputeResourcePreferences - - userStoragePreferences - - identityServerTenant - - identityServerPwdCredToken - - isNull - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'userId', None, None, ), # 1 - (2, TType.STRING, 'gatewayID', None, None, ), # 2 - (3, TType.STRING, 'credentialStoreToken', None, None, ), # 3 - (4, TType.LIST, 'userComputeResourcePreferences', (TType.STRUCT,(UserComputeResourcePreference, UserComputeResourcePreference.thrift_spec)), None, ), # 4 - (5, TType.LIST, 'userStoragePreferences', (TType.STRUCT,(UserStoragePreference, UserStoragePreference.thrift_spec)), None, ), # 5 - (6, TType.STRING, 'identityServerTenant', None, None, ), # 6 - (7, TType.STRING, 'identityServerPwdCredToken', None, None, ), # 7 - (8, TType.BOOL, 'isNull', None, False, ), # 8 - ) - - def __init__(self, userId=None, gatewayID=None, credentialStoreToken=None, userComputeResourcePreferences=None, userStoragePreferences=None, identityServerTenant=None, identityServerPwdCredToken=None, isNull=thrift_spec[8][4],): - self.userId = userId - self.gatewayID = gatewayID - self.credentialStoreToken = credentialStoreToken - self.userComputeResourcePreferences = userComputeResourcePreferences - self.userStoragePreferences = userStoragePreferences - self.identityServerTenant = identityServerTenant - self.identityServerPwdCredToken = identityServerPwdCredToken - self.isNull = isNull - - 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.STRING: - self.userId = iprot.readString() - 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.credentialStoreToken = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.LIST: - self.userComputeResourcePreferences = [] - (_etype3, _size0) = iprot.readListBegin() - for _i4 in xrange(_size0): - _elem5 = UserComputeResourcePreference() - _elem5.read(iprot) - self.userComputeResourcePreferences.append(_elem5) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.LIST: - self.userStoragePreferences = [] - (_etype9, _size6) = iprot.readListBegin() - for _i10 in xrange(_size6): - _elem11 = UserStoragePreference() - _elem11.read(iprot) - self.userStoragePreferences.append(_elem11) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.STRING: - self.identityServerTenant = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.STRING: - self.identityServerPwdCredToken = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.BOOL: - self.isNull = iprot.readBool() - 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('UserResourceProfile') - if self.userId is not None: - oprot.writeFieldBegin('userId', TType.STRING, 1) - oprot.writeString(self.userId) - oprot.writeFieldEnd() - if self.gatewayID is not None: - oprot.writeFieldBegin('gatewayID', TType.STRING, 2) - oprot.writeString(self.gatewayID) - oprot.writeFieldEnd() - if self.credentialStoreToken is not None: - oprot.writeFieldBegin('credentialStoreToken', TType.STRING, 3) - oprot.writeString(self.credentialStoreToken) - oprot.writeFieldEnd() - if self.userComputeResourcePreferences is not None: - oprot.writeFieldBegin('userComputeResourcePreferences', TType.LIST, 4) - oprot.writeListBegin(TType.STRUCT, len(self.userComputeResourcePreferences)) - for iter12 in self.userComputeResourcePreferences: - iter12.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.userStoragePreferences is not None: - oprot.writeFieldBegin('userStoragePreferences', TType.LIST, 5) - oprot.writeListBegin(TType.STRUCT, len(self.userStoragePreferences)) - for iter13 in self.userStoragePreferences: - iter13.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.identityServerTenant is not None: - oprot.writeFieldBegin('identityServerTenant', TType.STRING, 6) - oprot.writeString(self.identityServerTenant) - oprot.writeFieldEnd() - if self.identityServerPwdCredToken is not None: - oprot.writeFieldBegin('identityServerPwdCredToken', TType.STRING, 7) - oprot.writeString(self.identityServerPwdCredToken) - oprot.writeFieldEnd() - if self.isNull is not None: - oprot.writeFieldBegin('isNull', TType.BOOL, 8) - oprot.writeBool(self.isNull) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - if self.userId is None: - raise TProtocol.TProtocolException(message='Required field userId 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.userId) - value = (value * 31) ^ hash(self.gatewayID) - value = (value * 31) ^ hash(self.credentialStoreToken) - value = (value * 31) ^ hash(self.userComputeResourcePreferences) - value = (value * 31) ^ hash(self.userStoragePreferences) - value = (value * 31) ^ hash(self.identityServerTenant) - value = (value * 31) ^ hash(self.identityServerPwdCredToken) - value = (value * 31) ^ hash(self.isNull) - 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 UserComputeResourcePreference(object): + """ + User specific preferences for a Computer Resource + + computeResourceId: + Corelate the preference to a compute resource. + + + loginUserName: + If turned true, Airavata will override the preferences of better alternatives exist. + + + preferredBatchQueue: + Gateways can choose a defualt batch queue based on average job dimention, reservations or other metrics. + + scratchLocation: + Path to the local scratch space on a HPC cluster. Typically used to create working directory for job execution. + + allocationProjectNumber: + Typically used on HPC machines to charge computing usage to a account number. For instance, on XSEDE once an + allocation is approved, an allocation number is assigned. Before passing this number with job submittions, the + account to be used has to be added to the allocation. + + resourceSpecificCredentialStoreToken: + Resource specific credential store token. If this token is specified, then it is superceeded by the gateway's + default credential store. + + + Attributes: + - computeResourceId + - loginUserName + - preferredBatchQueue + - scratchLocation + - allocationProjectNumber + - resourceSpecificCredentialStoreToken + - qualityOfService + - reservation + - reservationStartTime + - reservationEndTime + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'computeResourceId', 'UTF8', None, ), # 1 + (2, TType.STRING, 'loginUserName', 'UTF8', None, ), # 2 + (3, TType.STRING, 'preferredBatchQueue', 'UTF8', None, ), # 3 + (4, TType.STRING, 'scratchLocation', 'UTF8', None, ), # 4 + (5, TType.STRING, 'allocationProjectNumber', 'UTF8', None, ), # 5 + (6, TType.STRING, 'resourceSpecificCredentialStoreToken', 'UTF8', None, ), # 6 + (7, TType.STRING, 'qualityOfService', 'UTF8', None, ), # 7 + (8, TType.STRING, 'reservation', 'UTF8', None, ), # 8 + (9, TType.I64, 'reservationStartTime', None, None, ), # 9 + (10, TType.I64, 'reservationEndTime', None, None, ), # 10 + ) + + def __init__(self, computeResourceId=None, loginUserName=None, preferredBatchQueue=None, scratchLocation=None, allocationProjectNumber=None, resourceSpecificCredentialStoreToken=None, qualityOfService=None, reservation=None, reservationStartTime=None, reservationEndTime=None,): + self.computeResourceId = computeResourceId + self.loginUserName = loginUserName + self.preferredBatchQueue = preferredBatchQueue + self.scratchLocation = scratchLocation + self.allocationProjectNumber = allocationProjectNumber + self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken + self.qualityOfService = qualityOfService + self.reservation = reservation + self.reservationStartTime = reservationStartTime + self.reservationEndTime = reservationEndTime + + def read(self, iprot): + if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None: + iprot._fast_decode(self, iprot, (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.STRING: + self.computeResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.loginUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.preferredBatchQueue = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.scratchLocation = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.allocationProjectNumber = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.resourceSpecificCredentialStoreToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.qualityOfService = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.STRING: + self.reservation = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.I64: + self.reservationStartTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.I64: + self.reservationEndTime = iprot.readI64() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot._fast_encode is not None and self.thrift_spec is not None: + oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('UserComputeResourcePreference') + if self.computeResourceId is not None: + oprot.writeFieldBegin('computeResourceId', TType.STRING, 1) + oprot.writeString(self.computeResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.computeResourceId) + oprot.writeFieldEnd() + if self.loginUserName is not None: + oprot.writeFieldBegin('loginUserName', TType.STRING, 2) + oprot.writeString(self.loginUserName.encode('utf-8') if sys.version_info[0] == 2 else self.loginUserName) + oprot.writeFieldEnd() + if self.preferredBatchQueue is not None: + oprot.writeFieldBegin('preferredBatchQueue', TType.STRING, 3) + oprot.writeString(self.preferredBatchQueue.encode('utf-8') if sys.version_info[0] == 2 else self.preferredBatchQueue) + oprot.writeFieldEnd() + if self.scratchLocation is not None: + oprot.writeFieldBegin('scratchLocation', TType.STRING, 4) + oprot.writeString(self.scratchLocation.encode('utf-8') if sys.version_info[0] == 2 else self.scratchLocation) + oprot.writeFieldEnd() + if self.allocationProjectNumber is not None: + oprot.writeFieldBegin('allocationProjectNumber', TType.STRING, 5) + oprot.writeString(self.allocationProjectNumber.encode('utf-8') if sys.version_info[0] == 2 else self.allocationProjectNumber) + oprot.writeFieldEnd() + if self.resourceSpecificCredentialStoreToken is not None: + oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 6) + oprot.writeString(self.resourceSpecificCredentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.resourceSpecificCredentialStoreToken) + oprot.writeFieldEnd() + if self.qualityOfService is not None: + oprot.writeFieldBegin('qualityOfService', TType.STRING, 7) + oprot.writeString(self.qualityOfService.encode('utf-8') if sys.version_info[0] == 2 else self.qualityOfService) + oprot.writeFieldEnd() + if self.reservation is not None: + oprot.writeFieldBegin('reservation', TType.STRING, 8) + oprot.writeString(self.reservation.encode('utf-8') if sys.version_info[0] == 2 else self.reservation) + oprot.writeFieldEnd() + if self.reservationStartTime is not None: + oprot.writeFieldBegin('reservationStartTime', TType.I64, 9) + oprot.writeI64(self.reservationStartTime) + oprot.writeFieldEnd() + if self.reservationEndTime is not None: + oprot.writeFieldBegin('reservationEndTime', TType.I64, 10) + oprot.writeI64(self.reservationEndTime) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.computeResourceId is None: + raise TProtocolException(message='Required field computeResourceId is unset!') + return + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.items()] + 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 UserStoragePreference(object): + """ + Attributes: + - storageResourceId + - loginUserName + - fileSystemRootLocation + - resourceSpecificCredentialStoreToken + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 1 + (2, TType.STRING, 'loginUserName', 'UTF8', None, ), # 2 + (3, TType.STRING, 'fileSystemRootLocation', 'UTF8', None, ), # 3 + (4, TType.STRING, 'resourceSpecificCredentialStoreToken', 'UTF8', None, ), # 4 + ) + + def __init__(self, storageResourceId=None, loginUserName=None, fileSystemRootLocation=None, resourceSpecificCredentialStoreToken=None,): + self.storageResourceId = storageResourceId + self.loginUserName = loginUserName + self.fileSystemRootLocation = fileSystemRootLocation + self.resourceSpecificCredentialStoreToken = resourceSpecificCredentialStoreToken + + def read(self, iprot): + if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None: + iprot._fast_decode(self, iprot, (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.STRING: + self.storageResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.loginUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.fileSystemRootLocation = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.resourceSpecificCredentialStoreToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot._fast_encode is not None and self.thrift_spec is not None: + oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('UserStoragePreference') + if self.storageResourceId is not None: + oprot.writeFieldBegin('storageResourceId', TType.STRING, 1) + oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId) + oprot.writeFieldEnd() + if self.loginUserName is not None: + oprot.writeFieldBegin('loginUserName', TType.STRING, 2) + oprot.writeString(self.loginUserName.encode('utf-8') if sys.version_info[0] == 2 else self.loginUserName) + oprot.writeFieldEnd() + if self.fileSystemRootLocation is not None: + oprot.writeFieldBegin('fileSystemRootLocation', TType.STRING, 3) + oprot.writeString(self.fileSystemRootLocation.encode('utf-8') if sys.version_info[0] == 2 else self.fileSystemRootLocation) + oprot.writeFieldEnd() + if self.resourceSpecificCredentialStoreToken is not None: + oprot.writeFieldBegin('resourceSpecificCredentialStoreToken', TType.STRING, 4) + oprot.writeString(self.resourceSpecificCredentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.resourceSpecificCredentialStoreToken) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.storageResourceId is None: + raise TProtocolException(message='Required field storageResourceId is unset!') + return + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.items()] + 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 UserResourceProfile(object): + """ + User Resource Profile + + userId: + Unique identifier used to link user to corresponding user data model + + gatewayID: + Unique identifier for the gateway assigned by Airavata. Corelate this to Airavata Admin API Gateway Registration. + + credentialStoreToken: + Gateway's defualt credential store token. + + computeResourcePreferences: + List of resource preferences for each of the registered compute resources. + + identityServerTenant: + + identityServerPwdCredToken: + + isNull: + Indicates that this instance is just a container for a null value. + + + Attributes: + - userId + - gatewayID + - credentialStoreToken + - userComputeResourcePreferences + - userStoragePreferences + - identityServerTenant + - identityServerPwdCredToken + - isNull + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'userId', 'UTF8', None, ), # 1 + (2, TType.STRING, 'gatewayID', 'UTF8', None, ), # 2 + (3, TType.STRING, 'credentialStoreToken', 'UTF8', None, ), # 3 + (4, TType.LIST, 'userComputeResourcePreferences', (TType.STRUCT, (UserComputeResourcePreference, UserComputeResourcePreference.thrift_spec), False), None, ), # 4 + (5, TType.LIST, 'userStoragePreferences', (TType.STRUCT, (UserStoragePreference, UserStoragePreference.thrift_spec), False), None, ), # 5 + (6, TType.STRING, 'identityServerTenant', 'UTF8', None, ), # 6 + (7, TType.STRING, 'identityServerPwdCredToken', 'UTF8', None, ), # 7 + (8, TType.BOOL, 'isNull', None, False, ), # 8 + ) + + def __init__(self, userId=None, gatewayID=None, credentialStoreToken=None, userComputeResourcePreferences=None, userStoragePreferences=None, identityServerTenant=None, identityServerPwdCredToken=None, isNull=thrift_spec[8][4],): + self.userId = userId + self.gatewayID = gatewayID + self.credentialStoreToken = credentialStoreToken + self.userComputeResourcePreferences = userComputeResourcePreferences + self.userStoragePreferences = userStoragePreferences + self.identityServerTenant = identityServerTenant + self.identityServerPwdCredToken = identityServerPwdCredToken + self.isNull = isNull + + def read(self, iprot): + if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None: + iprot._fast_decode(self, iprot, (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.STRING: + self.userId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.gatewayID = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.credentialStoreToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.userComputeResourcePreferences = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in range(_size0): + _elem5 = UserComputeResourcePreference() + _elem5.read(iprot) + self.userComputeResourcePreferences.append(_elem5) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.userStoragePreferences = [] + (_etype9, _size6) = iprot.readListBegin() + for _i10 in range(_size6): + _elem11 = UserStoragePreference() + _elem11.read(iprot) + self.userStoragePreferences.append(_elem11) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.identityServerTenant = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.identityServerPwdCredToken = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.BOOL: + self.isNull = iprot.readBool() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot._fast_encode is not None and self.thrift_spec is not None: + oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('UserResourceProfile') + if self.userId is not None: + oprot.writeFieldBegin('userId', TType.STRING, 1) + oprot.writeString(self.userId.encode('utf-8') if sys.version_info[0] == 2 else self.userId) + oprot.writeFieldEnd() + if self.gatewayID is not None: + oprot.writeFieldBegin('gatewayID', TType.STRING, 2) + oprot.writeString(self.gatewayID.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayID) + oprot.writeFieldEnd() + if self.credentialStoreToken is not None: + oprot.writeFieldBegin('credentialStoreToken', TType.STRING, 3) + oprot.writeString(self.credentialStoreToken.encode('utf-8') if sys.version_info[0] == 2 else self.credentialStoreToken) + oprot.writeFieldEnd() + if self.userComputeResourcePreferences is not None: + oprot.writeFieldBegin('userComputeResourcePreferences', TType.LIST, 4) + oprot.writeListBegin(TType.STRUCT, len(self.userComputeResourcePreferences)) + for iter12 in self.userComputeResourcePreferences: + iter12.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.userStoragePreferences is not None: + oprot.writeFieldBegin('userStoragePreferences', TType.LIST, 5) + oprot.writeListBegin(TType.STRUCT, len(self.userStoragePreferences)) + for iter13 in self.userStoragePreferences: + iter13.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.identityServerTenant is not None: + oprot.writeFieldBegin('identityServerTenant', TType.STRING, 6) + oprot.writeString(self.identityServerTenant.encode('utf-8') if sys.version_info[0] == 2 else self.identityServerTenant) + oprot.writeFieldEnd() + if self.identityServerPwdCredToken is not None: + oprot.writeFieldBegin('identityServerPwdCredToken', TType.STRING, 7) + oprot.writeString(self.identityServerPwdCredToken.encode('utf-8') if sys.version_info[0] == 2 else self.identityServerPwdCredToken) + oprot.writeFieldEnd() + if self.isNull is not None: + oprot.writeFieldBegin('isNull', TType.BOOL, 8) + oprot.writeBool(self.isNull) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.userId is None: + raise TProtocolException(message='Required field userId is unset!') + if self.gatewayID is None: + raise TProtocolException(message='Required field gatewayID is unset!') + return + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.items()] + 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) http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/constants.py index 4a6492b..eb0d35a 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/constants.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/constants.py @@ -1,11 +1,12 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.10.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # # options string: py # -from thrift.Thrift import TType, TMessageType, TException, TApplicationException -from ttypes import * - +from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException +from thrift.protocol.TProtocol import TProtocolException +import sys +from .ttypes import * http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/ttypes.py index 0e678da..da1e363 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/application/io/ttypes.py @@ -1,523 +1,486 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.10.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # # options string: py # -from thrift.Thrift import TType, TMessageType, TException, TApplicationException +from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException +from thrift.protocol.TProtocol import TProtocolException +import sys import apache.airavata.model.appcatalog.computeresource.ttypes - from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None - - -class DataType: - """ - Data Types supported in Airavata. The primitive data types - - """ - STRING = 0 - INTEGER = 1 - FLOAT = 2 - URI = 3 - URI_COLLECTION = 4 - STDOUT = 5 - STDERR = 6 - - _VALUES_TO_NAMES = { - 0: "STRING", - 1: "INTEGER", - 2: "FLOAT", - 3: "URI", - 4: "URI_COLLECTION", - 5: "STDOUT", - 6: "STDERR", - } - - _NAMES_TO_VALUES = { - "STRING": 0, - "INTEGER": 1, - "FLOAT": 2, - "URI": 3, - "URI_COLLECTION": 4, - "STDOUT": 5, - "STDERR": 6, - } - - -class InputDataObjectType: - """ - Application Inputs. The paramters describe how inputs are passed to the application. - - name: - Name of the parameter. - - value: - Value of the parameter. A default value could be set during registration. - - type: - Data type of the parameter - - applicationArguement: - The argument flag sent to the application. Such as -p pressure. - - standardInput: - When this value is set, the parameter is sent as standard input rather than a parameter. - Typically this is passed using redirection operator ">". - - userFriendlyDescription: - Description to be displayed at the user interface. - - metaData: - Any metadat. This is typically ignore by Airavata and is used by gateways for application configuration. - - - Attributes: - - name - - value - - type - - applicationArgument - - standardInput - - userFriendlyDescription - - metaData - - inputOrder - - isRequired - - requiredToAddedToCommandLine - - dataStaged - - storageResourceId - - isReadOnly - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'name', None, None, ), # 1 - (2, TType.STRING, 'value', None, None, ), # 2 - (3, TType.I32, 'type', None, None, ), # 3 - (4, TType.STRING, 'applicationArgument', None, None, ), # 4 - (5, TType.BOOL, 'standardInput', None, None, ), # 5 - (6, TType.STRING, 'userFriendlyDescription', None, None, ), # 6 - (7, TType.STRING, 'metaData', None, None, ), # 7 - (8, TType.I32, 'inputOrder', None, None, ), # 8 - (9, TType.BOOL, 'isRequired', None, None, ), # 9 - (10, TType.BOOL, 'requiredToAddedToCommandLine', None, None, ), # 10 - (11, TType.BOOL, 'dataStaged', None, None, ), # 11 - (12, TType.STRING, 'storageResourceId', None, None, ), # 12 - (13, TType.BOOL, 'isReadOnly', None, None, ), # 13 - ) - - def __init__(self, name=None, value=None, type=None, applicationArgument=None, standardInput=None, userFriendlyDescription=None, metaData=None, inputOrder=None, isRequired=None, requiredToAddedToCommandLine=None, dataStaged=None, storageResourceId=None, isReadOnly=None,): - self.name = name - self.value = value - self.type = type - self.applicationArgument = applicationArgument - self.standardInput = standardInput - self.userFriendlyDescription = userFriendlyDescription - self.metaData = metaData - self.inputOrder = inputOrder - self.isRequired = isRequired - self.requiredToAddedToCommandLine = requiredToAddedToCommandLine - self.dataStaged = dataStaged - self.storageResourceId = storageResourceId - self.isReadOnly = isReadOnly - - 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.STRING: - self.name = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.value = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.I32: - self.type = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.applicationArgument = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.BOOL: - self.standardInput = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.STRING: - self.userFriendlyDescription = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.STRING: - self.metaData = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.I32: - self.inputOrder = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.BOOL: - self.isRequired = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.BOOL: - self.requiredToAddedToCommandLine = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 11: - if ftype == TType.BOOL: - self.dataStaged = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 12: - if ftype == TType.STRING: - self.storageResourceId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 13: - if ftype == TType.BOOL: - self.isReadOnly = iprot.readBool() - 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('InputDataObjectType') - if self.name is not None: - oprot.writeFieldBegin('name', TType.STRING, 1) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.value is not None: - oprot.writeFieldBegin('value', TType.STRING, 2) - oprot.writeString(self.value) - oprot.writeFieldEnd() - if self.type is not None: - oprot.writeFieldBegin('type', TType.I32, 3) - oprot.writeI32(self.type) - oprot.writeFieldEnd() - if self.applicationArgument is not None: - oprot.writeFieldBegin('applicationArgument', TType.STRING, 4) - oprot.writeString(self.applicationArgument) - oprot.writeFieldEnd() - if self.standardInput is not None: - oprot.writeFieldBegin('standardInput', TType.BOOL, 5) - oprot.writeBool(self.standardInput) - oprot.writeFieldEnd() - if self.userFriendlyDescription is not None: - oprot.writeFieldBegin('userFriendlyDescription', TType.STRING, 6) - oprot.writeString(self.userFriendlyDescription) - oprot.writeFieldEnd() - if self.metaData is not None: - oprot.writeFieldBegin('metaData', TType.STRING, 7) - oprot.writeString(self.metaData) - oprot.writeFieldEnd() - if self.inputOrder is not None: - oprot.writeFieldBegin('inputOrder', TType.I32, 8) - oprot.writeI32(self.inputOrder) - oprot.writeFieldEnd() - if self.isRequired is not None: - oprot.writeFieldBegin('isRequired', TType.BOOL, 9) - oprot.writeBool(self.isRequired) - oprot.writeFieldEnd() - if self.requiredToAddedToCommandLine is not None: - oprot.writeFieldBegin('requiredToAddedToCommandLine', TType.BOOL, 10) - oprot.writeBool(self.requiredToAddedToCommandLine) - oprot.writeFieldEnd() - if self.dataStaged is not None: - oprot.writeFieldBegin('dataStaged', TType.BOOL, 11) - oprot.writeBool(self.dataStaged) - oprot.writeFieldEnd() - if self.storageResourceId is not None: - oprot.writeFieldBegin('storageResourceId', TType.STRING, 12) - oprot.writeString(self.storageResourceId) - oprot.writeFieldEnd() - if self.isReadOnly is not None: - oprot.writeFieldBegin('isReadOnly', TType.BOOL, 13) - oprot.writeBool(self.isReadOnly) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - if self.name is None: - raise TProtocol.TProtocolException(message='Required field name is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.name) - value = (value * 31) ^ hash(self.value) - value = (value * 31) ^ hash(self.type) - value = (value * 31) ^ hash(self.applicationArgument) - value = (value * 31) ^ hash(self.standardInput) - value = (value * 31) ^ hash(self.userFriendlyDescription) - value = (value * 31) ^ hash(self.metaData) - value = (value * 31) ^ hash(self.inputOrder) - value = (value * 31) ^ hash(self.isRequired) - value = (value * 31) ^ hash(self.requiredToAddedToCommandLine) - value = (value * 31) ^ hash(self.dataStaged) - value = (value * 31) ^ hash(self.storageResourceId) - value = (value * 31) ^ hash(self.isReadOnly) - 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 OutputDataObjectType: - """ - Application Outputs. The paramters describe how outputs generated by the application. - - name: - Name of the parameter. - - value: - Value of the parameter. - - type: - Data type of the parameter - - applicationArguement: - The argument flag sent to the application. Such as -p pressure. - - standardInput: - When this value is set, the parameter is sent as standard input rather than a parameter. - Typically this is passed using redirection operator ">". - - userFriendlyDescription: - Description to be displayed at the user interface. - - metaData: - Any metadat. This is typically ignore by Airavata and is used by gateways for application configuration. - - - Attributes: - - name - - value - - type - - applicationArgument - - isRequired - - requiredToAddedToCommandLine - - dataMovement - - location - - searchQuery - - outputStreaming - - storageResourceId - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'name', None, None, ), # 1 - (2, TType.STRING, 'value', None, None, ), # 2 - (3, TType.I32, 'type', None, None, ), # 3 - (4, TType.STRING, 'applicationArgument', None, None, ), # 4 - (5, TType.BOOL, 'isRequired', None, None, ), # 5 - (6, TType.BOOL, 'requiredToAddedToCommandLine', None, None, ), # 6 - (7, TType.BOOL, 'dataMovement', None, None, ), # 7 - (8, TType.STRING, 'location', None, None, ), # 8 - (9, TType.STRING, 'searchQuery', None, None, ), # 9 - (10, TType.BOOL, 'outputStreaming', None, None, ), # 10 - (11, TType.STRING, 'storageResourceId', None, None, ), # 11 - ) - - def __init__(self, name=None, value=None, type=None, applicationArgument=None, isRequired=None, requiredToAddedToCommandLine=None, dataMovement=None, location=None, searchQuery=None, outputStreaming=None, storageResourceId=None,): - self.name = name - self.value = value - self.type = type - self.applicationArgument = applicationArgument - self.isRequired = isRequired - self.requiredToAddedToCommandLine = requiredToAddedToCommandLine - self.dataMovement = dataMovement - self.location = location - self.searchQuery = searchQuery - self.outputStreaming = outputStreaming - self.storageResourceId = storageResourceId - - 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.STRING: - self.name = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.value = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.I32: - self.type = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.applicationArgument = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.BOOL: - self.isRequired = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.BOOL: - self.requiredToAddedToCommandLine = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.BOOL: - self.dataMovement = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.STRING: - self.location = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.STRING: - self.searchQuery = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.BOOL: - self.outputStreaming = iprot.readBool() - else: - iprot.skip(ftype) - elif fid == 11: - if ftype == TType.STRING: - self.storageResourceId = 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('OutputDataObjectType') - if self.name is not None: - oprot.writeFieldBegin('name', TType.STRING, 1) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.value is not None: - oprot.writeFieldBegin('value', TType.STRING, 2) - oprot.writeString(self.value) - oprot.writeFieldEnd() - if self.type is not None: - oprot.writeFieldBegin('type', TType.I32, 3) - oprot.writeI32(self.type) - oprot.writeFieldEnd() - if self.applicationArgument is not None: - oprot.writeFieldBegin('applicationArgument', TType.STRING, 4) - oprot.writeString(self.applicationArgument) - oprot.writeFieldEnd() - if self.isRequired is not None: - oprot.writeFieldBegin('isRequired', TType.BOOL, 5) - oprot.writeBool(self.isRequired) - oprot.writeFieldEnd() - if self.requiredToAddedToCommandLine is not None: - oprot.writeFieldBegin('requiredToAddedToCommandLine', TType.BOOL, 6) - oprot.writeBool(self.requiredToAddedToCommandLine) - oprot.writeFieldEnd() - if self.dataMovement is not None: - oprot.writeFieldBegin('dataMovement', TType.BOOL, 7) - oprot.writeBool(self.dataMovement) - oprot.writeFieldEnd() - if self.location is not None: - oprot.writeFieldBegin('location', TType.STRING, 8) - oprot.writeString(self.location) - oprot.writeFieldEnd() - if self.searchQuery is not None: - oprot.writeFieldBegin('searchQuery', TType.STRING, 9) - oprot.writeString(self.searchQuery) - oprot.writeFieldEnd() - if self.outputStreaming is not None: - oprot.writeFieldBegin('outputStreaming', TType.BOOL, 10) - oprot.writeBool(self.outputStreaming) - oprot.writeFieldEnd() - if self.storageResourceId is not None: - oprot.writeFieldBegin('storageResourceId', TType.STRING, 11) - oprot.writeString(self.storageResourceId) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - if self.name is None: - raise TProtocol.TProtocolException(message='Required field name is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.name) - value = (value * 31) ^ hash(self.value) - value = (value * 31) ^ hash(self.type) - value = (value * 31) ^ hash(self.applicationArgument) - value = (value * 31) ^ hash(self.isRequired) - value = (value * 31) ^ hash(self.requiredToAddedToCommandLine) - value = (value * 31) ^ hash(self.dataMovement) - value = (value * 31) ^ hash(self.location) - value = (value * 31) ^ hash(self.searchQuery) - value = (value * 31) ^ hash(self.outputStreaming) - value = (value * 31) ^ hash(self.storageResourceId) - 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 DataType(object): + """ + Data Types supported in Airavata. The primitive data types + + """ + STRING = 0 + INTEGER = 1 + FLOAT = 2 + URI = 3 + URI_COLLECTION = 4 + STDOUT = 5 + STDERR = 6 + + _VALUES_TO_NAMES = { + 0: "STRING", + 1: "INTEGER", + 2: "FLOAT", + 3: "URI", + 4: "URI_COLLECTION", + 5: "STDOUT", + 6: "STDERR", + } + + _NAMES_TO_VALUES = { + "STRING": 0, + "INTEGER": 1, + "FLOAT": 2, + "URI": 3, + "URI_COLLECTION": 4, + "STDOUT": 5, + "STDERR": 6, + } + + +class InputDataObjectType(object): + """ + Application Inputs. The paramters describe how inputs are passed to the application. + + name: + Name of the parameter. + + value: + Value of the parameter. A default value could be set during registration. + + type: + Data type of the parameter + + applicationArguement: + The argument flag sent to the application. Such as -p pressure. + + standardInput: + When this value is set, the parameter is sent as standard input rather than a parameter. + Typically this is passed using redirection operator ">". + + userFriendlyDescription: + Description to be displayed at the user interface. + + metaData: + Any metadat. This is typically ignore by Airavata and is used by gateways for application configuration. + + + Attributes: + - name + - value + - type + - applicationArgument + - standardInput + - userFriendlyDescription + - metaData + - inputOrder + - isRequired + - requiredToAddedToCommandLine + - dataStaged + - storageResourceId + - isReadOnly + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', 'UTF8', None, ), # 1 + (2, TType.STRING, 'value', 'UTF8', None, ), # 2 + (3, TType.I32, 'type', None, None, ), # 3 + (4, TType.STRING, 'applicationArgument', 'UTF8', None, ), # 4 + (5, TType.BOOL, 'standardInput', None, None, ), # 5 + (6, TType.STRING, 'userFriendlyDescription', 'UTF8', None, ), # 6 + (7, TType.STRING, 'metaData', 'UTF8', None, ), # 7 + (8, TType.I32, 'inputOrder', None, None, ), # 8 + (9, TType.BOOL, 'isRequired', None, None, ), # 9 + (10, TType.BOOL, 'requiredToAddedToCommandLine', None, None, ), # 10 + (11, TType.BOOL, 'dataStaged', None, None, ), # 11 + (12, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 12 + (13, TType.BOOL, 'isReadOnly', None, None, ), # 13 + ) + + def __init__(self, name=None, value=None, type=None, applicationArgument=None, standardInput=None, userFriendlyDescription=None, metaData=None, inputOrder=None, isRequired=None, requiredToAddedToCommandLine=None, dataStaged=None, storageResourceId=None, isReadOnly=None,): + self.name = name + self.value = value + self.type = type + self.applicationArgument = applicationArgument + self.standardInput = standardInput + self.userFriendlyDescription = userFriendlyDescription + self.metaData = metaData + self.inputOrder = inputOrder + self.isRequired = isRequired + self.requiredToAddedToCommandLine = requiredToAddedToCommandLine + self.dataStaged = dataStaged + self.storageResourceId = storageResourceId + self.isReadOnly = isReadOnly + + def read(self, iprot): + if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None: + iprot._fast_decode(self, iprot, (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.STRING: + self.name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.value = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I32: + self.type = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.applicationArgument = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.BOOL: + self.standardInput = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.userFriendlyDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.metaData = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.I32: + self.inputOrder = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.BOOL: + self.isRequired = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.BOOL: + self.requiredToAddedToCommandLine = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.BOOL: + self.dataStaged = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.STRING: + self.storageResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 13: + if ftype == TType.BOOL: + self.isReadOnly = iprot.readBool() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot._fast_encode is not None and self.thrift_spec is not None: + oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('InputDataObjectType') + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 1) + oprot.writeString(self.name.encode('utf-8') if sys.version_info[0] == 2 else self.name) + oprot.writeFieldEnd() + if self.value is not None: + oprot.writeFieldBegin('value', TType.STRING, 2) + oprot.writeString(self.value.encode('utf-8') if sys.version_info[0] == 2 else self.value) + oprot.writeFieldEnd() + if self.type is not None: + oprot.writeFieldBegin('type', TType.I32, 3) + oprot.writeI32(self.type) + oprot.writeFieldEnd() + if self.applicationArgument is not None: + oprot.writeFieldBegin('applicationArgument', TType.STRING, 4) + oprot.writeString(self.applicationArgument.encode('utf-8') if sys.version_info[0] == 2 else self.applicationArgument) + oprot.writeFieldEnd() + if self.standardInput is not None: + oprot.writeFieldBegin('standardInput', TType.BOOL, 5) + oprot.writeBool(self.standardInput) + oprot.writeFieldEnd() + if self.userFriendlyDescription is not None: + oprot.writeFieldBegin('userFriendlyDescription', TType.STRING, 6) + oprot.writeString(self.userFriendlyDescription.encode('utf-8') if sys.version_info[0] == 2 else self.userFriendlyDescription) + oprot.writeFieldEnd() + if self.metaData is not None: + oprot.writeFieldBegin('metaData', TType.STRING, 7) + oprot.writeString(self.metaData.encode('utf-8') if sys.version_info[0] == 2 else self.metaData) + oprot.writeFieldEnd() + if self.inputOrder is not None: + oprot.writeFieldBegin('inputOrder', TType.I32, 8) + oprot.writeI32(self.inputOrder) + oprot.writeFieldEnd() + if self.isRequired is not None: + oprot.writeFieldBegin('isRequired', TType.BOOL, 9) + oprot.writeBool(self.isRequired) + oprot.writeFieldEnd() + if self.requiredToAddedToCommandLine is not None: + oprot.writeFieldBegin('requiredToAddedToCommandLine', TType.BOOL, 10) + oprot.writeBool(self.requiredToAddedToCommandLine) + oprot.writeFieldEnd() + if self.dataStaged is not None: + oprot.writeFieldBegin('dataStaged', TType.BOOL, 11) + oprot.writeBool(self.dataStaged) + oprot.writeFieldEnd() + if self.storageResourceId is not None: + oprot.writeFieldBegin('storageResourceId', TType.STRING, 12) + oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId) + oprot.writeFieldEnd() + if self.isReadOnly is not None: + oprot.writeFieldBegin('isReadOnly', TType.BOOL, 13) + oprot.writeBool(self.isReadOnly) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.name is None: + raise TProtocolException(message='Required field name is unset!') + return + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.items()] + 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 OutputDataObjectType(object): + """ + Application Outputs. The paramters describe how outputs generated by the application. + + name: + Name of the parameter. + + value: + Value of the parameter. + + type: + Data type of the parameter + + applicationArguement: + The argument flag sent to the application. Such as -p pressure. + + standardInput: + When this value is set, the parameter is sent as standard input rather than a parameter. + Typically this is passed using redirection operator ">". + + userFriendlyDescription: + Description to be displayed at the user interface. + + metaData: + Any metadat. This is typically ignore by Airavata and is used by gateways for application configuration. + + + Attributes: + - name + - value + - type + - applicationArgument + - isRequired + - requiredToAddedToCommandLine + - dataMovement + - location + - searchQuery + - outputStreaming + - storageResourceId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', 'UTF8', None, ), # 1 + (2, TType.STRING, 'value', 'UTF8', None, ), # 2 + (3, TType.I32, 'type', None, None, ), # 3 + (4, TType.STRING, 'applicationArgument', 'UTF8', None, ), # 4 + (5, TType.BOOL, 'isRequired', None, None, ), # 5 + (6, TType.BOOL, 'requiredToAddedToCommandLine', None, None, ), # 6 + (7, TType.BOOL, 'dataMovement', None, None, ), # 7 + (8, TType.STRING, 'location', 'UTF8', None, ), # 8 + (9, TType.STRING, 'searchQuery', 'UTF8', None, ), # 9 + (10, TType.BOOL, 'outputStreaming', None, None, ), # 10 + (11, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 11 + ) + + def __init__(self, name=None, value=None, type=None, applicationArgument=None, isRequired=None, requiredToAddedToCommandLine=None, dataMovement=None, location=None, searchQuery=None, outputStreaming=None, storageResourceId=None,): + self.name = name + self.value = value + self.type = type + self.applicationArgument = applicationArgument + self.isRequired = isRequired + self.requiredToAddedToCommandLine = requiredToAddedToCommandLine + self.dataMovement = dataMovement + self.location = location + self.searchQuery = searchQuery + self.outputStreaming = outputStreaming + self.storageResourceId = storageResourceId + + def read(self, iprot): + if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None: + iprot._fast_decode(self, iprot, (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.STRING: + self.name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.value = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I32: + self.type = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.applicationArgument = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.BOOL: + self.isRequired = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.BOOL: + self.requiredToAddedToCommandLine = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.BOOL: + self.dataMovement = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.STRING: + self.location = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.STRING: + self.searchQuery = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.BOOL: + self.outputStreaming = iprot.readBool() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.STRING: + self.storageResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot._fast_encode is not None and self.thrift_spec is not None: + oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('OutputDataObjectType') + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 1) + oprot.writeString(self.name.encode('utf-8') if sys.version_info[0] == 2 else self.name) + oprot.writeFieldEnd() + if self.value is not None: + oprot.writeFieldBegin('value', TType.STRING, 2) + oprot.writeString(self.value.encode('utf-8') if sys.version_info[0] == 2 else self.value) + oprot.writeFieldEnd() + if self.type is not None: + oprot.writeFieldBegin('type', TType.I32, 3) + oprot.writeI32(self.type) + oprot.writeFieldEnd() + if self.applicationArgument is not None: + oprot.writeFieldBegin('applicationArgument', TType.STRING, 4) + oprot.writeString(self.applicationArgument.encode('utf-8') if sys.version_info[0] == 2 else self.applicationArgument) + oprot.writeFieldEnd() + if self.isRequired is not None: + oprot.writeFieldBegin('isRequired', TType.BOOL, 5) + oprot.writeBool(self.isRequired) + oprot.writeFieldEnd() + if self.requiredToAddedToCommandLine is not None: + oprot.writeFieldBegin('requiredToAddedToCommandLine', TType.BOOL, 6) + oprot.writeBool(self.requiredToAddedToCommandLine) + oprot.writeFieldEnd() + if self.dataMovement is not None: + oprot.writeFieldBegin('dataMovement', TType.BOOL, 7) + oprot.writeBool(self.dataMovement) + oprot.writeFieldEnd() + if self.location is not None: + oprot.writeFieldBegin('location', TType.STRING, 8) + oprot.writeString(self.location.encode('utf-8') if sys.version_info[0] == 2 else self.location) + oprot.writeFieldEnd() + if self.searchQuery is not None: + oprot.writeFieldBegin('searchQuery', TType.STRING, 9) + oprot.writeString(self.searchQuery.encode('utf-8') if sys.version_info[0] == 2 else self.searchQuery) + oprot.writeFieldEnd() + if self.outputStreaming is not None: + oprot.writeFieldBegin('outputStreaming', TType.BOOL, 10) + oprot.writeBool(self.outputStreaming) + oprot.writeFieldEnd() + if self.storageResourceId is not None: + oprot.writeFieldBegin('storageResourceId', TType.STRING, 11) + oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.name is None: + raise TProtocolException(message='Required field name is unset!') + return + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.items()] + 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) http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/commons/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/commons/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/commons/constants.py index abf8bc6..2b09fa9 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/commons/constants.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/commons/constants.py @@ -1,12 +1,13 @@ # -# Autogenerated by Thrift Compiler (0.9.3) +# Autogenerated by Thrift Compiler (0.10.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # # options string: py # -from thrift.Thrift import TType, TMessageType, TException, TApplicationException -from ttypes import * - +from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException +from thrift.protocol.TProtocol import TProtocolException +import sys +from .ttypes import * DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS"