You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ma...@apache.org on 2017/08/07 14:01:07 UTC
[31/51] [abbrv] [partial] airavata git commit: AIRAVATA-2505 Upgrade
Airavata to Thrift 0.10.0
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 *