Return-Path: X-Original-To: apmail-airavata-commits-archive@www.apache.org Delivered-To: apmail-airavata-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 84E1218728 for ; Wed, 23 Dec 2015 06:53:24 +0000 (UTC) Received: (qmail 82105 invoked by uid 500); 23 Dec 2015 06:53:08 -0000 Delivered-To: apmail-airavata-commits-archive@airavata.apache.org Received: (qmail 81942 invoked by uid 500); 23 Dec 2015 06:53:08 -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 80712 invoked by uid 99); 23 Dec 2015 06:53:07 -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; Wed, 23 Dec 2015 06:53:07 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 9E175E0948; Wed, 23 Dec 2015 06:53:07 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: scnakandala@apache.org To: commits@airavata.apache.org Date: Wed, 23 Dec 2015 06:53:31 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [26/51] [abbrv] airavata git commit: restructureing the file manager module http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py index 6a896e3..d0bd8b7 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/api/ttypes.py @@ -23,7 +23,6 @@ import apache.airavata.model.appcatalog.storageresource.ttypes import apache.airavata.model.appcatalog.gatewayprofile.ttypes import apache.airavata.model.data.movement.ttypes import apache.airavata.model.workflow.ttypes -import apache.airavata.model.data.resource.ttypes from thrift.transport import TTransport http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py deleted file mode 100644 index adefd8e..0000000 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/__init__.py +++ /dev/null @@ -1 +0,0 @@ -__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py deleted file mode 100644 index 4a6492b..0000000 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/constants.py +++ /dev/null @@ -1,11 +0,0 @@ -# -# Autogenerated by Thrift Compiler (0.9.3) -# -# 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 * - http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py deleted file mode 100644 index 58b9cff..0000000 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/data/resource/ttypes.py +++ /dev/null @@ -1,574 +0,0 @@ -# -# Autogenerated by Thrift Compiler (0.9.3) -# -# 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 -import apache.airavata.model.data.movement.ttypes - - -from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None - - -class ReplicaLocationCategory: - GATEWAY_DATA_STORE = 0 - COMPUTE_RESOURCE = 1 - LONG_TERM_STORAGE_RESOURCE = 2 - OTHER = 3 - - _VALUES_TO_NAMES = { - 0: "GATEWAY_DATA_STORE", - 1: "COMPUTE_RESOURCE", - 2: "LONG_TERM_STORAGE_RESOURCE", - 3: "OTHER", - } - - _NAMES_TO_VALUES = { - "GATEWAY_DATA_STORE": 0, - "COMPUTE_RESOURCE": 1, - "LONG_TERM_STORAGE_RESOURCE": 2, - "OTHER": 3, - } - -class ReplicaPersistentType: - TRANSIENT = 0 - PERSISTENT = 1 - - _VALUES_TO_NAMES = { - 0: "TRANSIENT", - 1: "PERSISTENT", - } - - _NAMES_TO_VALUES = { - "TRANSIENT": 0, - "PERSISTENT": 1, - } - -class DataResourceType: - COLLECTION = 0 - FILE = 1 - - _VALUES_TO_NAMES = { - 0: "COLLECTION", - 1: "FILE", - } - - _NAMES_TO_VALUES = { - "COLLECTION": 0, - "FILE": 1, - } - - -class DataResourceModel: - """ - Attributes: - - resourceId - - gatewayId - - parentResourceId - - resourceName - - resourceDescription - - ownerName - - sha256Checksum - - dataResourceType - - resourceSize - - nativeFormat - - creationTime - - lastModifiedTime - - resourceMetadata - - replicaLocations - - childResources - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'resourceId', None, None, ), # 1 - (2, TType.STRING, 'gatewayId', None, None, ), # 2 - (3, TType.STRING, 'parentResourceId', None, None, ), # 3 - (4, TType.STRING, 'resourceName', None, None, ), # 4 - (5, TType.STRING, 'resourceDescription', None, None, ), # 5 - (6, TType.STRING, 'ownerName', None, None, ), # 6 - (7, TType.STRING, 'sha256Checksum', None, None, ), # 7 - (8, TType.I32, 'dataResourceType', None, None, ), # 8 - (9, TType.I32, 'resourceSize', None, None, ), # 9 - (10, TType.STRING, 'nativeFormat', None, None, ), # 10 - (11, TType.I64, 'creationTime', None, None, ), # 11 - (12, TType.I64, 'lastModifiedTime', None, None, ), # 12 - (13, TType.MAP, 'resourceMetadata', (TType.STRING,None,TType.STRING,None), None, ), # 13 - (14, TType.LIST, 'replicaLocations', (TType.STRUCT,(DataReplicaLocationModel, DataReplicaLocationModel.thrift_spec)), None, ), # 14 - (15, TType.LIST, 'childResources', (TType.STRUCT,(DataResourceModel, DataResourceModel.thrift_spec)), None, ), # 15 - ) - - def __init__(self, resourceId=None, gatewayId=None, parentResourceId=None, resourceName=None, resourceDescription=None, ownerName=None, sha256Checksum=None, dataResourceType=None, resourceSize=None, nativeFormat=None, creationTime=None, lastModifiedTime=None, resourceMetadata=None, replicaLocations=None, childResources=None,): - self.resourceId = resourceId - self.gatewayId = gatewayId - self.parentResourceId = parentResourceId - self.resourceName = resourceName - self.resourceDescription = resourceDescription - self.ownerName = ownerName - self.sha256Checksum = sha256Checksum - self.dataResourceType = dataResourceType - self.resourceSize = resourceSize - self.nativeFormat = nativeFormat - self.creationTime = creationTime - self.lastModifiedTime = lastModifiedTime - self.resourceMetadata = resourceMetadata - self.replicaLocations = replicaLocations - self.childResources = childResources - - 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.resourceId = 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.parentResourceId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.resourceName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRING: - self.resourceDescription = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.STRING: - self.ownerName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.STRING: - self.sha256Checksum = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.I32: - self.dataResourceType = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.I32: - self.resourceSize = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.STRING: - self.nativeFormat = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 11: - if ftype == TType.I64: - self.creationTime = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 12: - if ftype == TType.I64: - self.lastModifiedTime = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 13: - if ftype == TType.MAP: - self.resourceMetadata = {} - (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin() - for _i4 in xrange(_size0): - _key5 = iprot.readString() - _val6 = iprot.readString() - self.resourceMetadata[_key5] = _val6 - iprot.readMapEnd() - else: - iprot.skip(ftype) - elif fid == 14: - if ftype == TType.LIST: - self.replicaLocations = [] - (_etype10, _size7) = iprot.readListBegin() - for _i11 in xrange(_size7): - _elem12 = DataReplicaLocationModel() - _elem12.read(iprot) - self.replicaLocations.append(_elem12) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 15: - if ftype == TType.LIST: - self.childResources = [] - (_etype16, _size13) = iprot.readListBegin() - for _i17 in xrange(_size13): - _elem18 = DataResourceModel() - _elem18.read(iprot) - self.childResources.append(_elem18) - iprot.readListEnd() - 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('DataResourceModel') - if self.resourceId is not None: - oprot.writeFieldBegin('resourceId', TType.STRING, 1) - oprot.writeString(self.resourceId) - oprot.writeFieldEnd() - if self.gatewayId is not None: - oprot.writeFieldBegin('gatewayId', TType.STRING, 2) - oprot.writeString(self.gatewayId) - oprot.writeFieldEnd() - if self.parentResourceId is not None: - oprot.writeFieldBegin('parentResourceId', TType.STRING, 3) - oprot.writeString(self.parentResourceId) - oprot.writeFieldEnd() - if self.resourceName is not None: - oprot.writeFieldBegin('resourceName', TType.STRING, 4) - oprot.writeString(self.resourceName) - oprot.writeFieldEnd() - if self.resourceDescription is not None: - oprot.writeFieldBegin('resourceDescription', TType.STRING, 5) - oprot.writeString(self.resourceDescription) - oprot.writeFieldEnd() - if self.ownerName is not None: - oprot.writeFieldBegin('ownerName', TType.STRING, 6) - oprot.writeString(self.ownerName) - oprot.writeFieldEnd() - if self.sha256Checksum is not None: - oprot.writeFieldBegin('sha256Checksum', TType.STRING, 7) - oprot.writeString(self.sha256Checksum) - oprot.writeFieldEnd() - if self.dataResourceType is not None: - oprot.writeFieldBegin('dataResourceType', TType.I32, 8) - oprot.writeI32(self.dataResourceType) - oprot.writeFieldEnd() - if self.resourceSize is not None: - oprot.writeFieldBegin('resourceSize', TType.I32, 9) - oprot.writeI32(self.resourceSize) - oprot.writeFieldEnd() - if self.nativeFormat is not None: - oprot.writeFieldBegin('nativeFormat', TType.STRING, 10) - oprot.writeString(self.nativeFormat) - oprot.writeFieldEnd() - if self.creationTime is not None: - oprot.writeFieldBegin('creationTime', TType.I64, 11) - oprot.writeI64(self.creationTime) - oprot.writeFieldEnd() - if self.lastModifiedTime is not None: - oprot.writeFieldBegin('lastModifiedTime', TType.I64, 12) - oprot.writeI64(self.lastModifiedTime) - oprot.writeFieldEnd() - if self.resourceMetadata is not None: - oprot.writeFieldBegin('resourceMetadata', TType.MAP, 13) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.resourceMetadata)) - for kiter19,viter20 in self.resourceMetadata.items(): - oprot.writeString(kiter19) - oprot.writeString(viter20) - oprot.writeMapEnd() - oprot.writeFieldEnd() - if self.replicaLocations is not None: - oprot.writeFieldBegin('replicaLocations', TType.LIST, 14) - oprot.writeListBegin(TType.STRUCT, len(self.replicaLocations)) - for iter21 in self.replicaLocations: - iter21.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.childResources is not None: - oprot.writeFieldBegin('childResources', TType.LIST, 15) - oprot.writeListBegin(TType.STRUCT, len(self.childResources)) - for iter22 in self.childResources: - iter22.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.resourceId) - value = (value * 31) ^ hash(self.gatewayId) - value = (value * 31) ^ hash(self.parentResourceId) - value = (value * 31) ^ hash(self.resourceName) - value = (value * 31) ^ hash(self.resourceDescription) - value = (value * 31) ^ hash(self.ownerName) - value = (value * 31) ^ hash(self.sha256Checksum) - value = (value * 31) ^ hash(self.dataResourceType) - value = (value * 31) ^ hash(self.resourceSize) - value = (value * 31) ^ hash(self.nativeFormat) - value = (value * 31) ^ hash(self.creationTime) - value = (value * 31) ^ hash(self.lastModifiedTime) - value = (value * 31) ^ hash(self.resourceMetadata) - value = (value * 31) ^ hash(self.replicaLocations) - value = (value * 31) ^ hash(self.childResources) - 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 DataReplicaLocationModel: - """ - Attributes: - - replicaId - - resourceId - - replicaName - - replicaDescription - - sourceReplicaId - - creationTime - - lastModifiedTime - - validUntilTime - - replicaLocationCategory - - replicaPersistentType - - storageResourceId - - fileAbsolutePath - - replicaMetadata - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'replicaId', None, None, ), # 1 - (2, TType.STRING, 'resourceId', None, None, ), # 2 - (3, TType.STRING, 'replicaName', None, None, ), # 3 - (4, TType.STRING, 'replicaDescription', None, None, ), # 4 - (5, TType.STRING, 'sourceReplicaId', None, None, ), # 5 - (6, TType.I64, 'creationTime', None, None, ), # 6 - (7, TType.I64, 'lastModifiedTime', None, None, ), # 7 - (8, TType.I64, 'validUntilTime', None, None, ), # 8 - (9, TType.I32, 'replicaLocationCategory', None, None, ), # 9 - (10, TType.I32, 'replicaPersistentType', None, None, ), # 10 - (11, TType.STRING, 'storageResourceId', None, None, ), # 11 - (12, TType.STRING, 'fileAbsolutePath', None, None, ), # 12 - (13, TType.MAP, 'replicaMetadata', (TType.STRING,None,TType.STRING,None), None, ), # 13 - ) - - def __init__(self, replicaId=None, resourceId=None, replicaName=None, replicaDescription=None, sourceReplicaId=None, creationTime=None, lastModifiedTime=None, validUntilTime=None, replicaLocationCategory=None, replicaPersistentType=None, storageResourceId=None, fileAbsolutePath=None, replicaMetadata=None,): - self.replicaId = replicaId - self.resourceId = resourceId - self.replicaName = replicaName - self.replicaDescription = replicaDescription - self.sourceReplicaId = sourceReplicaId - self.creationTime = creationTime - self.lastModifiedTime = lastModifiedTime - self.validUntilTime = validUntilTime - self.replicaLocationCategory = replicaLocationCategory - self.replicaPersistentType = replicaPersistentType - self.storageResourceId = storageResourceId - self.fileAbsolutePath = fileAbsolutePath - self.replicaMetadata = replicaMetadata - - 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.replicaId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.resourceId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.replicaName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.replicaDescription = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.STRING: - self.sourceReplicaId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.I64: - self.creationTime = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.I64: - self.lastModifiedTime = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.I64: - self.validUntilTime = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.I32: - self.replicaLocationCategory = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.I32: - self.replicaPersistentType = iprot.readI32() - else: - iprot.skip(ftype) - elif fid == 11: - if ftype == TType.STRING: - self.storageResourceId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 12: - if ftype == TType.STRING: - self.fileAbsolutePath = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 13: - if ftype == TType.MAP: - self.replicaMetadata = {} - (_ktype24, _vtype25, _size23 ) = iprot.readMapBegin() - for _i27 in xrange(_size23): - _key28 = iprot.readString() - _val29 = iprot.readString() - self.replicaMetadata[_key28] = _val29 - iprot.readMapEnd() - 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('DataReplicaLocationModel') - if self.replicaId is not None: - oprot.writeFieldBegin('replicaId', TType.STRING, 1) - oprot.writeString(self.replicaId) - oprot.writeFieldEnd() - if self.resourceId is not None: - oprot.writeFieldBegin('resourceId', TType.STRING, 2) - oprot.writeString(self.resourceId) - oprot.writeFieldEnd() - if self.replicaName is not None: - oprot.writeFieldBegin('replicaName', TType.STRING, 3) - oprot.writeString(self.replicaName) - oprot.writeFieldEnd() - if self.replicaDescription is not None: - oprot.writeFieldBegin('replicaDescription', TType.STRING, 4) - oprot.writeString(self.replicaDescription) - oprot.writeFieldEnd() - if self.sourceReplicaId is not None: - oprot.writeFieldBegin('sourceReplicaId', TType.STRING, 5) - oprot.writeString(self.sourceReplicaId) - oprot.writeFieldEnd() - if self.creationTime is not None: - oprot.writeFieldBegin('creationTime', TType.I64, 6) - oprot.writeI64(self.creationTime) - oprot.writeFieldEnd() - if self.lastModifiedTime is not None: - oprot.writeFieldBegin('lastModifiedTime', TType.I64, 7) - oprot.writeI64(self.lastModifiedTime) - oprot.writeFieldEnd() - if self.validUntilTime is not None: - oprot.writeFieldBegin('validUntilTime', TType.I64, 8) - oprot.writeI64(self.validUntilTime) - oprot.writeFieldEnd() - if self.replicaLocationCategory is not None: - oprot.writeFieldBegin('replicaLocationCategory', TType.I32, 9) - oprot.writeI32(self.replicaLocationCategory) - oprot.writeFieldEnd() - if self.replicaPersistentType is not None: - oprot.writeFieldBegin('replicaPersistentType', TType.I32, 10) - oprot.writeI32(self.replicaPersistentType) - oprot.writeFieldEnd() - if self.storageResourceId is not None: - oprot.writeFieldBegin('storageResourceId', TType.STRING, 11) - oprot.writeString(self.storageResourceId) - oprot.writeFieldEnd() - if self.fileAbsolutePath is not None: - oprot.writeFieldBegin('fileAbsolutePath', TType.STRING, 12) - oprot.writeString(self.fileAbsolutePath) - oprot.writeFieldEnd() - if self.replicaMetadata is not None: - oprot.writeFieldBegin('replicaMetadata', TType.MAP, 13) - oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.replicaMetadata)) - for kiter30,viter31 in self.replicaMetadata.items(): - oprot.writeString(kiter30) - oprot.writeString(viter31) - oprot.writeMapEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.replicaId) - value = (value * 31) ^ hash(self.resourceId) - value = (value * 31) ^ hash(self.replicaName) - value = (value * 31) ^ hash(self.replicaDescription) - value = (value * 31) ^ hash(self.sourceReplicaId) - value = (value * 31) ^ hash(self.creationTime) - value = (value * 31) ^ hash(self.lastModifiedTime) - value = (value * 31) ^ hash(self.validUntilTime) - value = (value * 31) ^ hash(self.replicaLocationCategory) - value = (value * 31) ^ hash(self.replicaPersistentType) - value = (value * 31) ^ hash(self.storageResourceId) - value = (value * 31) ^ hash(self.fileAbsolutePath) - value = (value * 31) ^ hash(self.replicaMetadata) - 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) http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/constants.py new file mode 100644 index 0000000..4a6492b --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/constants.py @@ -0,0 +1,11 @@ +# +# Autogenerated by Thrift Compiler (0.9.3) +# +# 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 * + http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/ttypes.py new file mode 100644 index 0000000..dc6b187 --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/file/ttypes.py @@ -0,0 +1,550 @@ +# +# Autogenerated by Thrift Compiler (0.9.3) +# +# 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.transport import TTransport +from thrift.protocol import TBinaryProtocol, TProtocol +try: + from thrift.protocol import fastbinary +except: + fastbinary = None + + +class StorageResourceProtocol: + SCP = 0 + SFTP = 1 + HTTP = 2 + HTTPS = 3 + GridFTP = 4 + LOCAL = 5 + + _VALUES_TO_NAMES = { + 0: "SCP", + 1: "SFTP", + 2: "HTTP", + 3: "HTTPS", + 4: "GridFTP", + 5: "LOCAL", + } + + _NAMES_TO_VALUES = { + "SCP": 0, + "SFTP": 1, + "HTTP": 2, + "HTTPS": 3, + "GridFTP": 4, + "LOCAL": 5, + } + +class FileNodeTypes: + DIRECTORY = 0 + FILE = 1 + + _VALUES_TO_NAMES = { + 0: "DIRECTORY", + 1: "FILE", + } + + _NAMES_TO_VALUES = { + "DIRECTORY": 0, + "FILE": 1, + } + +class FileTransferMode: + SYNC = 0 + ASYNC = 1 + + _VALUES_TO_NAMES = { + 0: "SYNC", + 1: "ASYNC", + } + + _NAMES_TO_VALUES = { + "SYNC": 0, + "ASYNC": 1, + } + +class FileTransferStatus: + CREATED = 0 + QUEUED = 1 + RUNNING = 2 + COMPLETED = 3 + FAILED = 4 + + _VALUES_TO_NAMES = { + 0: "CREATED", + 1: "QUEUED", + 2: "RUNNING", + 3: "COMPLETED", + 4: "FAILED", + } + + _NAMES_TO_VALUES = { + "CREATED": 0, + "QUEUED": 1, + "RUNNING": 2, + "COMPLETED": 3, + "FAILED": 4, + } + + +class FileTransferRequest: + """ + Attributes: + - transferId + - srcHostname + - srcLoginName + - srcPort + - srcProtocol + - srcFilePath + - srcHostCredToken + - destHostname + - destLoginName + - destPort + - destProtocol + - destFilePath + - destHostCredToken + - fileTransferMode + - transferStatus + - fileSize + - transferTime + - createdTime + - lastModifiedType + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'transferId', None, None, ), # 1 + (2, TType.STRING, 'srcHostname', None, None, ), # 2 + (3, TType.STRING, 'srcLoginName', None, None, ), # 3 + (4, TType.I64, 'srcPort', None, None, ), # 4 + (5, TType.I32, 'srcProtocol', None, None, ), # 5 + (6, TType.STRING, 'srcFilePath', None, None, ), # 6 + (7, TType.STRING, 'srcHostCredToken', None, None, ), # 7 + (8, TType.STRING, 'destHostname', None, None, ), # 8 + (9, TType.STRING, 'destLoginName', None, None, ), # 9 + (10, TType.I64, 'destPort', None, None, ), # 10 + (11, TType.I32, 'destProtocol', None, None, ), # 11 + (12, TType.STRING, 'destFilePath', None, None, ), # 12 + (13, TType.STRING, 'destHostCredToken', None, None, ), # 13 + (14, TType.I32, 'fileTransferMode', None, None, ), # 14 + (15, TType.I32, 'transferStatus', None, None, ), # 15 + (16, TType.I64, 'fileSize', None, None, ), # 16 + (17, TType.I64, 'transferTime', None, None, ), # 17 + (18, TType.I64, 'createdTime', None, None, ), # 18 + (19, TType.I64, 'lastModifiedType', None, None, ), # 19 + ) + + def __init__(self, transferId=None, srcHostname=None, srcLoginName=None, srcPort=None, srcProtocol=None, srcFilePath=None, srcHostCredToken=None, destHostname=None, destLoginName=None, destPort=None, destProtocol=None, destFilePath=None, destHostCredToken=None, fileTransferMode=None, transferStatus=None, fileSize=None, transferTime=None, createdTime=None, lastModifiedType=None,): + self.transferId = transferId + self.srcHostname = srcHostname + self.srcLoginName = srcLoginName + self.srcPort = srcPort + self.srcProtocol = srcProtocol + self.srcFilePath = srcFilePath + self.srcHostCredToken = srcHostCredToken + self.destHostname = destHostname + self.destLoginName = destLoginName + self.destPort = destPort + self.destProtocol = destProtocol + self.destFilePath = destFilePath + self.destHostCredToken = destHostCredToken + self.fileTransferMode = fileTransferMode + self.transferStatus = transferStatus + self.fileSize = fileSize + self.transferTime = transferTime + self.createdTime = createdTime + self.lastModifiedType = lastModifiedType + + 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.transferId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.srcHostname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.srcLoginName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.I64: + self.srcPort = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.I32: + self.srcProtocol = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.srcFilePath = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.srcHostCredToken = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.STRING: + self.destHostname = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.STRING: + self.destLoginName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.I64: + self.destPort = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.I32: + self.destProtocol = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.STRING: + self.destFilePath = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 13: + if ftype == TType.STRING: + self.destHostCredToken = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 14: + if ftype == TType.I32: + self.fileTransferMode = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 15: + if ftype == TType.I32: + self.transferStatus = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 16: + if ftype == TType.I64: + self.fileSize = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 17: + if ftype == TType.I64: + self.transferTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 18: + if ftype == TType.I64: + self.createdTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 19: + if ftype == TType.I64: + self.lastModifiedType = 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('FileTransferRequest') + if self.transferId is not None: + oprot.writeFieldBegin('transferId', TType.STRING, 1) + oprot.writeString(self.transferId) + oprot.writeFieldEnd() + if self.srcHostname is not None: + oprot.writeFieldBegin('srcHostname', TType.STRING, 2) + oprot.writeString(self.srcHostname) + oprot.writeFieldEnd() + if self.srcLoginName is not None: + oprot.writeFieldBegin('srcLoginName', TType.STRING, 3) + oprot.writeString(self.srcLoginName) + oprot.writeFieldEnd() + if self.srcPort is not None: + oprot.writeFieldBegin('srcPort', TType.I64, 4) + oprot.writeI64(self.srcPort) + oprot.writeFieldEnd() + if self.srcProtocol is not None: + oprot.writeFieldBegin('srcProtocol', TType.I32, 5) + oprot.writeI32(self.srcProtocol) + oprot.writeFieldEnd() + if self.srcFilePath is not None: + oprot.writeFieldBegin('srcFilePath', TType.STRING, 6) + oprot.writeString(self.srcFilePath) + oprot.writeFieldEnd() + if self.srcHostCredToken is not None: + oprot.writeFieldBegin('srcHostCredToken', TType.STRING, 7) + oprot.writeString(self.srcHostCredToken) + oprot.writeFieldEnd() + if self.destHostname is not None: + oprot.writeFieldBegin('destHostname', TType.STRING, 8) + oprot.writeString(self.destHostname) + oprot.writeFieldEnd() + if self.destLoginName is not None: + oprot.writeFieldBegin('destLoginName', TType.STRING, 9) + oprot.writeString(self.destLoginName) + oprot.writeFieldEnd() + if self.destPort is not None: + oprot.writeFieldBegin('destPort', TType.I64, 10) + oprot.writeI64(self.destPort) + oprot.writeFieldEnd() + if self.destProtocol is not None: + oprot.writeFieldBegin('destProtocol', TType.I32, 11) + oprot.writeI32(self.destProtocol) + oprot.writeFieldEnd() + if self.destFilePath is not None: + oprot.writeFieldBegin('destFilePath', TType.STRING, 12) + oprot.writeString(self.destFilePath) + oprot.writeFieldEnd() + if self.destHostCredToken is not None: + oprot.writeFieldBegin('destHostCredToken', TType.STRING, 13) + oprot.writeString(self.destHostCredToken) + oprot.writeFieldEnd() + if self.fileTransferMode is not None: + oprot.writeFieldBegin('fileTransferMode', TType.I32, 14) + oprot.writeI32(self.fileTransferMode) + oprot.writeFieldEnd() + if self.transferStatus is not None: + oprot.writeFieldBegin('transferStatus', TType.I32, 15) + oprot.writeI32(self.transferStatus) + oprot.writeFieldEnd() + if self.fileSize is not None: + oprot.writeFieldBegin('fileSize', TType.I64, 16) + oprot.writeI64(self.fileSize) + oprot.writeFieldEnd() + if self.transferTime is not None: + oprot.writeFieldBegin('transferTime', TType.I64, 17) + oprot.writeI64(self.transferTime) + oprot.writeFieldEnd() + if self.createdTime is not None: + oprot.writeFieldBegin('createdTime', TType.I64, 18) + oprot.writeI64(self.createdTime) + oprot.writeFieldEnd() + if self.lastModifiedType is not None: + oprot.writeFieldBegin('lastModifiedType', TType.I64, 19) + oprot.writeI64(self.lastModifiedType) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.transferId) + value = (value * 31) ^ hash(self.srcHostname) + value = (value * 31) ^ hash(self.srcLoginName) + value = (value * 31) ^ hash(self.srcPort) + value = (value * 31) ^ hash(self.srcProtocol) + value = (value * 31) ^ hash(self.srcFilePath) + value = (value * 31) ^ hash(self.srcHostCredToken) + value = (value * 31) ^ hash(self.destHostname) + value = (value * 31) ^ hash(self.destLoginName) + value = (value * 31) ^ hash(self.destPort) + value = (value * 31) ^ hash(self.destProtocol) + value = (value * 31) ^ hash(self.destFilePath) + value = (value * 31) ^ hash(self.destHostCredToken) + value = (value * 31) ^ hash(self.fileTransferMode) + value = (value * 31) ^ hash(self.transferStatus) + value = (value * 31) ^ hash(self.fileSize) + value = (value * 31) ^ hash(self.transferTime) + value = (value * 31) ^ hash(self.createdTime) + value = (value * 31) ^ hash(self.lastModifiedType) + 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 FileNode: + """ + Attributes: + - type + - size + - nativeType + - name + - path + - storageHostName + - lastModifiedType + - createdTime + """ + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'type', None, None, ), # 1 + (2, TType.I64, 'size', None, None, ), # 2 + (3, TType.STRING, 'nativeType', None, None, ), # 3 + (4, TType.STRING, 'name', None, None, ), # 4 + (5, TType.STRING, 'path', None, None, ), # 5 + (6, TType.STRING, 'storageHostName', None, None, ), # 6 + (7, TType.I64, 'lastModifiedType', None, None, ), # 7 + (8, TType.I64, 'createdTime', None, None, ), # 8 + ) + + def __init__(self, type=None, size=None, nativeType=None, name=None, path=None, storageHostName=None, lastModifiedType=None, createdTime=None,): + self.type = type + self.size = size + self.nativeType = nativeType + self.name = name + self.path = path + self.storageHostName = storageHostName + self.lastModifiedType = lastModifiedType + self.createdTime = createdTime + + 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.I32: + self.type = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.size = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.nativeType = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.path = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.storageHostName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.I64: + self.lastModifiedType = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.I64: + self.createdTime = 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('FileNode') + if self.type is not None: + oprot.writeFieldBegin('type', TType.I32, 1) + oprot.writeI32(self.type) + oprot.writeFieldEnd() + if self.size is not None: + oprot.writeFieldBegin('size', TType.I64, 2) + oprot.writeI64(self.size) + oprot.writeFieldEnd() + if self.nativeType is not None: + oprot.writeFieldBegin('nativeType', TType.STRING, 3) + oprot.writeString(self.nativeType) + oprot.writeFieldEnd() + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 4) + oprot.writeString(self.name) + oprot.writeFieldEnd() + if self.path is not None: + oprot.writeFieldBegin('path', TType.STRING, 5) + oprot.writeString(self.path) + oprot.writeFieldEnd() + if self.storageHostName is not None: + oprot.writeFieldBegin('storageHostName', TType.STRING, 6) + oprot.writeString(self.storageHostName) + oprot.writeFieldEnd() + if self.lastModifiedType is not None: + oprot.writeFieldBegin('lastModifiedType', TType.I64, 7) + oprot.writeI64(self.lastModifiedType) + oprot.writeFieldEnd() + if self.createdTime is not None: + oprot.writeFieldBegin('createdTime', TType.I64, 8) + oprot.writeI64(self.createdTime) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.type) + value = (value * 31) ^ hash(self.size) + value = (value * 31) ^ hash(self.nativeType) + value = (value * 31) ^ hash(self.name) + value = (value * 31) ^ hash(self.path) + value = (value * 31) ^ hash(self.storageHostName) + value = (value * 31) ^ hash(self.lastModifiedType) + value = (value * 31) ^ hash(self.createdTime) + 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) http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/__init__.py new file mode 100644 index 0000000..adefd8e --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/constants.py new file mode 100644 index 0000000..4a6492b --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/constants.py @@ -0,0 +1,11 @@ +# +# Autogenerated by Thrift Compiler (0.9.3) +# +# 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 * + http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/ttypes.py new file mode 100644 index 0000000..58b9cff --- /dev/null +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/replica/ttypes.py @@ -0,0 +1,574 @@ +# +# Autogenerated by Thrift Compiler (0.9.3) +# +# 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 +import apache.airavata.model.data.movement.ttypes + + +from thrift.transport import TTransport +from thrift.protocol import TBinaryProtocol, TProtocol +try: + from thrift.protocol import fastbinary +except: + fastbinary = None + + +class ReplicaLocationCategory: + GATEWAY_DATA_STORE = 0 + COMPUTE_RESOURCE = 1 + LONG_TERM_STORAGE_RESOURCE = 2 + OTHER = 3 + + _VALUES_TO_NAMES = { + 0: "GATEWAY_DATA_STORE", + 1: "COMPUTE_RESOURCE", + 2: "LONG_TERM_STORAGE_RESOURCE", + 3: "OTHER", + } + + _NAMES_TO_VALUES = { + "GATEWAY_DATA_STORE": 0, + "COMPUTE_RESOURCE": 1, + "LONG_TERM_STORAGE_RESOURCE": 2, + "OTHER": 3, + } + +class ReplicaPersistentType: + TRANSIENT = 0 + PERSISTENT = 1 + + _VALUES_TO_NAMES = { + 0: "TRANSIENT", + 1: "PERSISTENT", + } + + _NAMES_TO_VALUES = { + "TRANSIENT": 0, + "PERSISTENT": 1, + } + +class DataResourceType: + COLLECTION = 0 + FILE = 1 + + _VALUES_TO_NAMES = { + 0: "COLLECTION", + 1: "FILE", + } + + _NAMES_TO_VALUES = { + "COLLECTION": 0, + "FILE": 1, + } + + +class DataResourceModel: + """ + Attributes: + - resourceId + - gatewayId + - parentResourceId + - resourceName + - resourceDescription + - ownerName + - sha256Checksum + - dataResourceType + - resourceSize + - nativeFormat + - creationTime + - lastModifiedTime + - resourceMetadata + - replicaLocations + - childResources + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'resourceId', None, None, ), # 1 + (2, TType.STRING, 'gatewayId', None, None, ), # 2 + (3, TType.STRING, 'parentResourceId', None, None, ), # 3 + (4, TType.STRING, 'resourceName', None, None, ), # 4 + (5, TType.STRING, 'resourceDescription', None, None, ), # 5 + (6, TType.STRING, 'ownerName', None, None, ), # 6 + (7, TType.STRING, 'sha256Checksum', None, None, ), # 7 + (8, TType.I32, 'dataResourceType', None, None, ), # 8 + (9, TType.I32, 'resourceSize', None, None, ), # 9 + (10, TType.STRING, 'nativeFormat', None, None, ), # 10 + (11, TType.I64, 'creationTime', None, None, ), # 11 + (12, TType.I64, 'lastModifiedTime', None, None, ), # 12 + (13, TType.MAP, 'resourceMetadata', (TType.STRING,None,TType.STRING,None), None, ), # 13 + (14, TType.LIST, 'replicaLocations', (TType.STRUCT,(DataReplicaLocationModel, DataReplicaLocationModel.thrift_spec)), None, ), # 14 + (15, TType.LIST, 'childResources', (TType.STRUCT,(DataResourceModel, DataResourceModel.thrift_spec)), None, ), # 15 + ) + + def __init__(self, resourceId=None, gatewayId=None, parentResourceId=None, resourceName=None, resourceDescription=None, ownerName=None, sha256Checksum=None, dataResourceType=None, resourceSize=None, nativeFormat=None, creationTime=None, lastModifiedTime=None, resourceMetadata=None, replicaLocations=None, childResources=None,): + self.resourceId = resourceId + self.gatewayId = gatewayId + self.parentResourceId = parentResourceId + self.resourceName = resourceName + self.resourceDescription = resourceDescription + self.ownerName = ownerName + self.sha256Checksum = sha256Checksum + self.dataResourceType = dataResourceType + self.resourceSize = resourceSize + self.nativeFormat = nativeFormat + self.creationTime = creationTime + self.lastModifiedTime = lastModifiedTime + self.resourceMetadata = resourceMetadata + self.replicaLocations = replicaLocations + self.childResources = childResources + + 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.resourceId = 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.parentResourceId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.resourceName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.resourceDescription = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.STRING: + self.ownerName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.sha256Checksum = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.I32: + self.dataResourceType = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.I32: + self.resourceSize = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.STRING: + self.nativeFormat = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.I64: + self.creationTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.I64: + self.lastModifiedTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 13: + if ftype == TType.MAP: + self.resourceMetadata = {} + (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin() + for _i4 in xrange(_size0): + _key5 = iprot.readString() + _val6 = iprot.readString() + self.resourceMetadata[_key5] = _val6 + iprot.readMapEnd() + else: + iprot.skip(ftype) + elif fid == 14: + if ftype == TType.LIST: + self.replicaLocations = [] + (_etype10, _size7) = iprot.readListBegin() + for _i11 in xrange(_size7): + _elem12 = DataReplicaLocationModel() + _elem12.read(iprot) + self.replicaLocations.append(_elem12) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 15: + if ftype == TType.LIST: + self.childResources = [] + (_etype16, _size13) = iprot.readListBegin() + for _i17 in xrange(_size13): + _elem18 = DataResourceModel() + _elem18.read(iprot) + self.childResources.append(_elem18) + iprot.readListEnd() + 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('DataResourceModel') + if self.resourceId is not None: + oprot.writeFieldBegin('resourceId', TType.STRING, 1) + oprot.writeString(self.resourceId) + oprot.writeFieldEnd() + if self.gatewayId is not None: + oprot.writeFieldBegin('gatewayId', TType.STRING, 2) + oprot.writeString(self.gatewayId) + oprot.writeFieldEnd() + if self.parentResourceId is not None: + oprot.writeFieldBegin('parentResourceId', TType.STRING, 3) + oprot.writeString(self.parentResourceId) + oprot.writeFieldEnd() + if self.resourceName is not None: + oprot.writeFieldBegin('resourceName', TType.STRING, 4) + oprot.writeString(self.resourceName) + oprot.writeFieldEnd() + if self.resourceDescription is not None: + oprot.writeFieldBegin('resourceDescription', TType.STRING, 5) + oprot.writeString(self.resourceDescription) + oprot.writeFieldEnd() + if self.ownerName is not None: + oprot.writeFieldBegin('ownerName', TType.STRING, 6) + oprot.writeString(self.ownerName) + oprot.writeFieldEnd() + if self.sha256Checksum is not None: + oprot.writeFieldBegin('sha256Checksum', TType.STRING, 7) + oprot.writeString(self.sha256Checksum) + oprot.writeFieldEnd() + if self.dataResourceType is not None: + oprot.writeFieldBegin('dataResourceType', TType.I32, 8) + oprot.writeI32(self.dataResourceType) + oprot.writeFieldEnd() + if self.resourceSize is not None: + oprot.writeFieldBegin('resourceSize', TType.I32, 9) + oprot.writeI32(self.resourceSize) + oprot.writeFieldEnd() + if self.nativeFormat is not None: + oprot.writeFieldBegin('nativeFormat', TType.STRING, 10) + oprot.writeString(self.nativeFormat) + oprot.writeFieldEnd() + if self.creationTime is not None: + oprot.writeFieldBegin('creationTime', TType.I64, 11) + oprot.writeI64(self.creationTime) + oprot.writeFieldEnd() + if self.lastModifiedTime is not None: + oprot.writeFieldBegin('lastModifiedTime', TType.I64, 12) + oprot.writeI64(self.lastModifiedTime) + oprot.writeFieldEnd() + if self.resourceMetadata is not None: + oprot.writeFieldBegin('resourceMetadata', TType.MAP, 13) + oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.resourceMetadata)) + for kiter19,viter20 in self.resourceMetadata.items(): + oprot.writeString(kiter19) + oprot.writeString(viter20) + oprot.writeMapEnd() + oprot.writeFieldEnd() + if self.replicaLocations is not None: + oprot.writeFieldBegin('replicaLocations', TType.LIST, 14) + oprot.writeListBegin(TType.STRUCT, len(self.replicaLocations)) + for iter21 in self.replicaLocations: + iter21.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.childResources is not None: + oprot.writeFieldBegin('childResources', TType.LIST, 15) + oprot.writeListBegin(TType.STRUCT, len(self.childResources)) + for iter22 in self.childResources: + iter22.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.resourceId) + value = (value * 31) ^ hash(self.gatewayId) + value = (value * 31) ^ hash(self.parentResourceId) + value = (value * 31) ^ hash(self.resourceName) + value = (value * 31) ^ hash(self.resourceDescription) + value = (value * 31) ^ hash(self.ownerName) + value = (value * 31) ^ hash(self.sha256Checksum) + value = (value * 31) ^ hash(self.dataResourceType) + value = (value * 31) ^ hash(self.resourceSize) + value = (value * 31) ^ hash(self.nativeFormat) + value = (value * 31) ^ hash(self.creationTime) + value = (value * 31) ^ hash(self.lastModifiedTime) + value = (value * 31) ^ hash(self.resourceMetadata) + value = (value * 31) ^ hash(self.replicaLocations) + value = (value * 31) ^ hash(self.childResources) + 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 DataReplicaLocationModel: + """ + Attributes: + - replicaId + - resourceId + - replicaName + - replicaDescription + - sourceReplicaId + - creationTime + - lastModifiedTime + - validUntilTime + - replicaLocationCategory + - replicaPersistentType + - storageResourceId + - fileAbsolutePath + - replicaMetadata + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'replicaId', None, None, ), # 1 + (2, TType.STRING, 'resourceId', None, None, ), # 2 + (3, TType.STRING, 'replicaName', None, None, ), # 3 + (4, TType.STRING, 'replicaDescription', None, None, ), # 4 + (5, TType.STRING, 'sourceReplicaId', None, None, ), # 5 + (6, TType.I64, 'creationTime', None, None, ), # 6 + (7, TType.I64, 'lastModifiedTime', None, None, ), # 7 + (8, TType.I64, 'validUntilTime', None, None, ), # 8 + (9, TType.I32, 'replicaLocationCategory', None, None, ), # 9 + (10, TType.I32, 'replicaPersistentType', None, None, ), # 10 + (11, TType.STRING, 'storageResourceId', None, None, ), # 11 + (12, TType.STRING, 'fileAbsolutePath', None, None, ), # 12 + (13, TType.MAP, 'replicaMetadata', (TType.STRING,None,TType.STRING,None), None, ), # 13 + ) + + def __init__(self, replicaId=None, resourceId=None, replicaName=None, replicaDescription=None, sourceReplicaId=None, creationTime=None, lastModifiedTime=None, validUntilTime=None, replicaLocationCategory=None, replicaPersistentType=None, storageResourceId=None, fileAbsolutePath=None, replicaMetadata=None,): + self.replicaId = replicaId + self.resourceId = resourceId + self.replicaName = replicaName + self.replicaDescription = replicaDescription + self.sourceReplicaId = sourceReplicaId + self.creationTime = creationTime + self.lastModifiedTime = lastModifiedTime + self.validUntilTime = validUntilTime + self.replicaLocationCategory = replicaLocationCategory + self.replicaPersistentType = replicaPersistentType + self.storageResourceId = storageResourceId + self.fileAbsolutePath = fileAbsolutePath + self.replicaMetadata = replicaMetadata + + 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.replicaId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.resourceId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.replicaName = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.replicaDescription = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.sourceReplicaId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.I64: + self.creationTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.I64: + self.lastModifiedTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 8: + if ftype == TType.I64: + self.validUntilTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.I32: + self.replicaLocationCategory = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.I32: + self.replicaPersistentType = iprot.readI32() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.STRING: + self.storageResourceId = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.STRING: + self.fileAbsolutePath = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 13: + if ftype == TType.MAP: + self.replicaMetadata = {} + (_ktype24, _vtype25, _size23 ) = iprot.readMapBegin() + for _i27 in xrange(_size23): + _key28 = iprot.readString() + _val29 = iprot.readString() + self.replicaMetadata[_key28] = _val29 + iprot.readMapEnd() + 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('DataReplicaLocationModel') + if self.replicaId is not None: + oprot.writeFieldBegin('replicaId', TType.STRING, 1) + oprot.writeString(self.replicaId) + oprot.writeFieldEnd() + if self.resourceId is not None: + oprot.writeFieldBegin('resourceId', TType.STRING, 2) + oprot.writeString(self.resourceId) + oprot.writeFieldEnd() + if self.replicaName is not None: + oprot.writeFieldBegin('replicaName', TType.STRING, 3) + oprot.writeString(self.replicaName) + oprot.writeFieldEnd() + if self.replicaDescription is not None: + oprot.writeFieldBegin('replicaDescription', TType.STRING, 4) + oprot.writeString(self.replicaDescription) + oprot.writeFieldEnd() + if self.sourceReplicaId is not None: + oprot.writeFieldBegin('sourceReplicaId', TType.STRING, 5) + oprot.writeString(self.sourceReplicaId) + oprot.writeFieldEnd() + if self.creationTime is not None: + oprot.writeFieldBegin('creationTime', TType.I64, 6) + oprot.writeI64(self.creationTime) + oprot.writeFieldEnd() + if self.lastModifiedTime is not None: + oprot.writeFieldBegin('lastModifiedTime', TType.I64, 7) + oprot.writeI64(self.lastModifiedTime) + oprot.writeFieldEnd() + if self.validUntilTime is not None: + oprot.writeFieldBegin('validUntilTime', TType.I64, 8) + oprot.writeI64(self.validUntilTime) + oprot.writeFieldEnd() + if self.replicaLocationCategory is not None: + oprot.writeFieldBegin('replicaLocationCategory', TType.I32, 9) + oprot.writeI32(self.replicaLocationCategory) + oprot.writeFieldEnd() + if self.replicaPersistentType is not None: + oprot.writeFieldBegin('replicaPersistentType', TType.I32, 10) + oprot.writeI32(self.replicaPersistentType) + oprot.writeFieldEnd() + if self.storageResourceId is not None: + oprot.writeFieldBegin('storageResourceId', TType.STRING, 11) + oprot.writeString(self.storageResourceId) + oprot.writeFieldEnd() + if self.fileAbsolutePath is not None: + oprot.writeFieldBegin('fileAbsolutePath', TType.STRING, 12) + oprot.writeString(self.fileAbsolutePath) + oprot.writeFieldEnd() + if self.replicaMetadata is not None: + oprot.writeFieldBegin('replicaMetadata', TType.MAP, 13) + oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.replicaMetadata)) + for kiter30,viter31 in self.replicaMetadata.items(): + oprot.writeString(kiter30) + oprot.writeString(viter31) + oprot.writeMapEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.replicaId) + value = (value * 31) ^ hash(self.resourceId) + value = (value * 31) ^ hash(self.replicaName) + value = (value * 31) ^ hash(self.replicaDescription) + value = (value * 31) ^ hash(self.sourceReplicaId) + value = (value * 31) ^ hash(self.creationTime) + value = (value * 31) ^ hash(self.lastModifiedTime) + value = (value * 31) ^ hash(self.validUntilTime) + value = (value * 31) ^ hash(self.replicaLocationCategory) + value = (value * 31) ^ hash(self.replicaPersistentType) + value = (value * 31) ^ hash(self.storageResourceId) + value = (value * 31) ^ hash(self.fileAbsolutePath) + value = (value * 31) ^ hash(self.replicaMetadata) + 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) http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py index 68bbd05..e3e0e8f 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/ttypes.py @@ -19,7 +19,8 @@ import apache.airavata.model.process.ttypes import apache.airavata.model.scheduling.ttypes import apache.airavata.model.status.ttypes import apache.airavata.model.data.movement.ttypes -import apache.airavata.model.data.resource.ttypes +import apache.airavata.model.replica.ttypes +import apache.airavata.model.file.ttypes from thrift.transport import TTransport http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/__init__.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/__init__.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/__init__.py deleted file mode 100644 index adefd8e..0000000 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/__init__.py +++ /dev/null @@ -1 +0,0 @@ -__all__ = ['ttypes', 'constants'] http://git-wip-us.apache.org/repos/asf/airavata/blob/5881af94/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/constants.py deleted file mode 100644 index f9a3855..0000000 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/workspace/experiment/constants.py +++ /dev/null @@ -1,14 +0,0 @@ -# -# Autogenerated by Thrift Compiler (0.9.2) -# -# 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 * - -DEFAULT_ID = "DO_NOT_SET_AT_CLIENTS" -DEFAULT_PROJECT_NAME = "DEFAULT" -SINGLE_APP_NODE_NAME = "SINGLE_APP_NODE"