airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From machris...@apache.org
Subject [31/51] [abbrv] [partial] airavata git commit: AIRAVATA-2505 Upgrade Airavata to Thrift 0.10.0
Date Mon, 07 Aug 2017 14:01:07 GMT
http://git-wip-us.apache.org/repos/asf/airavata/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/task/ttypes.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/task/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/task/ttypes.py
index 213598b..0163b1f 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/task/ttypes.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/task/ttypes.py
@@ -1,12 +1,14 @@
 #
-# Autogenerated by Thrift Compiler (0.9.3)
+# 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, TException, TApplicationException
+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
@@ -14,706 +16,656 @@ import apache.airavata.model.application.io.ttypes
 import apache.airavata.model.status.ttypes
 import apache.airavata.model.job.ttypes
 
-
 from thrift.transport import TTransport
-from thrift.protocol import TBinaryProtocol, TProtocol
-try:
-  from thrift.protocol import fastbinary
-except:
-  fastbinary = None
-
-
-class TaskTypes:
-  """
-  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:
-  """
-  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:
-  """
-  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', None, "DO_NOT_SET_AT_CLIENTS", ), # 1
-    (2, TType.I32, 'taskType', None, None, ), # 2
-    (3, TType.STRING, 'parentProcessId', None, 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)), None, ), # 6
-    (7, TType.STRING, 'taskDetail', None, None, ), # 7
-    (8, TType.STRING, 'subTaskModel', None, None, ), # 8
-    (9, TType.LIST, 'taskErrors', (TType.STRUCT,(apache.airavata.model.commons.ttypes.ErrorModel, apache.airavata.model.commons.ttypes.ErrorModel.thrift_spec)), None, ), # 9
-    (10, TType.LIST, 'jobs', (TType.STRUCT,(apache.airavata.model.job.ttypes.JobModel, apache.airavata.model.job.ttypes.JobModel.thrift_spec)), 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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-      return
-    iprot.readStructBegin()
-    while True:
-      (fname, ftype, fid) = iprot.readFieldBegin()
-      if ftype == TType.STOP:
-        break
-      if fid == 1:
-        if ftype == TType.STRING:
-          self.taskId = 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()
-        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 xrange(_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()
-        else:
-          iprot.skip(ftype)
-      elif fid == 8:
-        if ftype == TType.STRING:
-          self.subTaskModel = iprot.readString()
-        else:
-          iprot.skip(ftype)
-      elif fid == 9:
-        if ftype == TType.LIST:
-          self.taskErrors = []
-          (_etype9, _size6) = iprot.readListBegin()
-          for _i10 in xrange(_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 xrange(_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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-      return
-    oprot.writeStructBegin('TaskModel')
-    if self.taskId is not None:
-      oprot.writeFieldBegin('taskId', TType.STRING, 1)
-      oprot.writeString(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)
-      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)
-      oprot.writeFieldEnd()
-    if self.subTaskModel is not None:
-      oprot.writeFieldBegin('subTaskModel', TType.STRING, 8)
-      oprot.writeString(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 TProtocol.TProtocolException(message='Required field taskId is unset!')
-    if self.taskType is None:
-      raise TProtocol.TProtocolException(message='Required field taskType is unset!')
-    if self.parentProcessId is None:
-      raise TProtocol.TProtocolException(message='Required field parentProcessId is unset!')
-    if self.creationTime is None:
-      raise TProtocol.TProtocolException(message='Required field creationTime is unset!')
-    if self.lastUpdateTime is None:
-      raise TProtocol.TProtocolException(message='Required field lastUpdateTime is unset!')
-    if self.taskStatuses is None:
-      raise TProtocol.TProtocolException(message='Required field taskStatuses is unset!')
-    return
-
-
-  def __hash__(self):
-    value = 17
-    value = (value * 31) ^ hash(self.taskId)
-    value = (value * 31) ^ hash(self.taskType)
-    value = (value * 31) ^ hash(self.parentProcessId)
-    value = (value * 31) ^ hash(self.creationTime)
-    value = (value * 31) ^ hash(self.lastUpdateTime)
-    value = (value * 31) ^ hash(self.taskStatuses)
-    value = (value * 31) ^ hash(self.taskDetail)
-    value = (value * 31) ^ hash(self.subTaskModel)
-    value = (value * 31) ^ hash(self.taskErrors)
-    value = (value * 31) ^ hash(self.jobs)
-    return value
-
-  def __repr__(self):
-    L = ['%s=%r' % (key, value)
-      for key, value in self.__dict__.iteritems()]
-    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-  def __eq__(self, other):
-    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-  def __ne__(self, other):
-    return not (self == other)
-
-class DataStagingTaskModel:
-  """
-  Attributes:
-   - source
-   - destination
-   - type
-   - transferStartTime
-   - transferEndTime
-   - transferRate
-   - processInput
-   - processOutput
-  """
-
-  thrift_spec = (
-    None, # 0
-    (1, TType.STRING, 'source', None, None, ), # 1
-    (2, TType.STRING, 'destination', None, 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', None, 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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-      return
-    iprot.readStructBegin()
-    while True:
-      (fname, ftype, fid) = iprot.readFieldBegin()
-      if ftype == TType.STOP:
-        break
-      if fid == 1:
-        if ftype == TType.STRING:
-          self.source = iprot.readString()
-        else:
-          iprot.skip(ftype)
-      elif fid == 2:
-        if ftype == TType.STRING:
-          self.destination = 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()
-        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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-      return
-    oprot.writeStructBegin('DataStagingTaskModel')
-    if self.source is not None:
-      oprot.writeFieldBegin('source', TType.STRING, 1)
-      oprot.writeString(self.source)
-      oprot.writeFieldEnd()
-    if self.destination is not None:
-      oprot.writeFieldBegin('destination', TType.STRING, 2)
-      oprot.writeString(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)
-      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 TProtocol.TProtocolException(message='Required field source is unset!')
-    if self.destination is None:
-      raise TProtocol.TProtocolException(message='Required field destination is unset!')
-    if self.type is None:
-      raise TProtocol.TProtocolException(message='Required field type is unset!')
-    return
-
-
-  def __hash__(self):
-    value = 17
-    value = (value * 31) ^ hash(self.source)
-    value = (value * 31) ^ hash(self.destination)
-    value = (value * 31) ^ hash(self.type)
-    value = (value * 31) ^ hash(self.transferStartTime)
-    value = (value * 31) ^ hash(self.transferEndTime)
-    value = (value * 31) ^ hash(self.transferRate)
-    value = (value * 31) ^ hash(self.processInput)
-    value = (value * 31) ^ hash(self.processOutput)
-    return value
-
-  def __repr__(self):
-    L = ['%s=%r' % (key, value)
-      for key, value in self.__dict__.iteritems()]
-    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-  def __eq__(self, other):
-    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-  def __ne__(self, other):
-    return not (self == other)
-
-class EnvironmentSetupTaskModel:
-  """
-  EnvironmentSetupTaskModel: A structure holding the environment creation task details
-
-
-  Attributes:
-   - location
-   - protocol
-  """
-
-  thrift_spec = (
-    None, # 0
-    (1, TType.STRING, 'location', None, 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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-      return
-    iprot.readStructBegin()
-    while True:
-      (fname, ftype, fid) = iprot.readFieldBegin()
-      if ftype == TType.STOP:
-        break
-      if fid == 1:
-        if ftype == TType.STRING:
-          self.location = 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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-      return
-    oprot.writeStructBegin('EnvironmentSetupTaskModel')
-    if self.location is not None:
-      oprot.writeFieldBegin('location', TType.STRING, 1)
-      oprot.writeString(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 TProtocol.TProtocolException(message='Required field location is unset!')
-    if self.protocol is None:
-      raise TProtocol.TProtocolException(message='Required field protocol is unset!')
-    return
-
-
-  def __hash__(self):
-    value = 17
-    value = (value * 31) ^ hash(self.location)
-    value = (value * 31) ^ hash(self.protocol)
-    return value
-
-  def __repr__(self):
-    L = ['%s=%r' % (key, value)
-      for key, value in self.__dict__.iteritems()]
-    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-  def __eq__(self, other):
-    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-  def __ne__(self, other):
-    return not (self == other)
-
-class JobSubmissionTaskModel:
-  """
-  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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-      return
-    iprot.readStructBegin()
-    while True:
-      (fname, ftype, fid) = iprot.readFieldBegin()
-      if ftype == TType.STOP:
-        break
-      if fid == 1:
-        if ftype == TType.I32:
-          self.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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-      return
-    oprot.writeStructBegin('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 TProtocol.TProtocolException(message='Required field jobSubmissionProtocol is unset!')
-    if self.monitorMode is None:
-      raise TProtocol.TProtocolException(message='Required field monitorMode is unset!')
-    return
-
-
-  def __hash__(self):
-    value = 17
-    value = (value * 31) ^ hash(self.jobSubmissionProtocol)
-    value = (value * 31) ^ hash(self.monitorMode)
-    value = (value * 31) ^ hash(self.wallTime)
-    return value
-
-  def __repr__(self):
-    L = ['%s=%r' % (key, value)
-      for key, value in self.__dict__.iteritems()]
-    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-  def __eq__(self, other):
-    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-  def __ne__(self, other):
-    return not (self == other)
-
-class MonitorTaskModel:
-  """
-  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.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-      return
-    iprot.readStructBegin()
-    while True:
-      (fname, ftype, fid) = iprot.readFieldBegin()
-      if ftype == TType.STOP:
-        break
-      if fid == 1:
-        if ftype == TType.I32:
-          self.monitorMode = iprot.readI32()
-        else:
-          iprot.skip(ftype)
-      else:
-        iprot.skip(ftype)
-      iprot.readFieldEnd()
-    iprot.readStructEnd()
-
-  def write(self, oprot):
-    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-      return
-    oprot.writeStructBegin('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 TProtocol.TProtocolException(message='Required field monitorMode is unset!')
-    return
-
-
-  def __hash__(self):
-    value = 17
-    value = (value * 31) ^ hash(self.monitorMode)
-    return value
-
-  def __repr__(self):
-    L = ['%s=%r' % (key, value)
-      for key, value in self.__dict__.iteritems()]
-    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
-  def __eq__(self, other):
-    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
-  def __ne__(self, other):
-    return not (self == other)
+
+
+class 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/blob/14ff0916/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/tenant/constants.py
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/tenant/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/tenant/constants.py
index 4a6492b..eb0d35a 100644
--- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/tenant/constants.py
+++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/tenant/constants.py
@@ -1,11 +1,12 @@
 #
-# Autogenerated by Thrift Compiler (0.9.3)
+# 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, TException, TApplicationException
-from ttypes import *
-
+from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
+from thrift.protocol.TProtocol import TProtocolException
+import sys
+from .ttypes import *


Mime
View raw message