Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 6A3C8200CDD for ; Mon, 7 Aug 2017 16:55:36 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 68F71165741; Mon, 7 Aug 2017 14:55:36 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id A0351165745 for ; Mon, 7 Aug 2017 16:55:33 +0200 (CEST) Received: (qmail 19212 invoked by uid 500); 7 Aug 2017 14:55:32 -0000 Mailing-List: contact commits-help@airavata.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airavata.apache.org Delivered-To: mailing list commits@airavata.apache.org Received: (qmail 17357 invoked by uid 99); 7 Aug 2017 14:55:30 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 07 Aug 2017 14:55:30 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 4F9B3F5ED3; Mon, 7 Aug 2017 14:55:28 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: machristie@apache.org To: commits@airavata.apache.org Date: Mon, 07 Aug 2017 14:55:56 -0000 Message-Id: <578a28da75a345c98f572e037fe1c925@git.apache.org> In-Reply-To: <3c67660f922b46c3b5d43e7f7bfa96ab@git.apache.org> References: <3c67660f922b46c3b5d43e7f7bfa96ab@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [31/51] [abbrv] [partial] airavata git commit: AIRAVATA-2505 Upgrade Airavata to Thrift 0.10.0 archived-at: Mon, 07 Aug 2017 14:55:36 -0000 http://git-wip-us.apache.org/repos/asf/airavata/blob/39fba1f5/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/39fba1f5/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 *