airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From machris...@apache.org
Subject [12/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 16:59:42 GMT
http://git-wip-us.apache.org/repos/asf/airavata-django-portal/blob/d8d7c37a/django_portal/apache/airavata/model/messaging/event/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/messaging/event/ttypes.py b/django_portal/apache/airavata/model/messaging/event/ttypes.py
deleted file mode 100644
index a5224ec..0000000
--- a/django_portal/apache/airavata/model/messaging/event/ttypes.py
+++ /dev/null
@@ -1,1407 +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.status.ttypes
-import apache.airavata.model.application.io.ttypes
-import apache.airavata.model.commons.ttypes
-
-from thrift.transport import TTransport
-
-
-class MessageLevel(object):
-    INFO = 0
-    DEBUG = 1
-    ERROR = 2
-    ACK = 3
-
-    _VALUES_TO_NAMES = {
-        0: "INFO",
-        1: "DEBUG",
-        2: "ERROR",
-        3: "ACK",
-    }
-
-    _NAMES_TO_VALUES = {
-        "INFO": 0,
-        "DEBUG": 1,
-        "ERROR": 2,
-        "ACK": 3,
-    }
-
-
-class MessageType(object):
-    EXPERIMENT = 0
-    EXPERIMENT_CANCEL = 1
-    TASK = 2
-    PROCESS = 3
-    JOB = 4
-    LAUNCHPROCESS = 5
-    TERMINATEPROCESS = 6
-    PROCESSOUTPUT = 7
-    DB_EVENT = 8
-
-    _VALUES_TO_NAMES = {
-        0: "EXPERIMENT",
-        1: "EXPERIMENT_CANCEL",
-        2: "TASK",
-        3: "PROCESS",
-        4: "JOB",
-        5: "LAUNCHPROCESS",
-        6: "TERMINATEPROCESS",
-        7: "PROCESSOUTPUT",
-        8: "DB_EVENT",
-    }
-
-    _NAMES_TO_VALUES = {
-        "EXPERIMENT": 0,
-        "EXPERIMENT_CANCEL": 1,
-        "TASK": 2,
-        "PROCESS": 3,
-        "JOB": 4,
-        "LAUNCHPROCESS": 5,
-        "TERMINATEPROCESS": 6,
-        "PROCESSOUTPUT": 7,
-        "DB_EVENT": 8,
-    }
-
-
-class ExperimentStatusChangeEvent(object):
-    """
-    Attributes:
-     - state
-     - experimentId
-     - gatewayId
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.I32, 'state', None, None, ),  # 1
-        (2, TType.STRING, 'experimentId', 'UTF8', None, ),  # 2
-        (3, TType.STRING, 'gatewayId', 'UTF8', None, ),  # 3
-    )
-
-    def __init__(self, state=None, experimentId=None, gatewayId=None,):
-        self.state = state
-        self.experimentId = experimentId
-        self.gatewayId = gatewayId
-
-    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.STRING:
-                    self.experimentId = 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.gatewayId = 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('ExperimentStatusChangeEvent')
-        if self.state is not None:
-            oprot.writeFieldBegin('state', TType.I32, 1)
-            oprot.writeI32(self.state)
-            oprot.writeFieldEnd()
-        if self.experimentId is not None:
-            oprot.writeFieldBegin('experimentId', TType.STRING, 2)
-            oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
-            oprot.writeFieldEnd()
-        if self.gatewayId is not None:
-            oprot.writeFieldBegin('gatewayId', TType.STRING, 3)
-            oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.state is None:
-            raise TProtocolException(message='Required field state is unset!')
-        if self.experimentId is None:
-            raise TProtocolException(message='Required field experimentId is unset!')
-        if self.gatewayId is None:
-            raise TProtocolException(message='Required field gatewayId is unset!')
-        return
-
-    def __repr__(self):
-        L = ['%s=%r' % (key, value)
-             for key, value in self.__dict__.items()]
-        return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-    def __eq__(self, other):
-        return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-    def __ne__(self, other):
-        return not (self == other)
-
-
-class ProcessIdentifier(object):
-    """
-    Attributes:
-     - processId
-     - experimentId
-     - gatewayId
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'processId', 'UTF8', None, ),  # 1
-        (2, TType.STRING, 'experimentId', 'UTF8', None, ),  # 2
-        (3, TType.STRING, 'gatewayId', 'UTF8', None, ),  # 3
-    )
-
-    def __init__(self, processId=None, experimentId=None, gatewayId=None,):
-        self.processId = processId
-        self.experimentId = experimentId
-        self.gatewayId = gatewayId
-
-    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.processId = 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.experimentId = 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.gatewayId = 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('ProcessIdentifier')
-        if self.processId is not None:
-            oprot.writeFieldBegin('processId', TType.STRING, 1)
-            oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId)
-            oprot.writeFieldEnd()
-        if self.experimentId is not None:
-            oprot.writeFieldBegin('experimentId', TType.STRING, 2)
-            oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
-            oprot.writeFieldEnd()
-        if self.gatewayId is not None:
-            oprot.writeFieldBegin('gatewayId', TType.STRING, 3)
-            oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.processId is None:
-            raise TProtocolException(message='Required field processId is unset!')
-        if self.experimentId is None:
-            raise TProtocolException(message='Required field experimentId is unset!')
-        if self.gatewayId is None:
-            raise TProtocolException(message='Required field gatewayId is unset!')
-        return
-
-    def __repr__(self):
-        L = ['%s=%r' % (key, value)
-             for key, value in self.__dict__.items()]
-        return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-    def __eq__(self, other):
-        return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-    def __ne__(self, other):
-        return not (self == other)
-
-
-class TaskIdentifier(object):
-    """
-    Attributes:
-     - taskId
-     - processId
-     - experimentId
-     - gatewayId
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'taskId', 'UTF8', None, ),  # 1
-        (2, TType.STRING, 'processId', 'UTF8', None, ),  # 2
-        (3, TType.STRING, 'experimentId', 'UTF8', None, ),  # 3
-        (4, TType.STRING, 'gatewayId', 'UTF8', None, ),  # 4
-    )
-
-    def __init__(self, taskId=None, processId=None, experimentId=None, gatewayId=None,):
-        self.taskId = taskId
-        self.processId = processId
-        self.experimentId = experimentId
-        self.gatewayId = gatewayId
-
-    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.STRING:
-                    self.processId = 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.experimentId = 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.gatewayId = 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('TaskIdentifier')
-        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.processId is not None:
-            oprot.writeFieldBegin('processId', TType.STRING, 2)
-            oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId)
-            oprot.writeFieldEnd()
-        if self.experimentId is not None:
-            oprot.writeFieldBegin('experimentId', TType.STRING, 3)
-            oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
-            oprot.writeFieldEnd()
-        if self.gatewayId is not None:
-            oprot.writeFieldBegin('gatewayId', TType.STRING, 4)
-            oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.taskId is None:
-            raise TProtocolException(message='Required field taskId is unset!')
-        if self.processId is None:
-            raise TProtocolException(message='Required field processId is unset!')
-        if self.experimentId is None:
-            raise TProtocolException(message='Required field experimentId is unset!')
-        if self.gatewayId is None:
-            raise TProtocolException(message='Required field gatewayId is unset!')
-        return
-
-    def __repr__(self):
-        L = ['%s=%r' % (key, value)
-             for key, value in self.__dict__.items()]
-        return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-    def __eq__(self, other):
-        return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-    def __ne__(self, other):
-        return not (self == other)
-
-
-class TaskStatusChangeEvent(object):
-    """
-    Attributes:
-     - state
-     - taskIdentity
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.I32, 'state', None, None, ),  # 1
-        (2, TType.STRUCT, 'taskIdentity', (TaskIdentifier, TaskIdentifier.thrift_spec), None, ),  # 2
-    )
-
-    def __init__(self, state=None, taskIdentity=None,):
-        self.state = state
-        self.taskIdentity = taskIdentity
-
-    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.STRUCT:
-                    self.taskIdentity = TaskIdentifier()
-                    self.taskIdentity.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('TaskStatusChangeEvent')
-        if self.state is not None:
-            oprot.writeFieldBegin('state', TType.I32, 1)
-            oprot.writeI32(self.state)
-            oprot.writeFieldEnd()
-        if self.taskIdentity is not None:
-            oprot.writeFieldBegin('taskIdentity', TType.STRUCT, 2)
-            self.taskIdentity.write(oprot)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.state is None:
-            raise TProtocolException(message='Required field state is unset!')
-        if self.taskIdentity is None:
-            raise TProtocolException(message='Required field taskIdentity 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 TaskStatusChangeRequestEvent(object):
-    """
-    Attributes:
-     - state
-     - taskIdentity
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.I32, 'state', None, None, ),  # 1
-        (2, TType.STRUCT, 'taskIdentity', (TaskIdentifier, TaskIdentifier.thrift_spec), None, ),  # 2
-    )
-
-    def __init__(self, state=None, taskIdentity=None,):
-        self.state = state
-        self.taskIdentity = taskIdentity
-
-    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.STRUCT:
-                    self.taskIdentity = TaskIdentifier()
-                    self.taskIdentity.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('TaskStatusChangeRequestEvent')
-        if self.state is not None:
-            oprot.writeFieldBegin('state', TType.I32, 1)
-            oprot.writeI32(self.state)
-            oprot.writeFieldEnd()
-        if self.taskIdentity is not None:
-            oprot.writeFieldBegin('taskIdentity', TType.STRUCT, 2)
-            self.taskIdentity.write(oprot)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.state is None:
-            raise TProtocolException(message='Required field state is unset!')
-        if self.taskIdentity is None:
-            raise TProtocolException(message='Required field taskIdentity 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 ProcessStatusChangeEvent(object):
-    """
-    Attributes:
-     - state
-     - processIdentity
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.I32, 'state', None, None, ),  # 1
-        (2, TType.STRUCT, 'processIdentity', (ProcessIdentifier, ProcessIdentifier.thrift_spec), None, ),  # 2
-    )
-
-    def __init__(self, state=None, processIdentity=None,):
-        self.state = state
-        self.processIdentity = processIdentity
-
-    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.STRUCT:
-                    self.processIdentity = ProcessIdentifier()
-                    self.processIdentity.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('ProcessStatusChangeEvent')
-        if self.state is not None:
-            oprot.writeFieldBegin('state', TType.I32, 1)
-            oprot.writeI32(self.state)
-            oprot.writeFieldEnd()
-        if self.processIdentity is not None:
-            oprot.writeFieldBegin('processIdentity', TType.STRUCT, 2)
-            self.processIdentity.write(oprot)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.state is None:
-            raise TProtocolException(message='Required field state is unset!')
-        if self.processIdentity is None:
-            raise TProtocolException(message='Required field processIdentity 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 ProcessStatusChangeRequestEvent(object):
-    """
-    Attributes:
-     - state
-     - processIdentity
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.I32, 'state', None, None, ),  # 1
-        (2, TType.STRUCT, 'processIdentity', (ProcessIdentifier, ProcessIdentifier.thrift_spec), None, ),  # 2
-    )
-
-    def __init__(self, state=None, processIdentity=None,):
-        self.state = state
-        self.processIdentity = processIdentity
-
-    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.STRUCT:
-                    self.processIdentity = ProcessIdentifier()
-                    self.processIdentity.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('ProcessStatusChangeRequestEvent')
-        if self.state is not None:
-            oprot.writeFieldBegin('state', TType.I32, 1)
-            oprot.writeI32(self.state)
-            oprot.writeFieldEnd()
-        if self.processIdentity is not None:
-            oprot.writeFieldBegin('processIdentity', TType.STRUCT, 2)
-            self.processIdentity.write(oprot)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.state is None:
-            raise TProtocolException(message='Required field state is unset!')
-        if self.processIdentity is None:
-            raise TProtocolException(message='Required field processIdentity 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 TaskOutputChangeEvent(object):
-    """
-    Attributes:
-     - output
-     - taskIdentity
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.LIST, 'output', (TType.STRUCT, (apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec), False), None, ),  # 1
-        (2, TType.STRUCT, 'taskIdentity', (TaskIdentifier, TaskIdentifier.thrift_spec), None, ),  # 2
-    )
-
-    def __init__(self, output=None, taskIdentity=None,):
-        self.output = output
-        self.taskIdentity = taskIdentity
-
-    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.LIST:
-                    self.output = []
-                    (_etype3, _size0) = iprot.readListBegin()
-                    for _i4 in range(_size0):
-                        _elem5 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
-                        _elem5.read(iprot)
-                        self.output.append(_elem5)
-                    iprot.readListEnd()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 2:
-                if ftype == TType.STRUCT:
-                    self.taskIdentity = TaskIdentifier()
-                    self.taskIdentity.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('TaskOutputChangeEvent')
-        if self.output is not None:
-            oprot.writeFieldBegin('output', TType.LIST, 1)
-            oprot.writeListBegin(TType.STRUCT, len(self.output))
-            for iter6 in self.output:
-                iter6.write(oprot)
-            oprot.writeListEnd()
-            oprot.writeFieldEnd()
-        if self.taskIdentity is not None:
-            oprot.writeFieldBegin('taskIdentity', TType.STRUCT, 2)
-            self.taskIdentity.write(oprot)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.output is None:
-            raise TProtocolException(message='Required field output is unset!')
-        if self.taskIdentity is None:
-            raise TProtocolException(message='Required field taskIdentity 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 JobIdentifier(object):
-    """
-    Attributes:
-     - jobId
-     - taskId
-     - processId
-     - experimentId
-     - gatewayId
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'jobId', 'UTF8', None, ),  # 1
-        (2, TType.STRING, 'taskId', 'UTF8', None, ),  # 2
-        (3, TType.STRING, 'processId', 'UTF8', None, ),  # 3
-        (4, TType.STRING, 'experimentId', 'UTF8', None, ),  # 4
-        (5, TType.STRING, 'gatewayId', 'UTF8', None, ),  # 5
-    )
-
-    def __init__(self, jobId=None, taskId=None, processId=None, experimentId=None, gatewayId=None,):
-        self.jobId = jobId
-        self.taskId = taskId
-        self.processId = processId
-        self.experimentId = experimentId
-        self.gatewayId = gatewayId
-
-    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.jobId = 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.taskId = 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.processId = 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.experimentId = 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.gatewayId = 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('JobIdentifier')
-        if self.jobId is not None:
-            oprot.writeFieldBegin('jobId', TType.STRING, 1)
-            oprot.writeString(self.jobId.encode('utf-8') if sys.version_info[0] == 2 else self.jobId)
-            oprot.writeFieldEnd()
-        if self.taskId is not None:
-            oprot.writeFieldBegin('taskId', TType.STRING, 2)
-            oprot.writeString(self.taskId.encode('utf-8') if sys.version_info[0] == 2 else self.taskId)
-            oprot.writeFieldEnd()
-        if self.processId is not None:
-            oprot.writeFieldBegin('processId', TType.STRING, 3)
-            oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId)
-            oprot.writeFieldEnd()
-        if self.experimentId is not None:
-            oprot.writeFieldBegin('experimentId', TType.STRING, 4)
-            oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
-            oprot.writeFieldEnd()
-        if self.gatewayId is not None:
-            oprot.writeFieldBegin('gatewayId', TType.STRING, 5)
-            oprot.writeString(self.gatewayId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayId)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.jobId is None:
-            raise TProtocolException(message='Required field jobId is unset!')
-        if self.taskId is None:
-            raise TProtocolException(message='Required field taskId is unset!')
-        if self.processId is None:
-            raise TProtocolException(message='Required field processId is unset!')
-        if self.experimentId is None:
-            raise TProtocolException(message='Required field experimentId is unset!')
-        if self.gatewayId is None:
-            raise TProtocolException(message='Required field gatewayId is unset!')
-        return
-
-    def __repr__(self):
-        L = ['%s=%r' % (key, value)
-             for key, value in self.__dict__.items()]
-        return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-    def __eq__(self, other):
-        return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-    def __ne__(self, other):
-        return not (self == other)
-
-
-class ExperimentSubmitEvent(object):
-    """
-    Attributes:
-     - experimentId
-     - gatewayId
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'experimentId', 'UTF8', None, ),  # 1
-        (2, TType.STRING, 'gatewayId', 'UTF8', None, ),  # 2
-    )
-
-    def __init__(self, experimentId=None, gatewayId=None,):
-        self.experimentId = experimentId
-        self.gatewayId = gatewayId
-
-    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.experimentId = 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)
-            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('ExperimentSubmitEvent')
-        if self.experimentId is not None:
-            oprot.writeFieldBegin('experimentId', TType.STRING, 1)
-            oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
-            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()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.experimentId is None:
-            raise TProtocolException(message='Required field experimentId is unset!')
-        if self.gatewayId is None:
-            raise TProtocolException(message='Required field gatewayId is unset!')
-        return
-
-    def __repr__(self):
-        L = ['%s=%r' % (key, value)
-             for key, value in self.__dict__.items()]
-        return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-    def __eq__(self, other):
-        return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-    def __ne__(self, other):
-        return not (self == other)
-
-
-class ProcessSubmitEvent(object):
-    """
-    Attributes:
-     - processId
-     - gatewayId
-     - experimentId
-     - tokenId
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'processId', 'UTF8', None, ),  # 1
-        (2, TType.STRING, 'gatewayId', 'UTF8', None, ),  # 2
-        (3, TType.STRING, 'experimentId', 'UTF8', None, ),  # 3
-        (4, TType.STRING, 'tokenId', 'UTF8', None, ),  # 4
-    )
-
-    def __init__(self, processId=None, gatewayId=None, experimentId=None, tokenId=None,):
-        self.processId = processId
-        self.gatewayId = gatewayId
-        self.experimentId = experimentId
-        self.tokenId = tokenId
-
-    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.processId = 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.experimentId = 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.tokenId = 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('ProcessSubmitEvent')
-        if self.processId is not None:
-            oprot.writeFieldBegin('processId', TType.STRING, 1)
-            oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId)
-            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.experimentId is not None:
-            oprot.writeFieldBegin('experimentId', TType.STRING, 3)
-            oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
-            oprot.writeFieldEnd()
-        if self.tokenId is not None:
-            oprot.writeFieldBegin('tokenId', TType.STRING, 4)
-            oprot.writeString(self.tokenId.encode('utf-8') if sys.version_info[0] == 2 else self.tokenId)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.processId is None:
-            raise TProtocolException(message='Required field processId is unset!')
-        if self.gatewayId is None:
-            raise TProtocolException(message='Required field gatewayId is unset!')
-        if self.experimentId is None:
-            raise TProtocolException(message='Required field experimentId is unset!')
-        if self.tokenId is None:
-            raise TProtocolException(message='Required field tokenId 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 ProcessTerminateEvent(object):
-    """
-    Attributes:
-     - processId
-     - gatewayId
-     - tokenId
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'processId', 'UTF8', None, ),  # 1
-        (2, TType.STRING, 'gatewayId', 'UTF8', None, ),  # 2
-        (3, TType.STRING, 'tokenId', 'UTF8', None, ),  # 3
-    )
-
-    def __init__(self, processId=None, gatewayId=None, tokenId=None,):
-        self.processId = processId
-        self.gatewayId = gatewayId
-        self.tokenId = tokenId
-
-    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.processId = 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.tokenId = 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('ProcessTerminateEvent')
-        if self.processId is not None:
-            oprot.writeFieldBegin('processId', TType.STRING, 1)
-            oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId)
-            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.tokenId is not None:
-            oprot.writeFieldBegin('tokenId', TType.STRING, 3)
-            oprot.writeString(self.tokenId.encode('utf-8') if sys.version_info[0] == 2 else self.tokenId)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.processId is None:
-            raise TProtocolException(message='Required field processId is unset!')
-        if self.gatewayId is None:
-            raise TProtocolException(message='Required field gatewayId is unset!')
-        if self.tokenId is None:
-            raise TProtocolException(message='Required field tokenId 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 JobStatusChangeEvent(object):
-    """
-    Attributes:
-     - state
-     - jobIdentity
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.I32, 'state', None, None, ),  # 1
-        (2, TType.STRUCT, 'jobIdentity', (JobIdentifier, JobIdentifier.thrift_spec), None, ),  # 2
-    )
-
-    def __init__(self, state=None, jobIdentity=None,):
-        self.state = state
-        self.jobIdentity = jobIdentity
-
-    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.STRUCT:
-                    self.jobIdentity = JobIdentifier()
-                    self.jobIdentity.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('JobStatusChangeEvent')
-        if self.state is not None:
-            oprot.writeFieldBegin('state', TType.I32, 1)
-            oprot.writeI32(self.state)
-            oprot.writeFieldEnd()
-        if self.jobIdentity is not None:
-            oprot.writeFieldBegin('jobIdentity', TType.STRUCT, 2)
-            self.jobIdentity.write(oprot)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.state is None:
-            raise TProtocolException(message='Required field state is unset!')
-        if self.jobIdentity is None:
-            raise TProtocolException(message='Required field jobIdentity 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 JobStatusChangeRequestEvent(object):
-    """
-    Attributes:
-     - state
-     - jobIdentity
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.I32, 'state', None, None, ),  # 1
-        (2, TType.STRUCT, 'jobIdentity', (JobIdentifier, JobIdentifier.thrift_spec), None, ),  # 2
-    )
-
-    def __init__(self, state=None, jobIdentity=None,):
-        self.state = state
-        self.jobIdentity = jobIdentity
-
-    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.STRUCT:
-                    self.jobIdentity = JobIdentifier()
-                    self.jobIdentity.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('JobStatusChangeRequestEvent')
-        if self.state is not None:
-            oprot.writeFieldBegin('state', TType.I32, 1)
-            oprot.writeI32(self.state)
-            oprot.writeFieldEnd()
-        if self.jobIdentity is not None:
-            oprot.writeFieldBegin('jobIdentity', TType.STRUCT, 2)
-            self.jobIdentity.write(oprot)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.state is None:
-            raise TProtocolException(message='Required field state is unset!')
-        if self.jobIdentity is None:
-            raise TProtocolException(message='Required field jobIdentity 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 Message(object):
-    """
-    Attributes:
-     - event
-     - messageId
-     - messageType
-     - updatedTime
-     - messageLevel
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'event', 'BINARY', None, ),  # 1
-        (2, TType.STRING, 'messageId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ),  # 2
-        (3, TType.I32, 'messageType', None, None, ),  # 3
-        (4, TType.I64, 'updatedTime', None, None, ),  # 4
-        (5, TType.I32, 'messageLevel', None, None, ),  # 5
-    )
-
-    def __init__(self, event=None, messageId=thrift_spec[2][4], messageType=None, updatedTime=None, messageLevel=None,):
-        self.event = event
-        self.messageId = messageId
-        self.messageType = messageType
-        self.updatedTime = updatedTime
-        self.messageLevel = messageLevel
-
-    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.event = iprot.readBinary()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 2:
-                if ftype == TType.STRING:
-                    self.messageId = 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.messageType = iprot.readI32()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 4:
-                if ftype == TType.I64:
-                    self.updatedTime = iprot.readI64()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 5:
-                if ftype == TType.I32:
-                    self.messageLevel = 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('Message')
-        if self.event is not None:
-            oprot.writeFieldBegin('event', TType.STRING, 1)
-            oprot.writeBinary(self.event)
-            oprot.writeFieldEnd()
-        if self.messageId is not None:
-            oprot.writeFieldBegin('messageId', TType.STRING, 2)
-            oprot.writeString(self.messageId.encode('utf-8') if sys.version_info[0] == 2 else self.messageId)
-            oprot.writeFieldEnd()
-        if self.messageType is not None:
-            oprot.writeFieldBegin('messageType', TType.I32, 3)
-            oprot.writeI32(self.messageType)
-            oprot.writeFieldEnd()
-        if self.updatedTime is not None:
-            oprot.writeFieldBegin('updatedTime', TType.I64, 4)
-            oprot.writeI64(self.updatedTime)
-            oprot.writeFieldEnd()
-        if self.messageLevel is not None:
-            oprot.writeFieldBegin('messageLevel', TType.I32, 5)
-            oprot.writeI32(self.messageLevel)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.event is None:
-            raise TProtocolException(message='Required field event is unset!')
-        if self.messageId is None:
-            raise TProtocolException(message='Required field messageId is unset!')
-        if self.messageType is None:
-            raise TProtocolException(message='Required field messageType 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/process/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/process/__init__.py b/django_portal/apache/airavata/model/process/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/process/__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/process/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/process/constants.py b/django_portal/apache/airavata/model/process/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/process/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/process/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/process/ttypes.py b/django_portal/apache/airavata/model/process/ttypes.py
deleted file mode 100644
index 1dce0d0..0000000
--- a/django_portal/apache/airavata/model/process/ttypes.py
+++ /dev/null
@@ -1,420 +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
-import apache.airavata.model.application.io.ttypes
-import apache.airavata.model.status.ttypes
-import apache.airavata.model.task.ttypes
-import apache.airavata.model.scheduling.ttypes
-
-from thrift.transport import TTransport
-
-
-class ProcessModel(object):
-    """
-    ProcessModel: A structure holding the process details. The infromation is derived based on user provided
-             configuration data or system inferred information from scheduling and QoS parameters.
-
-    processDetail:
-      A friendly description of the process, usally used to communicate information to users.
-
-
-
-    Attributes:
-     - processId
-     - experimentId
-     - creationTime
-     - lastUpdateTime
-     - processStatuses
-     - processDetail
-     - applicationInterfaceId
-     - applicationDeploymentId
-     - computeResourceId
-     - processInputs
-     - processOutputs
-     - processResourceSchedule
-     - tasks
-     - taskDag
-     - processErrors
-     - gatewayExecutionId
-     - enableEmailNotification
-     - emailAddresses
-     - storageResourceId
-     - userDn
-     - generateCert
-     - experimentDataDir
-     - userName
-     - useUserCRPref
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'processId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ),  # 1
-        (2, TType.STRING, 'experimentId', 'UTF8', None, ),  # 2
-        (3, TType.I64, 'creationTime', None, None, ),  # 3
-        (4, TType.I64, 'lastUpdateTime', None, None, ),  # 4
-        (5, TType.LIST, 'processStatuses', (TType.STRUCT, (apache.airavata.model.status.ttypes.ProcessStatus, apache.airavata.model.status.ttypes.ProcessStatus.thrift_spec), False), None, ),  # 5
-        (6, TType.STRING, 'processDetail', 'UTF8', None, ),  # 6
-        (7, TType.STRING, 'applicationInterfaceId', 'UTF8', None, ),  # 7
-        (8, TType.STRING, 'applicationDeploymentId', 'UTF8', None, ),  # 8
-        (9, TType.STRING, 'computeResourceId', 'UTF8', None, ),  # 9
-        (10, TType.LIST, 'processInputs', (TType.STRUCT, (apache.airavata.model.application.io.ttypes.InputDataObjectType, apache.airavata.model.application.io.ttypes.InputDataObjectType.thrift_spec), False), None, ),  # 10
-        (11, TType.LIST, 'processOutputs', (TType.STRUCT, (apache.airavata.model.application.io.ttypes.OutputDataObjectType, apache.airavata.model.application.io.ttypes.OutputDataObjectType.thrift_spec), False), None, ),  # 11
-        (12, TType.STRUCT, 'processResourceSchedule', (apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel, apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel.thrift_spec), None, ),  # 12
-        (13, TType.LIST, 'tasks', (TType.STRUCT, (apache.airavata.model.task.ttypes.TaskModel, apache.airavata.model.task.ttypes.TaskModel.thrift_spec), False), None, ),  # 13
-        (14, TType.STRING, 'taskDag', 'UTF8', None, ),  # 14
-        (15, TType.LIST, 'processErrors', (TType.STRUCT, (apache.airavata.model.commons.ttypes.ErrorModel, apache.airavata.model.commons.ttypes.ErrorModel.thrift_spec), False), None, ),  # 15
-        (16, TType.STRING, 'gatewayExecutionId', 'UTF8', None, ),  # 16
-        (17, TType.BOOL, 'enableEmailNotification', None, None, ),  # 17
-        (18, TType.LIST, 'emailAddresses', (TType.STRING, 'UTF8', False), None, ),  # 18
-        (19, TType.STRING, 'storageResourceId', 'UTF8', None, ),  # 19
-        (20, TType.STRING, 'userDn', 'UTF8', None, ),  # 20
-        (21, TType.BOOL, 'generateCert', None, False, ),  # 21
-        (22, TType.STRING, 'experimentDataDir', 'UTF8', None, ),  # 22
-        (23, TType.STRING, 'userName', 'UTF8', None, ),  # 23
-        (24, TType.BOOL, 'useUserCRPref', None, None, ),  # 24
-    )
-
-    def __init__(self, processId=thrift_spec[1][4], experimentId=None, creationTime=None, lastUpdateTime=None, processStatuses=None, processDetail=None, applicationInterfaceId=None, applicationDeploymentId=None, computeResourceId=None, processInputs=None, processOutputs=None, processResourceSchedule=None, tasks=None, taskDag=None, processErrors=None, gatewayExecutionId=None, enableEmailNotification=None, emailAddresses=None, storageResourceId=None, userDn=None, generateCert=thrift_spec[21][4], experimentDataDir=None, userName=None, useUserCRPref=None,):
-        self.processId = processId
-        self.experimentId = experimentId
-        self.creationTime = creationTime
-        self.lastUpdateTime = lastUpdateTime
-        self.processStatuses = processStatuses
-        self.processDetail = processDetail
-        self.applicationInterfaceId = applicationInterfaceId
-        self.applicationDeploymentId = applicationDeploymentId
-        self.computeResourceId = computeResourceId
-        self.processInputs = processInputs
-        self.processOutputs = processOutputs
-        self.processResourceSchedule = processResourceSchedule
-        self.tasks = tasks
-        self.taskDag = taskDag
-        self.processErrors = processErrors
-        self.gatewayExecutionId = gatewayExecutionId
-        self.enableEmailNotification = enableEmailNotification
-        self.emailAddresses = emailAddresses
-        self.storageResourceId = storageResourceId
-        self.userDn = userDn
-        self.generateCert = generateCert
-        self.experimentDataDir = experimentDataDir
-        self.userName = userName
-        self.useUserCRPref = useUserCRPref
-
-    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.processId = 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.experimentId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 3:
-                if ftype == TType.I64:
-                    self.creationTime = iprot.readI64()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 4:
-                if ftype == TType.I64:
-                    self.lastUpdateTime = iprot.readI64()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 5:
-                if ftype == TType.LIST:
-                    self.processStatuses = []
-                    (_etype3, _size0) = iprot.readListBegin()
-                    for _i4 in range(_size0):
-                        _elem5 = apache.airavata.model.status.ttypes.ProcessStatus()
-                        _elem5.read(iprot)
-                        self.processStatuses.append(_elem5)
-                    iprot.readListEnd()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 6:
-                if ftype == TType.STRING:
-                    self.processDetail = 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.applicationInterfaceId = 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.applicationDeploymentId = 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.computeResourceId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 10:
-                if ftype == TType.LIST:
-                    self.processInputs = []
-                    (_etype9, _size6) = iprot.readListBegin()
-                    for _i10 in range(_size6):
-                        _elem11 = apache.airavata.model.application.io.ttypes.InputDataObjectType()
-                        _elem11.read(iprot)
-                        self.processInputs.append(_elem11)
-                    iprot.readListEnd()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 11:
-                if ftype == TType.LIST:
-                    self.processOutputs = []
-                    (_etype15, _size12) = iprot.readListBegin()
-                    for _i16 in range(_size12):
-                        _elem17 = apache.airavata.model.application.io.ttypes.OutputDataObjectType()
-                        _elem17.read(iprot)
-                        self.processOutputs.append(_elem17)
-                    iprot.readListEnd()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 12:
-                if ftype == TType.STRUCT:
-                    self.processResourceSchedule = apache.airavata.model.scheduling.ttypes.ComputationalResourceSchedulingModel()
-                    self.processResourceSchedule.read(iprot)
-                else:
-                    iprot.skip(ftype)
-            elif fid == 13:
-                if ftype == TType.LIST:
-                    self.tasks = []
-                    (_etype21, _size18) = iprot.readListBegin()
-                    for _i22 in range(_size18):
-                        _elem23 = apache.airavata.model.task.ttypes.TaskModel()
-                        _elem23.read(iprot)
-                        self.tasks.append(_elem23)
-                    iprot.readListEnd()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 14:
-                if ftype == TType.STRING:
-                    self.taskDag = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 15:
-                if ftype == TType.LIST:
-                    self.processErrors = []
-                    (_etype27, _size24) = iprot.readListBegin()
-                    for _i28 in range(_size24):
-                        _elem29 = apache.airavata.model.commons.ttypes.ErrorModel()
-                        _elem29.read(iprot)
-                        self.processErrors.append(_elem29)
-                    iprot.readListEnd()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 16:
-                if ftype == TType.STRING:
-                    self.gatewayExecutionId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 17:
-                if ftype == TType.BOOL:
-                    self.enableEmailNotification = iprot.readBool()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 18:
-                if ftype == TType.LIST:
-                    self.emailAddresses = []
-                    (_etype33, _size30) = iprot.readListBegin()
-                    for _i34 in range(_size30):
-                        _elem35 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                        self.emailAddresses.append(_elem35)
-                    iprot.readListEnd()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 19:
-                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 == 20:
-                if ftype == TType.STRING:
-                    self.userDn = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 21:
-                if ftype == TType.BOOL:
-                    self.generateCert = iprot.readBool()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 22:
-                if ftype == TType.STRING:
-                    self.experimentDataDir = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 23:
-                if ftype == TType.STRING:
-                    self.userName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 24:
-                if ftype == TType.BOOL:
-                    self.useUserCRPref = iprot.readBool()
-                else:
-                    iprot.skip(ftype)
-            else:
-                iprot.skip(ftype)
-            iprot.readFieldEnd()
-        iprot.readStructEnd()
-
-    def write(self, oprot):
-        if oprot._fast_encode is not None and self.thrift_spec is not None:
-            oprot.trans.write(oprot._fast_encode(self, (self.__class__, self.thrift_spec)))
-            return
-        oprot.writeStructBegin('ProcessModel')
-        if self.processId is not None:
-            oprot.writeFieldBegin('processId', TType.STRING, 1)
-            oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId)
-            oprot.writeFieldEnd()
-        if self.experimentId is not None:
-            oprot.writeFieldBegin('experimentId', TType.STRING, 2)
-            oprot.writeString(self.experimentId.encode('utf-8') if sys.version_info[0] == 2 else self.experimentId)
-            oprot.writeFieldEnd()
-        if self.creationTime is not None:
-            oprot.writeFieldBegin('creationTime', TType.I64, 3)
-            oprot.writeI64(self.creationTime)
-            oprot.writeFieldEnd()
-        if self.lastUpdateTime is not None:
-            oprot.writeFieldBegin('lastUpdateTime', TType.I64, 4)
-            oprot.writeI64(self.lastUpdateTime)
-            oprot.writeFieldEnd()
-        if self.processStatuses is not None:
-            oprot.writeFieldBegin('processStatuses', TType.LIST, 5)
-            oprot.writeListBegin(TType.STRUCT, len(self.processStatuses))
-            for iter36 in self.processStatuses:
-                iter36.write(oprot)
-            oprot.writeListEnd()
-            oprot.writeFieldEnd()
-        if self.processDetail is not None:
-            oprot.writeFieldBegin('processDetail', TType.STRING, 6)
-            oprot.writeString(self.processDetail.encode('utf-8') if sys.version_info[0] == 2 else self.processDetail)
-            oprot.writeFieldEnd()
-        if self.applicationInterfaceId is not None:
-            oprot.writeFieldBegin('applicationInterfaceId', TType.STRING, 7)
-            oprot.writeString(self.applicationInterfaceId.encode('utf-8') if sys.version_info[0] == 2 else self.applicationInterfaceId)
-            oprot.writeFieldEnd()
-        if self.applicationDeploymentId is not None:
-            oprot.writeFieldBegin('applicationDeploymentId', TType.STRING, 8)
-            oprot.writeString(self.applicationDeploymentId.encode('utf-8') if sys.version_info[0] == 2 else self.applicationDeploymentId)
-            oprot.writeFieldEnd()
-        if self.computeResourceId is not None:
-            oprot.writeFieldBegin('computeResourceId', TType.STRING, 9)
-            oprot.writeString(self.computeResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.computeResourceId)
-            oprot.writeFieldEnd()
-        if self.processInputs is not None:
-            oprot.writeFieldBegin('processInputs', TType.LIST, 10)
-            oprot.writeListBegin(TType.STRUCT, len(self.processInputs))
-            for iter37 in self.processInputs:
-                iter37.write(oprot)
-            oprot.writeListEnd()
-            oprot.writeFieldEnd()
-        if self.processOutputs is not None:
-            oprot.writeFieldBegin('processOutputs', TType.LIST, 11)
-            oprot.writeListBegin(TType.STRUCT, len(self.processOutputs))
-            for iter38 in self.processOutputs:
-                iter38.write(oprot)
-            oprot.writeListEnd()
-            oprot.writeFieldEnd()
-        if self.processResourceSchedule is not None:
-            oprot.writeFieldBegin('processResourceSchedule', TType.STRUCT, 12)
-            self.processResourceSchedule.write(oprot)
-            oprot.writeFieldEnd()
-        if self.tasks is not None:
-            oprot.writeFieldBegin('tasks', TType.LIST, 13)
-            oprot.writeListBegin(TType.STRUCT, len(self.tasks))
-            for iter39 in self.tasks:
-                iter39.write(oprot)
-            oprot.writeListEnd()
-            oprot.writeFieldEnd()
-        if self.taskDag is not None:
-            oprot.writeFieldBegin('taskDag', TType.STRING, 14)
-            oprot.writeString(self.taskDag.encode('utf-8') if sys.version_info[0] == 2 else self.taskDag)
-            oprot.writeFieldEnd()
-        if self.processErrors is not None:
-            oprot.writeFieldBegin('processErrors', TType.LIST, 15)
-            oprot.writeListBegin(TType.STRUCT, len(self.processErrors))
-            for iter40 in self.processErrors:
-                iter40.write(oprot)
-            oprot.writeListEnd()
-            oprot.writeFieldEnd()
-        if self.gatewayExecutionId is not None:
-            oprot.writeFieldBegin('gatewayExecutionId', TType.STRING, 16)
-            oprot.writeString(self.gatewayExecutionId.encode('utf-8') if sys.version_info[0] == 2 else self.gatewayExecutionId)
-            oprot.writeFieldEnd()
-        if self.enableEmailNotification is not None:
-            oprot.writeFieldBegin('enableEmailNotification', TType.BOOL, 17)
-            oprot.writeBool(self.enableEmailNotification)
-            oprot.writeFieldEnd()
-        if self.emailAddresses is not None:
-            oprot.writeFieldBegin('emailAddresses', TType.LIST, 18)
-            oprot.writeListBegin(TType.STRING, len(self.emailAddresses))
-            for iter41 in self.emailAddresses:
-                oprot.writeString(iter41.encode('utf-8') if sys.version_info[0] == 2 else iter41)
-            oprot.writeListEnd()
-            oprot.writeFieldEnd()
-        if self.storageResourceId is not None:
-            oprot.writeFieldBegin('storageResourceId', TType.STRING, 19)
-            oprot.writeString(self.storageResourceId.encode('utf-8') if sys.version_info[0] == 2 else self.storageResourceId)
-            oprot.writeFieldEnd()
-        if self.userDn is not None:
-            oprot.writeFieldBegin('userDn', TType.STRING, 20)
-            oprot.writeString(self.userDn.encode('utf-8') if sys.version_info[0] == 2 else self.userDn)
-            oprot.writeFieldEnd()
-        if self.generateCert is not None:
-            oprot.writeFieldBegin('generateCert', TType.BOOL, 21)
-            oprot.writeBool(self.generateCert)
-            oprot.writeFieldEnd()
-        if self.experimentDataDir is not None:
-            oprot.writeFieldBegin('experimentDataDir', TType.STRING, 22)
-            oprot.writeString(self.experimentDataDir.encode('utf-8') if sys.version_info[0] == 2 else self.experimentDataDir)
-            oprot.writeFieldEnd()
-        if self.userName is not None:
-            oprot.writeFieldBegin('userName', TType.STRING, 23)
-            oprot.writeString(self.userName.encode('utf-8') if sys.version_info[0] == 2 else self.userName)
-            oprot.writeFieldEnd()
-        if self.useUserCRPref is not None:
-            oprot.writeFieldBegin('useUserCRPref', TType.BOOL, 24)
-            oprot.writeBool(self.useUserCRPref)
-            oprot.writeFieldEnd()
-        oprot.writeFieldStop()
-        oprot.writeStructEnd()
-
-    def validate(self):
-        if self.processId is None:
-            raise TProtocolException(message='Required field processId is unset!')
-        if self.experimentId is None:
-            raise TProtocolException(message='Required field experimentId 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/scheduling/__init__.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/scheduling/__init__.py b/django_portal/apache/airavata/model/scheduling/__init__.py
deleted file mode 100644
index adefd8e..0000000
--- a/django_portal/apache/airavata/model/scheduling/__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/scheduling/constants.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/scheduling/constants.py b/django_portal/apache/airavata/model/scheduling/constants.py
deleted file mode 100644
index eb0d35a..0000000
--- a/django_portal/apache/airavata/model/scheduling/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/scheduling/ttypes.py
----------------------------------------------------------------------
diff --git a/django_portal/apache/airavata/model/scheduling/ttypes.py b/django_portal/apache/airavata/model/scheduling/ttypes.py
deleted file mode 100644
index fcdae4c..0000000
--- a/django_portal/apache/airavata/model/scheduling/ttypes.py
+++ /dev/null
@@ -1,209 +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 ComputationalResourceSchedulingModel(object):
-    """
-    ComputationalResourceSchedulingModel:
-
-
-
-    Attributes:
-     - resourceHostId
-     - totalCPUCount
-     - nodeCount
-     - numberOfThreads
-     - queueName
-     - wallTimeLimit
-     - totalPhysicalMemory
-     - chessisNumber
-     - staticWorkingDir
-     - overrideLoginUserName
-     - overrideScratchLocation
-     - overrideAllocationProjectNumber
-    """
-
-    thrift_spec = (
-        None,  # 0
-        (1, TType.STRING, 'resourceHostId', 'UTF8', None, ),  # 1
-        (2, TType.I32, 'totalCPUCount', None, None, ),  # 2
-        (3, TType.I32, 'nodeCount', None, None, ),  # 3
-        (4, TType.I32, 'numberOfThreads', None, None, ),  # 4
-        (5, TType.STRING, 'queueName', 'UTF8', None, ),  # 5
-        (6, TType.I32, 'wallTimeLimit', None, None, ),  # 6
-        (7, TType.I32, 'totalPhysicalMemory', None, None, ),  # 7
-        (8, TType.STRING, 'chessisNumber', 'UTF8', None, ),  # 8
-        (9, TType.STRING, 'staticWorkingDir', 'UTF8', None, ),  # 9
-        (10, TType.STRING, 'overrideLoginUserName', 'UTF8', None, ),  # 10
-        (11, TType.STRING, 'overrideScratchLocation', 'UTF8', None, ),  # 11
-        (12, TType.STRING, 'overrideAllocationProjectNumber', 'UTF8', None, ),  # 12
-    )
-
-    def __init__(self, resourceHostId=None, totalCPUCount=None, nodeCount=None, numberOfThreads=None, queueName=None, wallTimeLimit=None, totalPhysicalMemory=None, chessisNumber=None, staticWorkingDir=None, overrideLoginUserName=None, overrideScratchLocation=None, overrideAllocationProjectNumber=None,):
-        self.resourceHostId = resourceHostId
-        self.totalCPUCount = totalCPUCount
-        self.nodeCount = nodeCount
-        self.numberOfThreads = numberOfThreads
-        self.queueName = queueName
-        self.wallTimeLimit = wallTimeLimit
-        self.totalPhysicalMemory = totalPhysicalMemory
-        self.chessisNumber = chessisNumber
-        self.staticWorkingDir = staticWorkingDir
-        self.overrideLoginUserName = overrideLoginUserName
-        self.overrideScratchLocation = overrideScratchLocation
-        self.overrideAllocationProjectNumber = overrideAllocationProjectNumber
-
-    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.resourceHostId = 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.totalCPUCount = iprot.readI32()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 3:
-                if ftype == TType.I32:
-                    self.nodeCount = iprot.readI32()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 4:
-                if ftype == TType.I32:
-                    self.numberOfThreads = iprot.readI32()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 5:
-                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 == 6:
-                if ftype == TType.I32:
-                    self.wallTimeLimit = iprot.readI32()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 7:
-                if ftype == TType.I32:
-                    self.totalPhysicalMemory = iprot.readI32()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 8:
-                if ftype == TType.STRING:
-                    self.chessisNumber = 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.staticWorkingDir = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
-                else:
-                    iprot.skip(ftype)
-            elif fid == 10:
-                if ftype == TType.STRING:
-                    self.overrideLoginUserName = 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.overrideScratchLocation = 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.overrideAllocationProjectNumber = 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('ComputationalResourceSchedulingModel')
-        if self.resourceHostId is not None:
-            oprot.writeFieldBegin('resourceHostId', TType.STRING, 1)
-            oprot.writeString(self.resourceHostId.encode('utf-8') if sys.version_info[0] == 2 else self.resourceHostId)
-            oprot.writeFieldEnd()
-        if self.totalCPUCount is not None:
-            oprot.writeFieldBegin('totalCPUCount', TType.I32, 2)
-            oprot.writeI32(self.totalCPUCount)
-            oprot.writeFieldEnd()
-        if self.nodeCount is not None:
-            oprot.writeFieldBegin('nodeCount', TType.I32, 3)
-            oprot.writeI32(self.nodeCount)
-            oprot.writeFieldEnd()
-        if self.numberOfThreads is not None:
-            oprot.writeFieldBegin('numberOfThreads', TType.I32, 4)
-            oprot.writeI32(self.numberOfThreads)
-            oprot.writeFieldEnd()
-        if self.queueName is not None:
-            oprot.writeFieldBegin('queueName', TType.STRING, 5)
-            oprot.writeString(self.queueName.encode('utf-8') if sys.version_info[0] == 2 else self.queueName)
-            oprot.writeFieldEnd()
-        if self.wallTimeLimit is not None:
-            oprot.writeFieldBegin('wallTimeLimit', TType.I32, 6)
-            oprot.writeI32(self.wallTimeLimit)
-            oprot.writeFieldEnd()
-        if self.totalPhysicalMemory is not None:
-            oprot.writeFieldBegin('totalPhysicalMemory', TType.I32, 7)
-            oprot.writeI32(self.totalPhysicalMemory)
-            oprot.writeFieldEnd()
-        if self.chessisNumber is not None:
-            oprot.writeFieldBegin('chessisNumber', TType.STRING, 8)
-            oprot.writeString(self.chessisNumber.encode('utf-8') if sys.version_info[0] == 2 else self.chessisNumber)
-            oprot.writeFieldEnd()
-        if self.staticWorkingDir is not None:
-            oprot.writeFieldBegin('staticWorkingDir', TType.STRING, 9)
-            oprot.writeString(self.staticWorkingDir.encode('utf-8') if sys.version_info[0] == 2 else self.staticWorkingDir)
-            oprot.writeFieldEnd()
-        if self.overrideLoginUserName is not None:
-            oprot.writeFieldBegin('overrideLoginUserName', TType.STRING, 10)
-            oprot.writeString(self.overrideLoginUserName.encode('utf-8') if sys.version_info[0] == 2 else self.overrideLoginUserName)
-            oprot.writeFieldEnd()
-        if self.overrideScratchLocation is not None:
-            oprot.writeFieldBegin('overrideScratchLocation', TType.STRING, 11)
-            oprot.writeString(self.overrideScratchLocation.encode('utf-8') if sys.version_info[0] == 2 else self.overrideScratchLocation)
-            oprot.writeFieldEnd()
-        if self.overrideAllocationProjectNumber is not None:
-            oprot.writeFieldBegin('overrideAllocationProjectNumber', TType.STRING, 12)
-            oprot.writeString(self.overrideAllocationProjectNumber.encode('utf-8') if sys.version_info[0] == 2 else self.overrideAllocationProjectNumber)
-            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)


Mime
View raw message