You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ma...@apache.org on 2017/09/21 16:59:44 UTC
[14/54] [abbrv] [partial] airavata-django-portal git commit: Moving
admin_view JS into django app and moving django project back
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/commons/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/commons/ttypes.py b/django_portal/apache/airavata/model/commons/ttypes.py
deleted file mode 100644
index 3e081fd..0000000
--- a/django_portal/apache/airavata/model/commons/ttypes.py
+++ /dev/null
@@ -1,308 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-
-from thrift.transport import TTransport
-
-
-class ErrorModel(object):
- """
- Attributes:
- - errorId
- - creationTime
- - actualErrorMessage
- - userFriendlyMessage
- - transientOrPersistent
- - rootCauseErrorIdList
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'errorId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ), # 1
- (2, TType.I64, 'creationTime', None, None, ), # 2
- (3, TType.STRING, 'actualErrorMessage', 'UTF8', None, ), # 3
- (4, TType.STRING, 'userFriendlyMessage', 'UTF8', None, ), # 4
- (5, TType.BOOL, 'transientOrPersistent', None, False, ), # 5
- (6, TType.LIST, 'rootCauseErrorIdList', (TType.STRING, 'UTF8', False), None, ), # 6
- )
-
- def __init__(self, errorId=thrift_spec[1][4], creationTime=None, actualErrorMessage=None, userFriendlyMessage=None, transientOrPersistent=thrift_spec[5][4], rootCauseErrorIdList=None,):
- self.errorId = errorId
- self.creationTime = creationTime
- self.actualErrorMessage = actualErrorMessage
- self.userFriendlyMessage = userFriendlyMessage
- self.transientOrPersistent = transientOrPersistent
- self.rootCauseErrorIdList = rootCauseErrorIdList
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.errorId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I64:
- self.creationTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.actualErrorMessage = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.userFriendlyMessage = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.BOOL:
- self.transientOrPersistent = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.LIST:
- self.rootCauseErrorIdList = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in range(_size0):
- _elem5 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- self.rootCauseErrorIdList.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ErrorModel')
- if self.errorId is not None:
- oprot.writeFieldBegin('errorId', TType.STRING, 1)
- oprot.writeString(self.errorId.encode('utf-8') if sys.version_info[0] == 2 else self.errorId)
- oprot.writeFieldEnd()
- if self.creationTime is not None:
- oprot.writeFieldBegin('creationTime', TType.I64, 2)
- oprot.writeI64(self.creationTime)
- oprot.writeFieldEnd()
- if self.actualErrorMessage is not None:
- oprot.writeFieldBegin('actualErrorMessage', TType.STRING, 3)
- oprot.writeString(self.actualErrorMessage.encode('utf-8') if sys.version_info[0] == 2 else self.actualErrorMessage)
- oprot.writeFieldEnd()
- if self.userFriendlyMessage is not None:
- oprot.writeFieldBegin('userFriendlyMessage', TType.STRING, 4)
- oprot.writeString(self.userFriendlyMessage.encode('utf-8') if sys.version_info[0] == 2 else self.userFriendlyMessage)
- oprot.writeFieldEnd()
- if self.transientOrPersistent is not None:
- oprot.writeFieldBegin('transientOrPersistent', TType.BOOL, 5)
- oprot.writeBool(self.transientOrPersistent)
- oprot.writeFieldEnd()
- if self.rootCauseErrorIdList is not None:
- oprot.writeFieldBegin('rootCauseErrorIdList', TType.LIST, 6)
- oprot.writeListBegin(TType.STRING, len(self.rootCauseErrorIdList))
- for iter6 in self.rootCauseErrorIdList:
- oprot.writeString(iter6.encode('utf-8') if sys.version_info[0] == 2 else iter6)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.errorId is None:
- raise TProtocolException(message='Required field errorId is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class ValidatorResult(object):
- """
- This data structure can be used to store the validation results
- captured during validation step and during the launchExperiment
- operation it can be easilly checked to see the errors occured
- during the experiment launch operation
-
-
- Attributes:
- - result
- - errorDetails
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.BOOL, 'result', None, None, ), # 1
- (2, TType.STRING, 'errorDetails', 'UTF8', None, ), # 2
- )
-
- def __init__(self, result=None, errorDetails=None,):
- self.result = result
- self.errorDetails = errorDetails
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.BOOL:
- self.result = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.errorDetails = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ValidatorResult')
- if self.result is not None:
- oprot.writeFieldBegin('result', TType.BOOL, 1)
- oprot.writeBool(self.result)
- oprot.writeFieldEnd()
- if self.errorDetails is not None:
- oprot.writeFieldBegin('errorDetails', TType.STRING, 2)
- oprot.writeString(self.errorDetails.encode('utf-8') if sys.version_info[0] == 2 else self.errorDetails)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.result is None:
- raise TProtocolException(message='Required field result is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class ValidationResults(object):
- """
- Attributes:
- - validationState
- - validationResultList
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.BOOL, 'validationState', None, None, ), # 1
- (2, TType.LIST, 'validationResultList', (TType.STRUCT, (ValidatorResult, ValidatorResult.thrift_spec), False), None, ), # 2
- )
-
- def __init__(self, validationState=None, validationResultList=None,):
- self.validationState = validationState
- self.validationResultList = validationResultList
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.BOOL:
- self.validationState = iprot.readBool()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.LIST:
- self.validationResultList = []
- (_etype10, _size7) = iprot.readListBegin()
- for _i11 in range(_size7):
- _elem12 = ValidatorResult()
- _elem12.read(iprot)
- self.validationResultList.append(_elem12)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('ValidationResults')
- if self.validationState is not None:
- oprot.writeFieldBegin('validationState', TType.BOOL, 1)
- oprot.writeBool(self.validationState)
- oprot.writeFieldEnd()
- if self.validationResultList is not None:
- oprot.writeFieldBegin('validationResultList', TType.LIST, 2)
- oprot.writeListBegin(TType.STRUCT, len(self.validationResultList))
- for iter13 in self.validationResultList:
- iter13.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.validationState is None:
- raise TProtocolException(message='Required field validationState is unset!')
- if self.validationResultList is None:
- raise TProtocolException(message='Required field validationResultList is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/constants.py b/django_portal/apache/airavata/model/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/data/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/data/__init__.py b/django_portal/apache/airavata/model/data/__init__.py
deleted file mode 100644
index e69de29..0000000
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/data/movement/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/data/movement/__init__.py b/django_portal/apache/airavata/model/data/movement/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/data/movement/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/data/movement/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/data/movement/constants.py b/django_portal/apache/airavata/model/data/movement/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/data/movement/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/data/movement/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/data/movement/ttypes.py b/django_portal/apache/airavata/model/data/movement/ttypes.py
deleted file mode 100644
index ff74381..0000000
--- a/django_portal/apache/airavata/model/data/movement/ttypes.py
+++ /dev/null
@@ -1,588 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-import apache.airavata.model.commons.ttypes
-
-from thrift.transport import TTransport
-
-
-class DMType(object):
- COMPUTE_RESOURCE = 0
- STORAGE_RESOURCE = 1
-
- _VALUES_TO_NAMES = {
- 0: "COMPUTE_RESOURCE",
- 1: "STORAGE_RESOURCE",
- }
-
- _NAMES_TO_VALUES = {
- "COMPUTE_RESOURCE": 0,
- "STORAGE_RESOURCE": 1,
- }
-
-
-class SecurityProtocol(object):
- """
- Enumeration of security sshKeyAuthentication and authorization mechanisms supported by Airavata. This enumeration just
- describes the supported mechanism. The corresponding security credentials are registered with Airavata Credential
- store.
-
- USERNAME_PASSWORD:
- A User Name.
-
- SSH_KEYS:
- SSH Keys
-
- FIXME: Change GSI to a more precise generic security protocol - X509
-
- """
- USERNAME_PASSWORD = 0
- SSH_KEYS = 1
- GSI = 2
- KERBEROS = 3
- OAUTH = 4
- LOCAL = 5
-
- _VALUES_TO_NAMES = {
- 0: "USERNAME_PASSWORD",
- 1: "SSH_KEYS",
- 2: "GSI",
- 3: "KERBEROS",
- 4: "OAUTH",
- 5: "LOCAL",
- }
-
- _NAMES_TO_VALUES = {
- "USERNAME_PASSWORD": 0,
- "SSH_KEYS": 1,
- "GSI": 2,
- "KERBEROS": 3,
- "OAUTH": 4,
- "LOCAL": 5,
- }
-
-
-class DataMovementProtocol(object):
- """
- Enumeration of data movement supported by Airavata
-
- SCP:
- Job manager supporting the Portal Batch System (PBS) protocol. Some examples include TORQUE, PBSPro, Grid Engine.
-
- SFTP:
- The Simple Linux Utility for Resource Management is a open source workload manager.
-
- GridFTP:
- Globus File Transfer Protocol
-
- UNICORE_STORAGE_SERVICE:
- Storage Service Provided by Unicore
-
- """
- LOCAL = 0
- SCP = 1
- SFTP = 2
- GridFTP = 3
- UNICORE_STORAGE_SERVICE = 4
-
- _VALUES_TO_NAMES = {
- 0: "LOCAL",
- 1: "SCP",
- 2: "SFTP",
- 3: "GridFTP",
- 4: "UNICORE_STORAGE_SERVICE",
- }
-
- _NAMES_TO_VALUES = {
- "LOCAL": 0,
- "SCP": 1,
- "SFTP": 2,
- "GridFTP": 3,
- "UNICORE_STORAGE_SERVICE": 4,
- }
-
-
-class SCPDataMovement(object):
- """
- Data Movement through Secured Copy
-
- alternativeSCPHostName:
- If the login to scp is different than the hostname itself, specify it here
-
- sshPort:
- If a non-default port needs to used, specify it.
-
- Attributes:
- - dataMovementInterfaceId
- - securityProtocol
- - alternativeSCPHostName
- - sshPort
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'dataMovementInterfaceId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ), # 1
- (2, TType.I32, 'securityProtocol', None, None, ), # 2
- (3, TType.STRING, 'alternativeSCPHostName', 'UTF8', None, ), # 3
- (4, TType.I32, 'sshPort', None, 22, ), # 4
- )
-
- def __init__(self, dataMovementInterfaceId=thrift_spec[1][4], securityProtocol=None, alternativeSCPHostName=None, sshPort=thrift_spec[4][4],):
- self.dataMovementInterfaceId = dataMovementInterfaceId
- self.securityProtocol = securityProtocol
- self.alternativeSCPHostName = alternativeSCPHostName
- self.sshPort = sshPort
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.dataMovementInterfaceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.securityProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.alternativeSCPHostName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.I32:
- self.sshPort = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('SCPDataMovement')
- if self.dataMovementInterfaceId is not None:
- oprot.writeFieldBegin('dataMovementInterfaceId', TType.STRING, 1)
- oprot.writeString(self.dataMovementInterfaceId.encode('utf-8') if sys.version_info[0] == 2 else self.dataMovementInterfaceId)
- oprot.writeFieldEnd()
- if self.securityProtocol is not None:
- oprot.writeFieldBegin('securityProtocol', TType.I32, 2)
- oprot.writeI32(self.securityProtocol)
- oprot.writeFieldEnd()
- if self.alternativeSCPHostName is not None:
- oprot.writeFieldBegin('alternativeSCPHostName', TType.STRING, 3)
- oprot.writeString(self.alternativeSCPHostName.encode('utf-8') if sys.version_info[0] == 2 else self.alternativeSCPHostName)
- oprot.writeFieldEnd()
- if self.sshPort is not None:
- oprot.writeFieldBegin('sshPort', TType.I32, 4)
- oprot.writeI32(self.sshPort)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.dataMovementInterfaceId is None:
- raise TProtocolException(message='Required field dataMovementInterfaceId is unset!')
- if self.securityProtocol is None:
- raise TProtocolException(message='Required field securityProtocol is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class GridFTPDataMovement(object):
- """
- Data Movement through GridFTP
-
- alternativeSCPHostName:
- If the login to scp is different than the hostname itself, specify it here
-
- sshPort:
- If a non-default port needs to used, specify it.
-
- Attributes:
- - dataMovementInterfaceId
- - securityProtocol
- - gridFTPEndPoints
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'dataMovementInterfaceId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ), # 1
- (2, TType.I32, 'securityProtocol', None, None, ), # 2
- (3, TType.LIST, 'gridFTPEndPoints', (TType.STRING, 'UTF8', False), None, ), # 3
- )
-
- def __init__(self, dataMovementInterfaceId=thrift_spec[1][4], securityProtocol=None, gridFTPEndPoints=None,):
- self.dataMovementInterfaceId = dataMovementInterfaceId
- self.securityProtocol = securityProtocol
- self.gridFTPEndPoints = gridFTPEndPoints
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.dataMovementInterfaceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.securityProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.LIST:
- self.gridFTPEndPoints = []
- (_etype3, _size0) = iprot.readListBegin()
- for _i4 in range(_size0):
- _elem5 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- self.gridFTPEndPoints.append(_elem5)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('GridFTPDataMovement')
- if self.dataMovementInterfaceId is not None:
- oprot.writeFieldBegin('dataMovementInterfaceId', TType.STRING, 1)
- oprot.writeString(self.dataMovementInterfaceId.encode('utf-8') if sys.version_info[0] == 2 else self.dataMovementInterfaceId)
- oprot.writeFieldEnd()
- if self.securityProtocol is not None:
- oprot.writeFieldBegin('securityProtocol', TType.I32, 2)
- oprot.writeI32(self.securityProtocol)
- oprot.writeFieldEnd()
- if self.gridFTPEndPoints is not None:
- oprot.writeFieldBegin('gridFTPEndPoints', TType.LIST, 3)
- oprot.writeListBegin(TType.STRING, len(self.gridFTPEndPoints))
- for iter6 in self.gridFTPEndPoints:
- oprot.writeString(iter6.encode('utf-8') if sys.version_info[0] == 2 else iter6)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.dataMovementInterfaceId is None:
- raise TProtocolException(message='Required field dataMovementInterfaceId is unset!')
- if self.securityProtocol is None:
- raise TProtocolException(message='Required field securityProtocol is unset!')
- if self.gridFTPEndPoints is None:
- raise TProtocolException(message='Required field gridFTPEndPoints is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class UnicoreDataMovement(object):
- """
- Data Movement through UnicoreStorage
-
- unicoreEndPointURL:
- unicoreGateway End Point. The provider will query this service to fetch required service end points.
-
- Attributes:
- - dataMovementInterfaceId
- - securityProtocol
- - unicoreEndPointURL
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'dataMovementInterfaceId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ), # 1
- (2, TType.I32, 'securityProtocol', None, None, ), # 2
- (3, TType.STRING, 'unicoreEndPointURL', 'UTF8', None, ), # 3
- )
-
- def __init__(self, dataMovementInterfaceId=thrift_spec[1][4], securityProtocol=None, unicoreEndPointURL=None,):
- self.dataMovementInterfaceId = dataMovementInterfaceId
- self.securityProtocol = securityProtocol
- self.unicoreEndPointURL = unicoreEndPointURL
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.dataMovementInterfaceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.securityProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.unicoreEndPointURL = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('UnicoreDataMovement')
- if self.dataMovementInterfaceId is not None:
- oprot.writeFieldBegin('dataMovementInterfaceId', TType.STRING, 1)
- oprot.writeString(self.dataMovementInterfaceId.encode('utf-8') if sys.version_info[0] == 2 else self.dataMovementInterfaceId)
- oprot.writeFieldEnd()
- if self.securityProtocol is not None:
- oprot.writeFieldBegin('securityProtocol', TType.I32, 2)
- oprot.writeI32(self.securityProtocol)
- oprot.writeFieldEnd()
- if self.unicoreEndPointURL is not None:
- oprot.writeFieldBegin('unicoreEndPointURL', TType.STRING, 3)
- oprot.writeString(self.unicoreEndPointURL.encode('utf-8') if sys.version_info[0] == 2 else self.unicoreEndPointURL)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.dataMovementInterfaceId is None:
- raise TProtocolException(message='Required field dataMovementInterfaceId is unset!')
- if self.securityProtocol is None:
- raise TProtocolException(message='Required field securityProtocol is unset!')
- if self.unicoreEndPointURL is None:
- raise TProtocolException(message='Required field unicoreEndPointURL is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class LOCALDataMovement(object):
- """
- LOCAL
-
- alternativeSCPHostName:
- If the login to scp is different than the hostname itself, specify it here
-
- sshPort:
- If a non-defualt port needs to used, specify it.
-
- Attributes:
- - dataMovementInterfaceId
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'dataMovementInterfaceId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ), # 1
- )
-
- def __init__(self, dataMovementInterfaceId=thrift_spec[1][4],):
- self.dataMovementInterfaceId = dataMovementInterfaceId
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.dataMovementInterfaceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('LOCALDataMovement')
- if self.dataMovementInterfaceId is not None:
- oprot.writeFieldBegin('dataMovementInterfaceId', TType.STRING, 1)
- oprot.writeString(self.dataMovementInterfaceId.encode('utf-8') if sys.version_info[0] == 2 else self.dataMovementInterfaceId)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.dataMovementInterfaceId is None:
- raise TProtocolException(message='Required field dataMovementInterfaceId is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class DataMovementInterface(object):
- """
- Data Movement Interfaces
-
- dataMovementInterfaceId: The Data Movement Interface has to be previously registered and referenced here.
-
- priorityOrder:
- For resources with multiple interfaces, the priority order should be selected.
- Lower the numerical number, higher the priority
-
-
- Attributes:
- - dataMovementInterfaceId
- - dataMovementProtocol
- - priorityOrder
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'dataMovementInterfaceId', 'UTF8', None, ), # 1
- (2, TType.I32, 'dataMovementProtocol', None, None, ), # 2
- (3, TType.I32, 'priorityOrder', None, 0, ), # 3
- )
-
- def __init__(self, dataMovementInterfaceId=None, dataMovementProtocol=None, priorityOrder=thrift_spec[3][4],):
- self.dataMovementInterfaceId = dataMovementInterfaceId
- self.dataMovementProtocol = dataMovementProtocol
- self.priorityOrder = priorityOrder
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.dataMovementInterfaceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.dataMovementProtocol = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I32:
- self.priorityOrder = iprot.readI32()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DataMovementInterface')
- if self.dataMovementInterfaceId is not None:
- oprot.writeFieldBegin('dataMovementInterfaceId', TType.STRING, 1)
- oprot.writeString(self.dataMovementInterfaceId.encode('utf-8') if sys.version_info[0] == 2 else self.dataMovementInterfaceId)
- oprot.writeFieldEnd()
- if self.dataMovementProtocol is not None:
- oprot.writeFieldBegin('dataMovementProtocol', TType.I32, 2)
- oprot.writeI32(self.dataMovementProtocol)
- oprot.writeFieldEnd()
- if self.priorityOrder is not None:
- oprot.writeFieldBegin('priorityOrder', TType.I32, 3)
- oprot.writeI32(self.priorityOrder)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.dataMovementInterfaceId is None:
- raise TProtocolException(message='Required field dataMovementInterfaceId is unset!')
- if self.dataMovementProtocol is None:
- raise TProtocolException(message='Required field dataMovementProtocol is unset!')
- if self.priorityOrder is None:
- raise TProtocolException(message='Required field priorityOrder is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/data/replica/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/data/replica/__init__.py b/django_portal/apache/airavata/model/data/replica/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/data/replica/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/data/replica/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/data/replica/constants.py b/django_portal/apache/airavata/model/data/replica/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/data/replica/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/data/replica/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/data/replica/ttypes.py b/django_portal/apache/airavata/model/data/replica/ttypes.py
deleted file mode 100644
index ca2ecbb..0000000
--- a/django_portal/apache/airavata/model/data/replica/ttypes.py
+++ /dev/null
@@ -1,477 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-
-from thrift.transport import TTransport
-
-
-class ReplicaLocationCategory(object):
- 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(object):
- TRANSIENT = 0
- PERSISTENT = 1
-
- _VALUES_TO_NAMES = {
- 0: "TRANSIENT",
- 1: "PERSISTENT",
- }
-
- _NAMES_TO_VALUES = {
- "TRANSIENT": 0,
- "PERSISTENT": 1,
- }
-
-
-class DataProductType(object):
- FILE = 0
- COLLECTION = 1
-
- _VALUES_TO_NAMES = {
- 0: "FILE",
- 1: "COLLECTION",
- }
-
- _NAMES_TO_VALUES = {
- "FILE": 0,
- "COLLECTION": 1,
- }
-
-
-class DataReplicaLocationModel(object):
- """
- Attributes:
- - replicaId
- - productUri
- - replicaName
- - replicaDescription
- - creationTime
- - lastModifiedTime
- - validUntilTime
- - replicaLocationCategory
- - replicaPersistentType
- - storageResourceId
- - filePath
- - replicaMetadata
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'replicaId', 'UTF8', None, ), # 1
- (2, TType.STRING, 'productUri', 'UTF8', None, ), # 2
- (3, TType.STRING, 'replicaName', 'UTF8', None, ), # 3
- (4, TType.STRING, 'replicaDescription', 'UTF8', None, ), # 4
- (5, TType.I64, 'creationTime', None, None, ), # 5
- (6, TType.I64, 'lastModifiedTime', None, None, ), # 6
- (7, TType.I64, 'validUntilTime', None, None, ), # 7
- (8, TType.I32, 'replicaLocationCategory', None, None, ), # 8
- (9, TType.I32, 'replicaPersistentType', None, None, ), # 9
- (10, TType.STRING, 'storageResourceId', 'UTF8', None, ), # 10
- (11, TType.STRING, 'filePath', 'UTF8', None, ), # 11
- (12, TType.MAP, 'replicaMetadata', (TType.STRING, 'UTF8', TType.STRING, 'UTF8', False), None, ), # 12
- )
-
- def __init__(self, replicaId=None, productUri=None, replicaName=None, replicaDescription=None, creationTime=None, lastModifiedTime=None, validUntilTime=None, replicaLocationCategory=None, replicaPersistentType=None, storageResourceId=None, filePath=None, replicaMetadata=None,):
- self.replicaId = replicaId
- self.productUri = productUri
- self.replicaName = replicaName
- self.replicaDescription = replicaDescription
- self.creationTime = creationTime
- self.lastModifiedTime = lastModifiedTime
- self.validUntilTime = validUntilTime
- self.replicaLocationCategory = replicaLocationCategory
- self.replicaPersistentType = replicaPersistentType
- self.storageResourceId = storageResourceId
- self.filePath = filePath
- self.replicaMetadata = replicaMetadata
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.replicaId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.productUri = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.replicaName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.replicaDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.I64:
- self.creationTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.I64:
- self.lastModifiedTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I64:
- self.validUntilTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.I32:
- self.replicaLocationCategory = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.I32:
- self.replicaPersistentType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.STRING:
- self.storageResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.STRING:
- self.filePath = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- if ftype == TType.MAP:
- self.replicaMetadata = {}
- (_ktype1, _vtype2, _size0) = iprot.readMapBegin()
- for _i4 in range(_size0):
- _key5 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- _val6 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- self.replicaMetadata[_key5] = _val6
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DataReplicaLocationModel')
- if self.replicaId is not None:
- oprot.writeFieldBegin('replicaId', TType.STRING, 1)
- oprot.writeString(self.replicaId.encode('utf-8') if sys.version_info[0] == 2 else self.replicaId)
- oprot.writeFieldEnd()
- if self.productUri is not None:
- oprot.writeFieldBegin('productUri', TType.STRING, 2)
- oprot.writeString(self.productUri.encode('utf-8') if sys.version_info[0] == 2 else self.productUri)
- oprot.writeFieldEnd()
- if self.replicaName is not None:
- oprot.writeFieldBegin('replicaName', TType.STRING, 3)
- oprot.writeString(self.replicaName.encode('utf-8') if sys.version_info[0] == 2 else self.replicaName)
- oprot.writeFieldEnd()
- if self.replicaDescription is not None:
- oprot.writeFieldBegin('replicaDescription', TType.STRING, 4)
- oprot.writeString(self.replicaDescription.encode('utf-8') if sys.version_info[0] == 2 else self.replicaDescription)
- oprot.writeFieldEnd()
- if self.creationTime is not None:
- oprot.writeFieldBegin('creationTime', TType.I64, 5)
- oprot.writeI64(self.creationTime)
- oprot.writeFieldEnd()
- if self.lastModifiedTime is not None:
- oprot.writeFieldBegin('lastModifiedTime', TType.I64, 6)
- oprot.writeI64(self.lastModifiedTime)
- oprot.writeFieldEnd()
- if self.validUntilTime is not None:
- oprot.writeFieldBegin('validUntilTime', TType.I64, 7)
- oprot.writeI64(self.validUntilTime)
- oprot.writeFieldEnd()
- if self.replicaLocationCategory is not None:
- oprot.writeFieldBegin('replicaLocationCategory', TType.I32, 8)
- oprot.writeI32(self.replicaLocationCategory)
- oprot.writeFieldEnd()
- if self.replicaPersistentType is not None:
- oprot.writeFieldBegin('replicaPersistentType', TType.I32, 9)
- oprot.writeI32(self.replicaPersistentType)
- oprot.writeFieldEnd()
- if self.storageResourceId is not None:
- oprot.writeFieldBegin('storageResourceId', TType.STRING, 10)
- oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId)
- oprot.writeFieldEnd()
- if self.filePath is not None:
- oprot.writeFieldBegin('filePath', TType.STRING, 11)
- oprot.writeString(self.filePath.encode('utf-8') if sys.version_info[0] == 2 else self.filePath)
- oprot.writeFieldEnd()
- if self.replicaMetadata is not None:
- oprot.writeFieldBegin('replicaMetadata', TType.MAP, 12)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.replicaMetadata))
- for kiter7, viter8 in self.replicaMetadata.items():
- oprot.writeString(kiter7.encode('utf-8') if sys.version_info[0] == 2 else kiter7)
- oprot.writeString(viter8.encode('utf-8') if sys.version_info[0] == 2 else viter8)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class DataProductModel(object):
- """
- Attributes:
- - productUri
- - gatewayId
- - parentProductUri
- - productName
- - productDescription
- - ownerName
- - dataProductType
- - productSize
- - creationTime
- - lastModifiedTime
- - productMetadata
- - replicaLocations
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'productUri', 'UTF8', None, ), # 1
- (2, TType.STRING, 'gatewayId', 'UTF8', None, ), # 2
- (3, TType.STRING, 'parentProductUri', 'UTF8', None, ), # 3
- (4, TType.STRING, 'productName', 'UTF8', None, ), # 4
- (5, TType.STRING, 'productDescription', 'UTF8', None, ), # 5
- (6, TType.STRING, 'ownerName', 'UTF8', None, ), # 6
- (7, TType.I32, 'dataProductType', None, None, ), # 7
- (8, TType.I32, 'productSize', None, None, ), # 8
- (9, TType.I64, 'creationTime', None, None, ), # 9
- (10, TType.I64, 'lastModifiedTime', None, None, ), # 10
- (11, TType.MAP, 'productMetadata', (TType.STRING, 'UTF8', TType.STRING, 'UTF8', False), None, ), # 11
- (12, TType.LIST, 'replicaLocations', (TType.STRUCT, (DataReplicaLocationModel, DataReplicaLocationModel.thrift_spec), False), None, ), # 12
- )
-
- def __init__(self, productUri=None, gatewayId=None, parentProductUri=None, productName=None, productDescription=None, ownerName=None, dataProductType=None, productSize=None, creationTime=None, lastModifiedTime=None, productMetadata=None, replicaLocations=None,):
- self.productUri = productUri
- self.gatewayId = gatewayId
- self.parentProductUri = parentProductUri
- self.productName = productName
- self.productDescription = productDescription
- self.ownerName = ownerName
- self.dataProductType = dataProductType
- self.productSize = productSize
- self.creationTime = creationTime
- self.lastModifiedTime = lastModifiedTime
- self.productMetadata = productMetadata
- self.replicaLocations = replicaLocations
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.productUri = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.gatewayId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.parentProductUri = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRING:
- self.productName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.STRING:
- self.productDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 6:
- if ftype == TType.STRING:
- self.ownerName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 7:
- if ftype == TType.I32:
- self.dataProductType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 8:
- if ftype == TType.I32:
- self.productSize = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 9:
- if ftype == TType.I64:
- self.creationTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 10:
- if ftype == TType.I64:
- self.lastModifiedTime = iprot.readI64()
- else:
- iprot.skip(ftype)
- elif fid == 11:
- if ftype == TType.MAP:
- self.productMetadata = {}
- (_ktype10, _vtype11, _size9) = iprot.readMapBegin()
- for _i13 in range(_size9):
- _key14 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- _val15 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- self.productMetadata[_key14] = _val15
- iprot.readMapEnd()
- else:
- iprot.skip(ftype)
- elif fid == 12:
- if ftype == TType.LIST:
- self.replicaLocations = []
- (_etype19, _size16) = iprot.readListBegin()
- for _i20 in range(_size16):
- _elem21 = DataReplicaLocationModel()
- _elem21.read(iprot)
- self.replicaLocations.append(_elem21)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DataProductModel')
- if self.productUri is not None:
- oprot.writeFieldBegin('productUri', TType.STRING, 1)
- oprot.writeString(self.productUri.encode('utf-8') if sys.version_info[0] == 2 else self.productUri)
- oprot.writeFieldEnd()
- if self.gatewayId is not None:
- oprot.writeFieldBegin('gatewayId', TType.STRING, 2)
- oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
- oprot.writeFieldEnd()
- if self.parentProductUri is not None:
- oprot.writeFieldBegin('parentProductUri', TType.STRING, 3)
- oprot.writeString(self.parentProductUri.encode('utf-8') if sys.version_info[0] == 2 else self.parentProductUri)
- oprot.writeFieldEnd()
- if self.productName is not None:
- oprot.writeFieldBegin('productName', TType.STRING, 4)
- oprot.writeString(self.productName.encode('utf-8') if sys.version_info[0] == 2 else self.productName)
- oprot.writeFieldEnd()
- if self.productDescription is not None:
- oprot.writeFieldBegin('productDescription', TType.STRING, 5)
- oprot.writeString(self.productDescription.encode('utf-8') if sys.version_info[0] == 2 else self.productDescription)
- oprot.writeFieldEnd()
- if self.ownerName is not None:
- oprot.writeFieldBegin('ownerName', TType.STRING, 6)
- oprot.writeString(self.ownerName.encode('utf-8') if sys.version_info[0] == 2 else self.ownerName)
- oprot.writeFieldEnd()
- if self.dataProductType is not None:
- oprot.writeFieldBegin('dataProductType', TType.I32, 7)
- oprot.writeI32(self.dataProductType)
- oprot.writeFieldEnd()
- if self.productSize is not None:
- oprot.writeFieldBegin('productSize', TType.I32, 8)
- oprot.writeI32(self.productSize)
- oprot.writeFieldEnd()
- if self.creationTime is not None:
- oprot.writeFieldBegin('creationTime', TType.I64, 9)
- oprot.writeI64(self.creationTime)
- oprot.writeFieldEnd()
- if self.lastModifiedTime is not None:
- oprot.writeFieldBegin('lastModifiedTime', TType.I64, 10)
- oprot.writeI64(self.lastModifiedTime)
- oprot.writeFieldEnd()
- if self.productMetadata is not None:
- oprot.writeFieldBegin('productMetadata', TType.MAP, 11)
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.productMetadata))
- for kiter22, viter23 in self.productMetadata.items():
- oprot.writeString(kiter22.encode('utf-8') if sys.version_info[0] == 2 else kiter22)
- oprot.writeString(viter23.encode('utf-8') if sys.version_info[0] == 2 else viter23)
- oprot.writeMapEnd()
- oprot.writeFieldEnd()
- if self.replicaLocations is not None:
- oprot.writeFieldBegin('replicaLocations', TType.LIST, 12)
- oprot.writeListBegin(TType.STRUCT, len(self.replicaLocations))
- for iter24 in self.replicaLocations:
- iter24.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/dbevent/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/dbevent/__init__.py b/django_portal/apache/airavata/model/dbevent/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/dbevent/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/dbevent/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/dbevent/constants.py b/django_portal/apache/airavata/model/dbevent/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/dbevent/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/dbevent/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/dbevent/ttypes.py b/django_portal/apache/airavata/model/dbevent/ttypes.py
deleted file mode 100644
index d33f0df..0000000
--- a/django_portal/apache/airavata/model/dbevent/ttypes.py
+++ /dev/null
@@ -1,462 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-
-from thrift.transport import TTransport
-
-
-class CrudType(object):
- CREATE = 0
- READ = 1
- UPDATE = 2
- DELETE = 3
-
- _VALUES_TO_NAMES = {
- 0: "CREATE",
- 1: "READ",
- 2: "UPDATE",
- 3: "DELETE",
- }
-
- _NAMES_TO_VALUES = {
- "CREATE": 0,
- "READ": 1,
- "UPDATE": 2,
- "DELETE": 3,
- }
-
-
-class EntityType(object):
- USER_PROFILE = 0
- TENANT = 1
- GROUP = 2
- PROJECT = 3
- EXPERIMENT = 4
- APPLICATION = 5
- SHARING = 6
- REGISTRY = 7
-
- _VALUES_TO_NAMES = {
- 0: "USER_PROFILE",
- 1: "TENANT",
- 2: "GROUP",
- 3: "PROJECT",
- 4: "EXPERIMENT",
- 5: "APPLICATION",
- 6: "SHARING",
- 7: "REGISTRY",
- }
-
- _NAMES_TO_VALUES = {
- "USER_PROFILE": 0,
- "TENANT": 1,
- "GROUP": 2,
- "PROJECT": 3,
- "EXPERIMENT": 4,
- "APPLICATION": 5,
- "SHARING": 6,
- "REGISTRY": 7,
- }
-
-
-class DBEventType(object):
- PUBLISHER = 0
- SUBSCRIBER = 1
-
- _VALUES_TO_NAMES = {
- 0: "PUBLISHER",
- 1: "SUBSCRIBER",
- }
-
- _NAMES_TO_VALUES = {
- "PUBLISHER": 0,
- "SUBSCRIBER": 1,
- }
-
-
-class DBEventPublisherContext(object):
- """
- Attributes:
- - crudType
- - entityType
- - entityDataModel
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'crudType', None, None, ), # 1
- (2, TType.I32, 'entityType', None, None, ), # 2
- (3, TType.STRING, 'entityDataModel', 'BINARY', None, ), # 3
- )
-
- def __init__(self, crudType=None, entityType=None, entityDataModel=None,):
- self.crudType = crudType
- self.entityType = entityType
- self.entityDataModel = entityDataModel
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I32:
- self.crudType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.I32:
- self.entityType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.entityDataModel = iprot.readBinary()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DBEventPublisherContext')
- if self.crudType is not None:
- oprot.writeFieldBegin('crudType', TType.I32, 1)
- oprot.writeI32(self.crudType)
- oprot.writeFieldEnd()
- if self.entityType is not None:
- oprot.writeFieldBegin('entityType', TType.I32, 2)
- oprot.writeI32(self.entityType)
- oprot.writeFieldEnd()
- if self.entityDataModel is not None:
- oprot.writeFieldBegin('entityDataModel', TType.STRING, 3)
- oprot.writeBinary(self.entityDataModel)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.crudType is None:
- raise TProtocolException(message='Required field crudType is unset!')
- if self.entityType is None:
- raise TProtocolException(message='Required field entityType is unset!')
- if self.entityDataModel is None:
- raise TProtocolException(message='Required field entityDataModel is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class DBEventPublisher(object):
- """
- Attributes:
- - publisherContext
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'publisherContext', (DBEventPublisherContext, DBEventPublisherContext.thrift_spec), None, ), # 1
- )
-
- def __init__(self, publisherContext=None,):
- self.publisherContext = publisherContext
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.publisherContext = DBEventPublisherContext()
- self.publisherContext.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DBEventPublisher')
- if self.publisherContext is not None:
- oprot.writeFieldBegin('publisherContext', TType.STRUCT, 1)
- self.publisherContext.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.publisherContext is None:
- raise TProtocolException(message='Required field publisherContext is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class DBEventSubscriber(object):
- """
- Attributes:
- - subscriberService
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'subscriberService', 'UTF8', None, ), # 1
- )
-
- def __init__(self, subscriberService=None,):
- self.subscriberService = subscriberService
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.subscriberService = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DBEventSubscriber')
- if self.subscriberService is not None:
- oprot.writeFieldBegin('subscriberService', TType.STRING, 1)
- oprot.writeString(self.subscriberService.encode('utf-8') if sys.version_info[0] == 2 else self.subscriberService)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.subscriberService is None:
- raise TProtocolException(message='Required field subscriberService is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class DBEventMessageContext(object):
- """
- Attributes:
- - publisher
- - subscriber
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'publisher', (DBEventPublisher, DBEventPublisher.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'subscriber', (DBEventSubscriber, DBEventSubscriber.thrift_spec), None, ), # 2
- )
-
- def __init__(self, publisher=None, subscriber=None,):
- self.publisher = publisher
- self.subscriber = subscriber
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.publisher = DBEventPublisher()
- self.publisher.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.subscriber = DBEventSubscriber()
- self.subscriber.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DBEventMessageContext')
- if self.publisher is not None:
- oprot.writeFieldBegin('publisher', TType.STRUCT, 1)
- self.publisher.write(oprot)
- oprot.writeFieldEnd()
- if self.subscriber is not None:
- oprot.writeFieldBegin('subscriber', TType.STRUCT, 2)
- self.subscriber.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-
-class DBEventMessage(object):
- """
- Attributes:
- - dbEventType
- - messageContext
- - publisherService
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'dbEventType', None, None, ), # 1
- (2, TType.STRUCT, 'messageContext', (DBEventMessageContext, DBEventMessageContext.thrift_spec), None, ), # 2
- (3, TType.STRING, 'publisherService', 'UTF8', None, ), # 3
- )
-
- def __init__(self, dbEventType=None, messageContext=None, publisherService=None,):
- self.dbEventType = dbEventType
- self.messageContext = messageContext
- self.publisherService = publisherService
-
- def read(self, iprot):
- if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
- iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.I32:
- self.dbEventType = iprot.readI32()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.messageContext = DBEventMessageContext()
- self.messageContext.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRING:
- self.publisherService = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot._fast_encode is not None and self.thrift_spec is not None:
- oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('DBEventMessage')
- if self.dbEventType is not None:
- oprot.writeFieldBegin('dbEventType', TType.I32, 1)
- oprot.writeI32(self.dbEventType)
- oprot.writeFieldEnd()
- if self.messageContext is not None:
- oprot.writeFieldBegin('messageContext', TType.STRUCT, 2)
- self.messageContext.write(oprot)
- oprot.writeFieldEnd()
- if self.publisherService is not None:
- oprot.writeFieldBegin('publisherService', TType.STRING, 3)
- oprot.writeString(self.publisherService.encode('utf-8') if sys.version_info[0] == 2 else self.publisherService)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- if self.dbEventType is None:
- raise TProtocolException(message='Required field dbEventType is unset!')
- if self.messageContext is None:
- raise TProtocolException(message='Required field messageContext is unset!')
- if self.publisherService is None:
- raise TProtocolException(message='Required field publisherService is unset!')
- return
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.items()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/experiment/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/experiment/__init__.py b/django_portal/apache/airavata/model/experiment/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/experiment/__init__.py
+++ /dev/null
@@ -1 +0,0 @@
-__all__ = ['ttypes', 'constants']
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/experiment/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/experiment/constants.py b/django_portal/apache/airavata/model/experiment/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/experiment/constants.py
+++ /dev/null
@@ -1,12 +0,0 @@
-#
-# Autogenerated by Thrift Compiler (0.10.0)
-#
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
-#
-# options string: py
-#
-
-from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
-from thrift.protocol.TProtocol import TProtocolException
-import sys
-from .ttypes import *