airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From scnakand...@apache.org
Subject [26/51] [abbrv] airavata git commit: restructureing the file manager module
Date Wed, 23 Dec 2015 06:53:31 GMT
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"


Mime
View raw message