airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From machris...@apache.org
Subject [37/54] [abbrv] [partial] airavata-django-portal git commit: Moving admin_view JS into django app and moving django project back
Date Thu, 21 Sep 2017 17:00:07 GMT
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/apache/airavata/model/status/ttypes.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/status/ttypes.py b/apache/airavata/model/status/ttypes.py
new file mode 100644
index 0000000..cd26873
--- /dev/null
+++ b/apache/airavata/model/status/ttypes.py
@@ -0,0 +1,645 @@
+#
+# 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 ExperimentState(object):
+    CREATED = 0
+    VALIDATED = 1
+    SCHEDULED = 2
+    LAUNCHED = 3
+    EXECUTING = 4
+    CANCELING = 5
+    CANCELED = 6
+    COMPLETED = 7
+    FAILED = 8
+
+    _VALUES_TO_NAMES = {
+        0: "CREATED",
+        1: "VALIDATED",
+        2: "SCHEDULED",
+        3: "LAUNCHED",
+        4: "EXECUTING",
+        5: "CANCELING",
+        6: "CANCELED",
+        7: "COMPLETED",
+        8: "FAILED",
+    }
+
+    _NAMES_TO_VALUES = {
+        "CREATED": 0,
+        "VALIDATED": 1,
+        "SCHEDULED": 2,
+        "LAUNCHED": 3,
+        "EXECUTING": 4,
+        "CANCELING": 5,
+        "CANCELED": 6,
+        "COMPLETED": 7,
+        "FAILED": 8,
+    }
+
+
+class TaskState(object):
+    CREATED = 0
+    EXECUTING = 1
+    COMPLETED = 2
+    FAILED = 3
+    CANCELED = 4
+
+    _VALUES_TO_NAMES = {
+        0: "CREATED",
+        1: "EXECUTING",
+        2: "COMPLETED",
+        3: "FAILED",
+        4: "CANCELED",
+    }
+
+    _NAMES_TO_VALUES = {
+        "CREATED": 0,
+        "EXECUTING": 1,
+        "COMPLETED": 2,
+        "FAILED": 3,
+        "CANCELED": 4,
+    }
+
+
+class ProcessState(object):
+    CREATED = 0
+    VALIDATED = 1
+    STARTED = 2
+    PRE_PROCESSING = 3
+    CONFIGURING_WORKSPACE = 4
+    INPUT_DATA_STAGING = 5
+    EXECUTING = 6
+    MONITORING = 7
+    OUTPUT_DATA_STAGING = 8
+    POST_PROCESSING = 9
+    COMPLETED = 10
+    FAILED = 11
+    CANCELLING = 12
+    CANCELED = 13
+
+    _VALUES_TO_NAMES = {
+        0: "CREATED",
+        1: "VALIDATED",
+        2: "STARTED",
+        3: "PRE_PROCESSING",
+        4: "CONFIGURING_WORKSPACE",
+        5: "INPUT_DATA_STAGING",
+        6: "EXECUTING",
+        7: "MONITORING",
+        8: "OUTPUT_DATA_STAGING",
+        9: "POST_PROCESSING",
+        10: "COMPLETED",
+        11: "FAILED",
+        12: "CANCELLING",
+        13: "CANCELED",
+    }
+
+    _NAMES_TO_VALUES = {
+        "CREATED": 0,
+        "VALIDATED": 1,
+        "STARTED": 2,
+        "PRE_PROCESSING": 3,
+        "CONFIGURING_WORKSPACE": 4,
+        "INPUT_DATA_STAGING": 5,
+        "EXECUTING": 6,
+        "MONITORING": 7,
+        "OUTPUT_DATA_STAGING": 8,
+        "POST_PROCESSING": 9,
+        "COMPLETED": 10,
+        "FAILED": 11,
+        "CANCELLING": 12,
+        "CANCELED": 13,
+    }
+
+
+class JobState(object):
+    SUBMITTED = 0
+    QUEUED = 1
+    ACTIVE = 2
+    COMPLETE = 3
+    CANCELED = 4
+    FAILED = 5
+    SUSPENDED = 6
+    UNKNOWN = 7
+
+    _VALUES_TO_NAMES = {
+        0: "SUBMITTED",
+        1: "QUEUED",
+        2: "ACTIVE",
+        3: "COMPLETE",
+        4: "CANCELED",
+        5: "FAILED",
+        6: "SUSPENDED",
+        7: "UNKNOWN",
+    }
+
+    _NAMES_TO_VALUES = {
+        "SUBMITTED": 0,
+        "QUEUED": 1,
+        "ACTIVE": 2,
+        "COMPLETE": 3,
+        "CANCELED": 4,
+        "FAILED": 5,
+        "SUSPENDED": 6,
+        "UNKNOWN": 7,
+    }
+
+
+class ExperimentStatus(object):
+    """
+    Status: A generic status object.
+
+    state:
+      State .
+
+    timeOfStateChange:
+      time the status was last updated.
+
+    reason:
+      User friendly reason on how the state is inferred.
+
+
+    Attributes:
+     - state
+     - timeOfStateChange
+     - reason
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.I32, 'state', None, None, ),  # 1
+        (2, TType.I64, 'timeOfStateChange', None, None, ),  # 2
+        (3, TType.STRING, 'reason', 'UTF8', None, ),  # 3
+    )
+
+    def __init__(self, state=None, timeOfStateChange=None, reason=None,):
+        self.state = state
+        self.timeOfStateChange = timeOfStateChange
+        self.reason = reason
+
+    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.state = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 2:
+                if ftype == TType.I64:
+                    self.timeOfStateChange = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.STRING:
+                    self.reason = 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('ExperimentStatus')
+        if self.state is not None:
+            oprot.writeFieldBegin('state', TType.I32, 1)
+            oprot.writeI32(self.state)
+            oprot.writeFieldEnd()
+        if self.timeOfStateChange is not None:
+            oprot.writeFieldBegin('timeOfStateChange', TType.I64, 2)
+            oprot.writeI64(self.timeOfStateChange)
+            oprot.writeFieldEnd()
+        if self.reason is not None:
+            oprot.writeFieldBegin('reason', TType.STRING, 3)
+            oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.state is None:
+            raise TProtocolException(message='Required field state 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 ProcessStatus(object):
+    """
+    Attributes:
+     - state
+     - timeOfStateChange
+     - reason
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.I32, 'state', None, None, ),  # 1
+        (2, TType.I64, 'timeOfStateChange', None, None, ),  # 2
+        (3, TType.STRING, 'reason', 'UTF8', None, ),  # 3
+    )
+
+    def __init__(self, state=None, timeOfStateChange=None, reason=None,):
+        self.state = state
+        self.timeOfStateChange = timeOfStateChange
+        self.reason = reason
+
+    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.state = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 2:
+                if ftype == TType.I64:
+                    self.timeOfStateChange = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.STRING:
+                    self.reason = 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('ProcessStatus')
+        if self.state is not None:
+            oprot.writeFieldBegin('state', TType.I32, 1)
+            oprot.writeI32(self.state)
+            oprot.writeFieldEnd()
+        if self.timeOfStateChange is not None:
+            oprot.writeFieldBegin('timeOfStateChange', TType.I64, 2)
+            oprot.writeI64(self.timeOfStateChange)
+            oprot.writeFieldEnd()
+        if self.reason is not None:
+            oprot.writeFieldBegin('reason', TType.STRING, 3)
+            oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.state is None:
+            raise TProtocolException(message='Required field state 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 TaskStatus(object):
+    """
+    Attributes:
+     - state
+     - timeOfStateChange
+     - reason
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.I32, 'state', None, None, ),  # 1
+        (2, TType.I64, 'timeOfStateChange', None, None, ),  # 2
+        (3, TType.STRING, 'reason', 'UTF8', None, ),  # 3
+    )
+
+    def __init__(self, state=None, timeOfStateChange=None, reason=None,):
+        self.state = state
+        self.timeOfStateChange = timeOfStateChange
+        self.reason = reason
+
+    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.state = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 2:
+                if ftype == TType.I64:
+                    self.timeOfStateChange = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.STRING:
+                    self.reason = 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('TaskStatus')
+        if self.state is not None:
+            oprot.writeFieldBegin('state', TType.I32, 1)
+            oprot.writeI32(self.state)
+            oprot.writeFieldEnd()
+        if self.timeOfStateChange is not None:
+            oprot.writeFieldBegin('timeOfStateChange', TType.I64, 2)
+            oprot.writeI64(self.timeOfStateChange)
+            oprot.writeFieldEnd()
+        if self.reason is not None:
+            oprot.writeFieldBegin('reason', TType.STRING, 3)
+            oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.state is None:
+            raise TProtocolException(message='Required field state 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 JobStatus(object):
+    """
+    Attributes:
+     - jobState
+     - timeOfStateChange
+     - reason
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.I32, 'jobState', None, None, ),  # 1
+        (2, TType.I64, 'timeOfStateChange', None, None, ),  # 2
+        (3, TType.STRING, 'reason', 'UTF8', None, ),  # 3
+    )
+
+    def __init__(self, jobState=None, timeOfStateChange=None, reason=None,):
+        self.jobState = jobState
+        self.timeOfStateChange = timeOfStateChange
+        self.reason = reason
+
+    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.jobState = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 2:
+                if ftype == TType.I64:
+                    self.timeOfStateChange = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.STRING:
+                    self.reason = 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('JobStatus')
+        if self.jobState is not None:
+            oprot.writeFieldBegin('jobState', TType.I32, 1)
+            oprot.writeI32(self.jobState)
+            oprot.writeFieldEnd()
+        if self.timeOfStateChange is not None:
+            oprot.writeFieldBegin('timeOfStateChange', TType.I64, 2)
+            oprot.writeI64(self.timeOfStateChange)
+            oprot.writeFieldEnd()
+        if self.reason is not None:
+            oprot.writeFieldBegin('reason', TType.STRING, 3)
+            oprot.writeString(self.reason.encode('utf-8') if sys.version_info[0] == 2 else self.reason)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.jobState is None:
+            raise TProtocolException(message='Required field jobState 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 QueueStatusModel(object):
+    """
+    Attributes:
+     - hostName
+     - queueName
+     - queueUp
+     - runningJobs
+     - queuedJobs
+     - time
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.STRING, 'hostName', 'UTF8', None, ),  # 1
+        (2, TType.STRING, 'queueName', 'UTF8', None, ),  # 2
+        (3, TType.BOOL, 'queueUp', None, None, ),  # 3
+        (4, TType.I32, 'runningJobs', None, None, ),  # 4
+        (5, TType.I32, 'queuedJobs', None, None, ),  # 5
+        (6, TType.I64, 'time', None, None, ),  # 6
+    )
+
+    def __init__(self, hostName=None, queueName=None, queueUp=None, runningJobs=None, queuedJobs=None, time=None,):
+        self.hostName = hostName
+        self.queueName = queueName
+        self.queueUp = queueUp
+        self.runningJobs = runningJobs
+        self.queuedJobs = queuedJobs
+        self.time = time
+
+    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.hostName = 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.queueName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.BOOL:
+                    self.queueUp = iprot.readBool()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 4:
+                if ftype == TType.I32:
+                    self.runningJobs = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 5:
+                if ftype == TType.I32:
+                    self.queuedJobs = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 6:
+                if ftype == TType.I64:
+                    self.time = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            else:
+                iprot.skip(ftype)
+            iprot.readFieldEnd()
+        iprot.readStructEnd()
+
+    def write(self, oprot):
+        if oprot._fast_encode is not None and self.thrift_spec is not None:
+            oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
+            return
+        oprot.writeStructBegin('QueueStatusModel')
+        if self.hostName is not None:
+            oprot.writeFieldBegin('hostName', TType.STRING, 1)
+            oprot.writeString(self.hostName.encode('utf-8') if sys.version_info[0] == 2 else self.hostName)
+            oprot.writeFieldEnd()
+        if self.queueName is not None:
+            oprot.writeFieldBegin('queueName', TType.STRING, 2)
+            oprot.writeString(self.queueName.encode('utf-8') if sys.version_info[0] == 2 else self.queueName)
+            oprot.writeFieldEnd()
+        if self.queueUp is not None:
+            oprot.writeFieldBegin('queueUp', TType.BOOL, 3)
+            oprot.writeBool(self.queueUp)
+            oprot.writeFieldEnd()
+        if self.runningJobs is not None:
+            oprot.writeFieldBegin('runningJobs', TType.I32, 4)
+            oprot.writeI32(self.runningJobs)
+            oprot.writeFieldEnd()
+        if self.queuedJobs is not None:
+            oprot.writeFieldBegin('queuedJobs', TType.I32, 5)
+            oprot.writeI32(self.queuedJobs)
+            oprot.writeFieldEnd()
+        if self.time is not None:
+            oprot.writeFieldBegin('time', TType.I64, 6)
+            oprot.writeI64(self.time)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.hostName is None:
+            raise TProtocolException(message='Required field hostName is unset!')
+        if self.queueName is None:
+            raise TProtocolException(message='Required field queueName is unset!')
+        if self.queueUp is None:
+            raise TProtocolException(message='Required field queueUp is unset!')
+        if self.runningJobs is None:
+            raise TProtocolException(message='Required field runningJobs is unset!')
+        if self.queuedJobs is None:
+            raise TProtocolException(message='Required field queuedJobs is unset!')
+        if self.time is None:
+            raise TProtocolException(message='Required field time 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/apache/airavata/model/task/__init__.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/task/__init__.py b/apache/airavata/model/task/__init__.py
new file mode 100644
index 0000000..adefd8e
--- /dev/null
+++ b/apache/airavata/model/task/__init__.py
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants']

http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/apache/airavata/model/task/constants.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/task/constants.py b/apache/airavata/model/task/constants.py
new file mode 100644
index 0000000..eb0d35a
--- /dev/null
+++ b/apache/airavata/model/task/constants.py
@@ -0,0 +1,12 @@
+#
+# 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/apache/airavata/model/task/ttypes.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/task/ttypes.py b/apache/airavata/model/task/ttypes.py
new file mode 100644
index 0000000..0163b1f
--- /dev/null
+++ b/apache/airavata/model/task/ttypes.py
@@ -0,0 +1,671 @@
+#
+# 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
+import apache.airavata.model.appcatalog.computeresource.ttypes
+import apache.airavata.model.data.movement.ttypes
+import apache.airavata.model.application.io.ttypes
+import apache.airavata.model.status.ttypes
+import apache.airavata.model.job.ttypes
+
+from thrift.transport import TTransport
+
+
+class TaskTypes(object):
+    """
+    TaskTypes: An enumerated list of TaskTypes. Task being generic, the task type will provide the concrete interpretation.
+
+    """
+    ENV_SETUP = 0
+    DATA_STAGING = 1
+    JOB_SUBMISSION = 2
+    ENV_CLEANUP = 3
+    MONITORING = 4
+    OUTPUT_FETCHING = 5
+
+    _VALUES_TO_NAMES = {
+        0: "ENV_SETUP",
+        1: "DATA_STAGING",
+        2: "JOB_SUBMISSION",
+        3: "ENV_CLEANUP",
+        4: "MONITORING",
+        5: "OUTPUT_FETCHING",
+    }
+
+    _NAMES_TO_VALUES = {
+        "ENV_SETUP": 0,
+        "DATA_STAGING": 1,
+        "JOB_SUBMISSION": 2,
+        "ENV_CLEANUP": 3,
+        "MONITORING": 4,
+        "OUTPUT_FETCHING": 5,
+    }
+
+
+class DataStageType(object):
+    """
+    DataStagingTaskModel: A structure holding the data staging task details.
+
+    Source and Destination locations includes standard representation of protocol, host, port and path
+      A friendly description of the task, usally used to communicate information to users.
+
+    """
+    INPUT = 0
+    OUPUT = 1
+    ARCHIVE_OUTPUT = 2
+
+    _VALUES_TO_NAMES = {
+        0: "INPUT",
+        1: "OUPUT",
+        2: "ARCHIVE_OUTPUT",
+    }
+
+    _NAMES_TO_VALUES = {
+        "INPUT": 0,
+        "OUPUT": 1,
+        "ARCHIVE_OUTPUT": 2,
+    }
+
+
+class TaskModel(object):
+    """
+    TaskModel: A structure holding the generic task details.
+
+    taskDetail:
+      A friendly description of the task, usally used to communicate information to users.
+
+    subTaskModel:
+      A generic byte object for the Task developer to store internal serialized data into registry catalogs.
+
+    Attributes:
+     - taskId
+     - taskType
+     - parentProcessId
+     - creationTime
+     - lastUpdateTime
+     - taskStatuses
+     - taskDetail
+     - subTaskModel
+     - taskErrors
+     - jobs
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.STRING, 'taskId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ),  # 1
+        (2, TType.I32, 'taskType', None, None, ),  # 2
+        (3, TType.STRING, 'parentProcessId', 'UTF8', None, ),  # 3
+        (4, TType.I64, 'creationTime', None, None, ),  # 4
+        (5, TType.I64, 'lastUpdateTime', None, None, ),  # 5
+        (6, TType.LIST, 'taskStatuses', (TType.STRUCT, (apache.airavata.model.status.ttypes.TaskStatus, apache.airavata.model.status.ttypes.TaskStatus.thrift_spec), False), None, ),  # 6
+        (7, TType.STRING, 'taskDetail', 'UTF8', None, ),  # 7
+        (8, TType.STRING, 'subTaskModel', 'BINARY', None, ),  # 8
+        (9, TType.LIST, 'taskErrors', (TType.STRUCT, (apache.airavata.model.commons.ttypes.ErrorModel, apache.airavata.model.commons.ttypes.ErrorModel.thrift_spec), False), None, ),  # 9
+        (10, TType.LIST, 'jobs', (TType.STRUCT, (apache.airavata.model.job.ttypes.JobModel, apache.airavata.model.job.ttypes.JobModel.thrift_spec), False), None, ),  # 10
+    )
+
+    def __init__(self, taskId=thrift_spec[1][4], taskType=None, parentProcessId=None, creationTime=None, lastUpdateTime=None, taskStatuses=None, taskDetail=None, subTaskModel=None, taskErrors=None, jobs=None,):
+        self.taskId = taskId
+        self.taskType = taskType
+        self.parentProcessId = parentProcessId
+        self.creationTime = creationTime
+        self.lastUpdateTime = lastUpdateTime
+        self.taskStatuses = taskStatuses
+        self.taskDetail = taskDetail
+        self.subTaskModel = subTaskModel
+        self.taskErrors = taskErrors
+        self.jobs = jobs
+
+    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.taskId = 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.taskType = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.STRING:
+                    self.parentProcessId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 4:
+                if ftype == TType.I64:
+                    self.creationTime = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 5:
+                if ftype == TType.I64:
+                    self.lastUpdateTime = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 6:
+                if ftype == TType.LIST:
+                    self.taskStatuses = []
+                    (_etype3, _size0) = iprot.readListBegin()
+                    for _i4 in range(_size0):
+                        _elem5 = apache.airavata.model.status.ttypes.TaskStatus()
+                        _elem5.read(iprot)
+                        self.taskStatuses.append(_elem5)
+                    iprot.readListEnd()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 7:
+                if ftype == TType.STRING:
+                    self.taskDetail = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 8:
+                if ftype == TType.STRING:
+                    self.subTaskModel = iprot.readBinary()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 9:
+                if ftype == TType.LIST:
+                    self.taskErrors = []
+                    (_etype9, _size6) = iprot.readListBegin()
+                    for _i10 in range(_size6):
+                        _elem11 = apache.airavata.model.commons.ttypes.ErrorModel()
+                        _elem11.read(iprot)
+                        self.taskErrors.append(_elem11)
+                    iprot.readListEnd()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 10:
+                if ftype == TType.LIST:
+                    self.jobs = []
+                    (_etype15, _size12) = iprot.readListBegin()
+                    for _i16 in range(_size12):
+                        _elem17 = apache.airavata.model.job.ttypes.JobModel()
+                        _elem17.read(iprot)
+                        self.jobs.append(_elem17)
+                    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('TaskModel')
+        if self.taskId is not None:
+            oprot.writeFieldBegin('taskId', TType.STRING, 1)
+            oprot.writeString(self.taskId.encode('utf-8') if sys.version_info[0] == 2 else self.taskId)
+            oprot.writeFieldEnd()
+        if self.taskType is not None:
+            oprot.writeFieldBegin('taskType', TType.I32, 2)
+            oprot.writeI32(self.taskType)
+            oprot.writeFieldEnd()
+        if self.parentProcessId is not None:
+            oprot.writeFieldBegin('parentProcessId', TType.STRING, 3)
+            oprot.writeString(self.parentProcessId.encode('utf-8') if sys.version_info[0] == 2 else self.parentProcessId)
+            oprot.writeFieldEnd()
+        if self.creationTime is not None:
+            oprot.writeFieldBegin('creationTime', TType.I64, 4)
+            oprot.writeI64(self.creationTime)
+            oprot.writeFieldEnd()
+        if self.lastUpdateTime is not None:
+            oprot.writeFieldBegin('lastUpdateTime', TType.I64, 5)
+            oprot.writeI64(self.lastUpdateTime)
+            oprot.writeFieldEnd()
+        if self.taskStatuses is not None:
+            oprot.writeFieldBegin('taskStatuses', TType.LIST, 6)
+            oprot.writeListBegin(TType.STRUCT, len(self.taskStatuses))
+            for iter18 in self.taskStatuses:
+                iter18.write(oprot)
+            oprot.writeListEnd()
+            oprot.writeFieldEnd()
+        if self.taskDetail is not None:
+            oprot.writeFieldBegin('taskDetail', TType.STRING, 7)
+            oprot.writeString(self.taskDetail.encode('utf-8') if sys.version_info[0] == 2 else self.taskDetail)
+            oprot.writeFieldEnd()
+        if self.subTaskModel is not None:
+            oprot.writeFieldBegin('subTaskModel', TType.STRING, 8)
+            oprot.writeBinary(self.subTaskModel)
+            oprot.writeFieldEnd()
+        if self.taskErrors is not None:
+            oprot.writeFieldBegin('taskErrors', TType.LIST, 9)
+            oprot.writeListBegin(TType.STRUCT, len(self.taskErrors))
+            for iter19 in self.taskErrors:
+                iter19.write(oprot)
+            oprot.writeListEnd()
+            oprot.writeFieldEnd()
+        if self.jobs is not None:
+            oprot.writeFieldBegin('jobs', TType.LIST, 10)
+            oprot.writeListBegin(TType.STRUCT, len(self.jobs))
+            for iter20 in self.jobs:
+                iter20.write(oprot)
+            oprot.writeListEnd()
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.taskId is None:
+            raise TProtocolException(message='Required field taskId is unset!')
+        if self.taskType is None:
+            raise TProtocolException(message='Required field taskType is unset!')
+        if self.parentProcessId is None:
+            raise TProtocolException(message='Required field parentProcessId is unset!')
+        if self.creationTime is None:
+            raise TProtocolException(message='Required field creationTime is unset!')
+        if self.lastUpdateTime is None:
+            raise TProtocolException(message='Required field lastUpdateTime is unset!')
+        if self.taskStatuses is None:
+            raise TProtocolException(message='Required field taskStatuses 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 DataStagingTaskModel(object):
+    """
+    Attributes:
+     - source
+     - destination
+     - type
+     - transferStartTime
+     - transferEndTime
+     - transferRate
+     - processInput
+     - processOutput
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.STRING, 'source', 'UTF8', None, ),  # 1
+        (2, TType.STRING, 'destination', 'UTF8', None, ),  # 2
+        (3, TType.I32, 'type', None, None, ),  # 3
+        (4, TType.I64, 'transferStartTime', None, None, ),  # 4
+        (5, TType.I64, 'transferEndTime', None, None, ),  # 5
+        (6, TType.STRING, 'transferRate', 'UTF8', None, ),  # 6
+        (7, TType.STRUCT, 'processInput', (apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.thrift_spec), None, ),  # 7
+        (8, TType.STRUCT, 'processOutput', (apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec), None, ),  # 8
+    )
+
+    def __init__(self, source=None, destination=None, type=None, transferStartTime=None, transferEndTime=None, transferRate=None, processInput=None, processOutput=None,):
+        self.source = source
+        self.destination = destination
+        self.type = type
+        self.transferStartTime = transferStartTime
+        self.transferEndTime = transferEndTime
+        self.transferRate = transferRate
+        self.processInput = processInput
+        self.processOutput = processOutput
+
+    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.source = 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.destination = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.I32:
+                    self.type = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 4:
+                if ftype == TType.I64:
+                    self.transferStartTime = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 5:
+                if ftype == TType.I64:
+                    self.transferEndTime = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 6:
+                if ftype == TType.STRING:
+                    self.transferRate = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 7:
+                if ftype == TType.STRUCT:
+                    self.processInput = apache.airavata.model.application.io.ttypes.InputDataObjectType()
+                    self.processInput.read(iprot)
+                else:
+                    iprot.skip(ftype)
+            elif fid == 8:
+                if ftype == TType.STRUCT:
+                    self.processOutput = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
+                    self.processOutput.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('DataStagingTaskModel')
+        if self.source is not None:
+            oprot.writeFieldBegin('source', TType.STRING, 1)
+            oprot.writeString(self.source.encode('utf-8') if sys.version_info[0] == 2 else self.source)
+            oprot.writeFieldEnd()
+        if self.destination is not None:
+            oprot.writeFieldBegin('destination', TType.STRING, 2)
+            oprot.writeString(self.destination.encode('utf-8') if sys.version_info[0] == 2 else self.destination)
+            oprot.writeFieldEnd()
+        if self.type is not None:
+            oprot.writeFieldBegin('type', TType.I32, 3)
+            oprot.writeI32(self.type)
+            oprot.writeFieldEnd()
+        if self.transferStartTime is not None:
+            oprot.writeFieldBegin('transferStartTime', TType.I64, 4)
+            oprot.writeI64(self.transferStartTime)
+            oprot.writeFieldEnd()
+        if self.transferEndTime is not None:
+            oprot.writeFieldBegin('transferEndTime', TType.I64, 5)
+            oprot.writeI64(self.transferEndTime)
+            oprot.writeFieldEnd()
+        if self.transferRate is not None:
+            oprot.writeFieldBegin('transferRate', TType.STRING, 6)
+            oprot.writeString(self.transferRate.encode('utf-8') if sys.version_info[0] == 2 else self.transferRate)
+            oprot.writeFieldEnd()
+        if self.processInput is not None:
+            oprot.writeFieldBegin('processInput', TType.STRUCT, 7)
+            self.processInput.write(oprot)
+            oprot.writeFieldEnd()
+        if self.processOutput is not None:
+            oprot.writeFieldBegin('processOutput', TType.STRUCT, 8)
+            self.processOutput.write(oprot)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.source is None:
+            raise TProtocolException(message='Required field source is unset!')
+        if self.destination is None:
+            raise TProtocolException(message='Required field destination is unset!')
+        if self.type is None:
+            raise TProtocolException(message='Required field type 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 EnvironmentSetupTaskModel(object):
+    """
+    EnvironmentSetupTaskModel: A structure holding the environment creation task details
+
+
+    Attributes:
+     - location
+     - protocol
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.STRING, 'location', 'UTF8', None, ),  # 1
+        (2, TType.I32, 'protocol', None, None, ),  # 2
+    )
+
+    def __init__(self, location=None, protocol=None,):
+        self.location = location
+        self.protocol = protocol
+
+    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.location = 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.protocol = 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('EnvironmentSetupTaskModel')
+        if self.location is not None:
+            oprot.writeFieldBegin('location', TType.STRING, 1)
+            oprot.writeString(self.location.encode('utf-8') if sys.version_info[0] == 2 else self.location)
+            oprot.writeFieldEnd()
+        if self.protocol is not None:
+            oprot.writeFieldBegin('protocol', TType.I32, 2)
+            oprot.writeI32(self.protocol)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.location is None:
+            raise TProtocolException(message='Required field location is unset!')
+        if self.protocol is None:
+            raise TProtocolException(message='Required field protocol 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 JobSubmissionTaskModel(object):
+    """
+    Attributes:
+     - jobSubmissionProtocol
+     - monitorMode
+     - wallTime
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.I32, 'jobSubmissionProtocol', None, None, ),  # 1
+        (2, TType.I32, 'monitorMode', None, None, ),  # 2
+        (3, TType.I32, 'wallTime', None, None, ),  # 3
+    )
+
+    def __init__(self, jobSubmissionProtocol=None, monitorMode=None, wallTime=None,):
+        self.jobSubmissionProtocol = jobSubmissionProtocol
+        self.monitorMode = monitorMode
+        self.wallTime = wallTime
+
+    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.jobSubmissionProtocol = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 2:
+                if ftype == TType.I32:
+                    self.monitorMode = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.I32:
+                    self.wallTime = 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('JobSubmissionTaskModel')
+        if self.jobSubmissionProtocol is not None:
+            oprot.writeFieldBegin('jobSubmissionProtocol', TType.I32, 1)
+            oprot.writeI32(self.jobSubmissionProtocol)
+            oprot.writeFieldEnd()
+        if self.monitorMode is not None:
+            oprot.writeFieldBegin('monitorMode', TType.I32, 2)
+            oprot.writeI32(self.monitorMode)
+            oprot.writeFieldEnd()
+        if self.wallTime is not None:
+            oprot.writeFieldBegin('wallTime', TType.I32, 3)
+            oprot.writeI32(self.wallTime)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.jobSubmissionProtocol is None:
+            raise TProtocolException(message='Required field jobSubmissionProtocol is unset!')
+        if self.monitorMode is None:
+            raise TProtocolException(message='Required field monitorMode 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 MonitorTaskModel(object):
+    """
+    Attributes:
+     - monitorMode
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.I32, 'monitorMode', None, None, ),  # 1
+    )
+
+    def __init__(self, monitorMode=None,):
+        self.monitorMode = monitorMode
+
+    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.monitorMode = 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('MonitorTaskModel')
+        if self.monitorMode is not None:
+            oprot.writeFieldBegin('monitorMode', TType.I32, 1)
+            oprot.writeI32(self.monitorMode)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.monitorMode is None:
+            raise TProtocolException(message='Required field monitorMode 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/apache/airavata/model/tenant/__init__.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/tenant/__init__.py b/apache/airavata/model/tenant/__init__.py
new file mode 100644
index 0000000..adefd8e
--- /dev/null
+++ b/apache/airavata/model/tenant/__init__.py
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants']

http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/apache/airavata/model/tenant/constants.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/tenant/constants.py b/apache/airavata/model/tenant/constants.py
new file mode 100644
index 0000000..eb0d35a
--- /dev/null
+++ b/apache/airavata/model/tenant/constants.py
@@ -0,0 +1,12 @@
+#
+# 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/apache/airavata/model/tenant/ttypes.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/tenant/ttypes.py b/apache/airavata/model/tenant/ttypes.py
new file mode 100644
index 0000000..0f42429
--- /dev/null
+++ b/apache/airavata/model/tenant/ttypes.py
@@ -0,0 +1,452 @@
+#
+# 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 TenantApprovalStatus(object):
+    REQUESTED = 0
+    APPROVED = 1
+    ACTIVE = 2
+    DEACTIVATED = 3
+    CANCELLED = 4
+    DENIED = 5
+    CREATED = 6
+    DEPLOYED = 7
+
+    _VALUES_TO_NAMES = {
+        0: "REQUESTED",
+        1: "APPROVED",
+        2: "ACTIVE",
+        3: "DEACTIVATED",
+        4: "CANCELLED",
+        5: "DENIED",
+        6: "CREATED",
+        7: "DEPLOYED",
+    }
+
+    _NAMES_TO_VALUES = {
+        "REQUESTED": 0,
+        "APPROVED": 1,
+        "ACTIVE": 2,
+        "DEACTIVATED": 3,
+        "CANCELLED": 4,
+        "DENIED": 5,
+        "CREATED": 6,
+        "DEPLOYED": 7,
+    }
+
+
+class TenantPreferences(object):
+    """
+    Attributes:
+     - tenantAdminFirstName
+     - tenantAdminLastName
+     - tenantAdminEmail
+    """
+
+    thrift_spec = (
+        None,  # 0
+        None,  # 1
+        None,  # 2
+        None,  # 3
+        None,  # 4
+        None,  # 5
+        None,  # 6
+        None,  # 7
+        None,  # 8
+        None,  # 9
+        (10, TType.STRING, 'tenantAdminFirstName', 'UTF8', None, ),  # 10
+        (11, TType.STRING, 'tenantAdminLastName', 'UTF8', None, ),  # 11
+        (12, TType.STRING, 'tenantAdminEmail', 'UTF8', None, ),  # 12
+    )
+
+    def __init__(self, tenantAdminFirstName=None, tenantAdminLastName=None, tenantAdminEmail=None,):
+        self.tenantAdminFirstName = tenantAdminFirstName
+        self.tenantAdminLastName = tenantAdminLastName
+        self.tenantAdminEmail = tenantAdminEmail
+
+    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 == 10:
+                if ftype == TType.STRING:
+                    self.tenantAdminFirstName = 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.tenantAdminLastName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 12:
+                if ftype == TType.STRING:
+                    self.tenantAdminEmail = 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('TenantPreferences')
+        if self.tenantAdminFirstName is not None:
+            oprot.writeFieldBegin('tenantAdminFirstName', TType.STRING, 10)
+            oprot.writeString(self.tenantAdminFirstName.encode('utf-8') if sys.version_info[0] == 2 else self.tenantAdminFirstName)
+            oprot.writeFieldEnd()
+        if self.tenantAdminLastName is not None:
+            oprot.writeFieldBegin('tenantAdminLastName', TType.STRING, 11)
+            oprot.writeString(self.tenantAdminLastName.encode('utf-8') if sys.version_info[0] == 2 else self.tenantAdminLastName)
+            oprot.writeFieldEnd()
+        if self.tenantAdminEmail is not None:
+            oprot.writeFieldBegin('tenantAdminEmail', TType.STRING, 12)
+            oprot.writeString(self.tenantAdminEmail.encode('utf-8') if sys.version_info[0] == 2 else self.tenantAdminEmail)
+            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 TenantConfig(object):
+    """
+    Attributes:
+     - oauthClientId
+     - oauthClientSecret
+     - identityServerUserName
+     - identityServerPasswordToken
+    """
+
+    thrift_spec = (
+        None,  # 0
+        None,  # 1
+        None,  # 2
+        None,  # 3
+        None,  # 4
+        None,  # 5
+        None,  # 6
+        None,  # 7
+        None,  # 8
+        None,  # 9
+        None,  # 10
+        None,  # 11
+        None,  # 12
+        (13, TType.STRING, 'identityServerUserName', 'UTF8', None, ),  # 13
+        (14, TType.STRING, 'identityServerPasswordToken', 'UTF8', None, ),  # 14
+        None,  # 15
+        (16, TType.STRING, 'oauthClientId', 'UTF8', None, ),  # 16
+        (17, TType.STRING, 'oauthClientSecret', 'UTF8', None, ),  # 17
+    )
+
+    def __init__(self, oauthClientId=None, oauthClientSecret=None, identityServerUserName=None, identityServerPasswordToken=None,):
+        self.oauthClientId = oauthClientId
+        self.oauthClientSecret = oauthClientSecret
+        self.identityServerUserName = identityServerUserName
+        self.identityServerPasswordToken = identityServerPasswordToken
+
+    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 == 16:
+                if ftype == TType.STRING:
+                    self.oauthClientId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 17:
+                if ftype == TType.STRING:
+                    self.oauthClientSecret = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 13:
+                if ftype == TType.STRING:
+                    self.identityServerUserName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 14:
+                if ftype == TType.STRING:
+                    self.identityServerPasswordToken = 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('TenantConfig')
+        if self.identityServerUserName is not None:
+            oprot.writeFieldBegin('identityServerUserName', TType.STRING, 13)
+            oprot.writeString(self.identityServerUserName.encode('utf-8') if sys.version_info[0] == 2 else self.identityServerUserName)
+            oprot.writeFieldEnd()
+        if self.identityServerPasswordToken is not None:
+            oprot.writeFieldBegin('identityServerPasswordToken', TType.STRING, 14)
+            oprot.writeString(self.identityServerPasswordToken.encode('utf-8') if sys.version_info[0] == 2 else self.identityServerPasswordToken)
+            oprot.writeFieldEnd()
+        if self.oauthClientId is not None:
+            oprot.writeFieldBegin('oauthClientId', TType.STRING, 16)
+            oprot.writeString(self.oauthClientId.encode('utf-8') if sys.version_info[0] == 2 else self.oauthClientId)
+            oprot.writeFieldEnd()
+        if self.oauthClientSecret is not None:
+            oprot.writeFieldBegin('oauthClientSecret', TType.STRING, 17)
+            oprot.writeString(self.oauthClientSecret.encode('utf-8') if sys.version_info[0] == 2 else self.oauthClientSecret)
+            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 Tenant(object):
+    """
+    Attributes:
+     - tenantId
+     - tenantApprovalStatus
+     - tenantName
+     - domain
+     - emailAddress
+     - tenantAcronym
+     - tenantURL
+     - tenantPublicAbstract
+     - reviewProposalDescription
+     - declinedReason
+     - requestCreationTime
+     - requesterUsername
+    """
+
+    thrift_spec = (
+        None,  # 0
+        (1, TType.STRING, 'tenantId', 'UTF8', None, ),  # 1
+        (2, TType.I32, 'tenantApprovalStatus', None, None, ),  # 2
+        (3, TType.STRING, 'tenantName', 'UTF8', None, ),  # 3
+        (4, TType.STRING, 'domain', 'UTF8', None, ),  # 4
+        (5, TType.STRING, 'emailAddress', 'UTF8', None, ),  # 5
+        (6, TType.STRING, 'tenantAcronym', 'UTF8', None, ),  # 6
+        (7, TType.STRING, 'tenantURL', 'UTF8', None, ),  # 7
+        (8, TType.STRING, 'tenantPublicAbstract', 'UTF8', None, ),  # 8
+        (9, TType.STRING, 'reviewProposalDescription', 'UTF8', None, ),  # 9
+        None,  # 10
+        None,  # 11
+        None,  # 12
+        None,  # 13
+        None,  # 14
+        (15, TType.STRING, 'declinedReason', 'UTF8', None, ),  # 15
+        None,  # 16
+        None,  # 17
+        (18, TType.I64, 'requestCreationTime', None, None, ),  # 18
+        (19, TType.STRING, 'requesterUsername', 'UTF8', None, ),  # 19
+    )
+
+    def __init__(self, tenantId=None, tenantApprovalStatus=None, tenantName=None, domain=None, emailAddress=None, tenantAcronym=None, tenantURL=None, tenantPublicAbstract=None, reviewProposalDescription=None, declinedReason=None, requestCreationTime=None, requesterUsername=None,):
+        self.tenantId = tenantId
+        self.tenantApprovalStatus = tenantApprovalStatus
+        self.tenantName = tenantName
+        self.domain = domain
+        self.emailAddress = emailAddress
+        self.tenantAcronym = tenantAcronym
+        self.tenantURL = tenantURL
+        self.tenantPublicAbstract = tenantPublicAbstract
+        self.reviewProposalDescription = reviewProposalDescription
+        self.declinedReason = declinedReason
+        self.requestCreationTime = requestCreationTime
+        self.requesterUsername = requesterUsername
+
+    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.tenantId = 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.tenantApprovalStatus = iprot.readI32()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 3:
+                if ftype == TType.STRING:
+                    self.tenantName = 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.domain = 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.emailAddress = 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.tenantAcronym = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 7:
+                if ftype == TType.STRING:
+                    self.tenantURL = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 8:
+                if ftype == TType.STRING:
+                    self.tenantPublicAbstract = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 9:
+                if ftype == TType.STRING:
+                    self.reviewProposalDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 15:
+                if ftype == TType.STRING:
+                    self.declinedReason = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 18:
+                if ftype == TType.I64:
+                    self.requestCreationTime = iprot.readI64()
+                else:
+                    iprot.skip(ftype)
+            elif fid == 19:
+                if ftype == TType.STRING:
+                    self.requesterUsername = 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('Tenant')
+        if self.tenantId is not None:
+            oprot.writeFieldBegin('tenantId', TType.STRING, 1)
+            oprot.writeString(self.tenantId.encode('utf-8') if sys.version_info[0] == 2 else self.tenantId)
+            oprot.writeFieldEnd()
+        if self.tenantApprovalStatus is not None:
+            oprot.writeFieldBegin('tenantApprovalStatus', TType.I32, 2)
+            oprot.writeI32(self.tenantApprovalStatus)
+            oprot.writeFieldEnd()
+        if self.tenantName is not None:
+            oprot.writeFieldBegin('tenantName', TType.STRING, 3)
+            oprot.writeString(self.tenantName.encode('utf-8') if sys.version_info[0] == 2 else self.tenantName)
+            oprot.writeFieldEnd()
+        if self.domain is not None:
+            oprot.writeFieldBegin('domain', TType.STRING, 4)
+            oprot.writeString(self.domain.encode('utf-8') if sys.version_info[0] == 2 else self.domain)
+            oprot.writeFieldEnd()
+        if self.emailAddress is not None:
+            oprot.writeFieldBegin('emailAddress', TType.STRING, 5)
+            oprot.writeString(self.emailAddress.encode('utf-8') if sys.version_info[0] == 2 else self.emailAddress)
+            oprot.writeFieldEnd()
+        if self.tenantAcronym is not None:
+            oprot.writeFieldBegin('tenantAcronym', TType.STRING, 6)
+            oprot.writeString(self.tenantAcronym.encode('utf-8') if sys.version_info[0] == 2 else self.tenantAcronym)
+            oprot.writeFieldEnd()
+        if self.tenantURL is not None:
+            oprot.writeFieldBegin('tenantURL', TType.STRING, 7)
+            oprot.writeString(self.tenantURL.encode('utf-8') if sys.version_info[0] == 2 else self.tenantURL)
+            oprot.writeFieldEnd()
+        if self.tenantPublicAbstract is not None:
+            oprot.writeFieldBegin('tenantPublicAbstract', TType.STRING, 8)
+            oprot.writeString(self.tenantPublicAbstract.encode('utf-8') if sys.version_info[0] == 2 else self.tenantPublicAbstract)
+            oprot.writeFieldEnd()
+        if self.reviewProposalDescription is not None:
+            oprot.writeFieldBegin('reviewProposalDescription', TType.STRING, 9)
+            oprot.writeString(self.reviewProposalDescription.encode('utf-8') if sys.version_info[0] == 2 else self.reviewProposalDescription)
+            oprot.writeFieldEnd()
+        if self.declinedReason is not None:
+            oprot.writeFieldBegin('declinedReason', TType.STRING, 15)
+            oprot.writeString(self.declinedReason.encode('utf-8') if sys.version_info[0] == 2 else self.declinedReason)
+            oprot.writeFieldEnd()
+        if self.requestCreationTime is not None:
+            oprot.writeFieldBegin('requestCreationTime', TType.I64, 18)
+            oprot.writeI64(self.requestCreationTime)
+            oprot.writeFieldEnd()
+        if self.requesterUsername is not None:
+            oprot.writeFieldBegin('requesterUsername', TType.STRING, 19)
+            oprot.writeString(self.requesterUsername.encode('utf-8') if sys.version_info[0] == 2 else self.requesterUsername)
+            oprot.writeFieldEnd()
+        oprot.writeFieldStop()
+        oprot.writeStructEnd()
+
+    def validate(self):
+        if self.tenantId is None:
+            raise TProtocolException(message='Required field tenantId is unset!')
+        if self.tenantApprovalStatus is None:
+            raise TProtocolException(message='Required field tenantApprovalStatus 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/apache/airavata/model/ttypes.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/ttypes.py b/apache/airavata/model/ttypes.py
new file mode 100644
index 0000000..b77af5f
--- /dev/null
+++ b/apache/airavata/model/ttypes.py
@@ -0,0 +1,31 @@
+#
+# 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
+import apache.airavata.model.workspace.ttypes
+import apache.airavata.api.error.ttypes
+import apache.airavata.model.messaging.event.ttypes
+import apache.airavata.model.security.ttypes
+import apache.airavata.model.dbevent.ttypes
+import apache.airavata.model.experiment.ttypes
+import apache.airavata.model.job.ttypes
+import apache.airavata.model.task.ttypes
+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.replica.ttypes
+import apache.airavata.model.user.ttypes
+import apache.airavata.model.group.ttypes
+import apache.airavata.model.tenant.ttypes
+import credential_store_data_models.ttypes
+
+from thrift.transport import TTransport

http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/apache/airavata/model/user/__init__.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/user/__init__.py b/apache/airavata/model/user/__init__.py
new file mode 100644
index 0000000..adefd8e
--- /dev/null
+++ b/apache/airavata/model/user/__init__.py
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants']

http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/apache/airavata/model/user/constants.py
----------------------------------------------------------------------
diff --git a/apache/airavata/model/user/constants.py b/apache/airavata/model/user/constants.py
new file mode 100644
index 0000000..fcc6e7c
--- /dev/null
+++ b/apache/airavata/model/user/constants.py
@@ -0,0 +1,13 @@
+#
+# 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 *
+USER_PROFILE_VERSION = "1.0"


Mime
View raw message