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/group/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/constants.py index 4a6492b..eb0d35a 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/constants.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/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 *
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/group/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/ttypes.py index 996700b..17632e6 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/group/ttypes.py @@ -1,182 +1,169 @@ # -# 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 - from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None - - -class ResourceType: - PROJECT = 0 - EXPERIMENT = 1 - DATA = 2 - OTHER = 3 - - _VALUES_TO_NAMES = { - 0: "PROJECT", - 1: "EXPERIMENT", - 2: "DATA", - 3: "OTHER", - } - - _NAMES_TO_VALUES = { - "PROJECT": 0, - "EXPERIMENT": 1, - "DATA": 2, - "OTHER": 3, - } - -class ResourcePermissionType: - WRITE = 0 - READ = 1 - OWNER = 2 - - _VALUES_TO_NAMES = { - 0: "WRITE", - 1: "READ", - 2: "OWNER", - } - - _NAMES_TO_VALUES = { - "WRITE": 0, - "READ": 1, - "OWNER": 2, - } - - -class GroupModel: - """ - Attributes: - - id - - name - - ownerId - - description - - members - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'id', None, None, ), # 1 - (2, TType.STRING, 'name', None, None, ), # 2 - (3, TType.STRING, 'ownerId', None, None, ), # 3 - (4, TType.STRING, 'description', None, None, ), # 4 - (5, TType.LIST, 'members', (TType.STRING,None), None, ), # 5 - ) - - def __init__(self, id=None, name=None, ownerId=None, description=None, members=None,): - self.id = id - self.name = name - self.ownerId = ownerId - self.description = description - self.members = members - - 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.id = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.name = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.ownerId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.description = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.LIST: - self.members = [] - (_etype3, _size0) = iprot.readListBegin() - for _i4 in xrange(_size0): - _elem5 = iprot.readString() - self.members.append(_elem5) - 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('GroupModel') - if self.id is not None: - oprot.writeFieldBegin('id', TType.STRING, 1) - oprot.writeString(self.id) - oprot.writeFieldEnd() - if self.name is not None: - oprot.writeFieldBegin('name', TType.STRING, 2) - oprot.writeString(self.name) - oprot.writeFieldEnd() - if self.ownerId is not None: - oprot.writeFieldBegin('ownerId', TType.STRING, 3) - oprot.writeString(self.ownerId) - oprot.writeFieldEnd() - if self.description is not None: - oprot.writeFieldBegin('description', TType.STRING, 4) - oprot.writeString(self.description) - oprot.writeFieldEnd() - if self.members is not None: - oprot.writeFieldBegin('members', TType.LIST, 5) - oprot.writeListBegin(TType.STRING, len(self.members)) - for iter6 in self.members: - oprot.writeString(iter6) - oprot.writeListEnd() - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.id) - value = (value * 31) ^ hash(self.name) - value = (value * 31) ^ hash(self.ownerId) - value = (value * 31) ^ hash(self.description) - value = (value * 31) ^ hash(self.members) - 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 ResourceType(object): + PROJECT = 0 + EXPERIMENT = 1 + DATA = 2 + OTHER = 3 + + _VALUES_TO_NAMES = { + 0: "PROJECT", + 1: "EXPERIMENT", + 2: "DATA", + 3: "OTHER", + } + + _NAMES_TO_VALUES = { + "PROJECT": 0, + "EXPERIMENT": 1, + "DATA": 2, + "OTHER": 3, + } + + +class ResourcePermissionType(object): + WRITE = 0 + READ = 1 + OWNER = 2 + + _VALUES_TO_NAMES = { + 0: "WRITE", + 1: "READ", + 2: "OWNER", + } + + _NAMES_TO_VALUES = { + "WRITE": 0, + "READ": 1, + "OWNER": 2, + } + + +class GroupModel(object): + """ + Attributes: + - id + - name + - ownerId + - description + - members + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'id', 'UTF8', None, ), # 1 + (2, TType.STRING, 'name', 'UTF8', None, ), # 2 + (3, TType.STRING, 'ownerId', 'UTF8', None, ), # 3 + (4, TType.STRING, 'description', 'UTF8', None, ), # 4 + (5, TType.LIST, 'members', (TType.STRING, 'UTF8', False), None, ), # 5 + ) + + def __init__(self, id=None, name=None, ownerId=None, description=None, members=None,): + self.id = id + self.name = name + self.ownerId = ownerId + self.description = description + self.members = members + + 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.id = 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.name = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.ownerId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.description = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.members = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in range(_size0): + _elem5 = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + self.members.append(_elem5) + 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('GroupModel') + if self.id is not None: + oprot.writeFieldBegin('id', TType.STRING, 1) + oprot.writeString(self.id.encode('utf-8') if sys.version_info[0] == 2 else self.id) + oprot.writeFieldEnd() + if self.name is not None: + oprot.writeFieldBegin('name', TType.STRING, 2) + oprot.writeString(self.name.encode('utf-8') if sys.version_info[0] == 2 else self.name) + oprot.writeFieldEnd() + if self.ownerId is not None: + oprot.writeFieldBegin('ownerId', TType.STRING, 3) + oprot.writeString(self.ownerId.encode('utf-8') if sys.version_info[0] == 2 else self.ownerId) + oprot.writeFieldEnd() + if self.description is not None: + oprot.writeFieldBegin('description', TType.STRING, 4) + oprot.writeString(self.description.encode('utf-8') if sys.version_info[0] == 2 else self.description) + oprot.writeFieldEnd() + if self.members is not None: + oprot.writeFieldBegin('members', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.members)) + for iter6 in self.members: + oprot.writeString(iter6.encode('utf-8') if sys.version_info[0] == 2 else iter6) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.items()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) 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/job/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/constants.py index 4a6492b..eb0d35a 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/constants.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/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 * 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/job/ttypes.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/ttypes.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/ttypes.py index 52478a6..ed4e249 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/ttypes.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/job/ttypes.py @@ -1,245 +1,223 @@ # -# 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.status.ttypes - from thrift.transport import TTransport -from thrift.protocol import TBinaryProtocol, TProtocol -try: - from thrift.protocol import fastbinary -except: - fastbinary = None - - - -class JobModel: - """ - Attributes: - - jobId - - taskId - - processId - - jobDescription - - creationTime - - jobStatuses - - computeResourceConsumed - - jobName - - workingDir - - stdOut - - stdErr - - exitCode - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'jobId', None, None, ), # 1 - (2, TType.STRING, 'taskId', None, None, ), # 2 - (3, TType.STRING, 'processId', None, None, ), # 3 - (4, TType.STRING, 'jobDescription', None, None, ), # 4 - (5, TType.I64, 'creationTime', None, None, ), # 5 - (6, TType.LIST, 'jobStatuses', (TType.STRUCT,(apache.airavata.model.status.ttypes.JobStatus, apache.airavata.model.status.ttypes.JobStatus.thrift_spec)), None, ), # 6 - (7, TType.STRING, 'computeResourceConsumed', None, None, ), # 7 - (8, TType.STRING, 'jobName', None, None, ), # 8 - (9, TType.STRING, 'workingDir', None, None, ), # 9 - (10, TType.STRING, 'stdOut', None, None, ), # 10 - (11, TType.STRING, 'stdErr', None, None, ), # 11 - (12, TType.I32, 'exitCode', None, None, ), # 12 - ) - - def __init__(self, jobId=None, taskId=None, processId=None, jobDescription=None, creationTime=None, jobStatuses=None, computeResourceConsumed=None, jobName=None, workingDir=None, stdOut=None, stdErr=None, exitCode=None,): - self.jobId = jobId - self.taskId = taskId - self.processId = processId - self.jobDescription = jobDescription - self.creationTime = creationTime - self.jobStatuses = jobStatuses - self.computeResourceConsumed = computeResourceConsumed - self.jobName = jobName - self.workingDir = workingDir - self.stdOut = stdOut - self.stdErr = stdErr - self.exitCode = exitCode - - 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.jobId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.taskId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRING: - self.processId = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRING: - self.jobDescription = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.I64: - self.creationTime = iprot.readI64() - else: - iprot.skip(ftype) - elif fid == 6: - if ftype == TType.LIST: - self.jobStatuses = [] - (_etype3, _size0) = iprot.readListBegin() - for _i4 in xrange(_size0): - _elem5 = apache.airavata.model.status.ttypes.JobStatus() - _elem5.read(iprot) - self.jobStatuses.append(_elem5) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 7: - if ftype == TType.STRING: - self.computeResourceConsumed = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 8: - if ftype == TType.STRING: - self.jobName = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 9: - if ftype == TType.STRING: - self.workingDir = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 10: - if ftype == TType.STRING: - self.stdOut = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 11: - if ftype == TType.STRING: - self.stdErr = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 12: - if ftype == TType.I32: - self.exitCode = 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('JobModel') - if self.jobId is not None: - oprot.writeFieldBegin('jobId', TType.STRING, 1) - oprot.writeString(self.jobId) - oprot.writeFieldEnd() - if self.taskId is not None: - oprot.writeFieldBegin('taskId', TType.STRING, 2) - oprot.writeString(self.taskId) - oprot.writeFieldEnd() - if self.processId is not None: - oprot.writeFieldBegin('processId', TType.STRING, 3) - oprot.writeString(self.processId) - oprot.writeFieldEnd() - if self.jobDescription is not None: - oprot.writeFieldBegin('jobDescription', TType.STRING, 4) - oprot.writeString(self.jobDescription) - oprot.writeFieldEnd() - if self.creationTime is not None: - oprot.writeFieldBegin('creationTime', TType.I64, 5) - oprot.writeI64(self.creationTime) - oprot.writeFieldEnd() - if self.jobStatuses is not None: - oprot.writeFieldBegin('jobStatuses', TType.LIST, 6) - oprot.writeListBegin(TType.STRUCT, len(self.jobStatuses)) - for iter6 in self.jobStatuses: - iter6.write(oprot) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.computeResourceConsumed is not None: - oprot.writeFieldBegin('computeResourceConsumed', TType.STRING, 7) - oprot.writeString(self.computeResourceConsumed) - oprot.writeFieldEnd() - if self.jobName is not None: - oprot.writeFieldBegin('jobName', TType.STRING, 8) - oprot.writeString(self.jobName) - oprot.writeFieldEnd() - if self.workingDir is not None: - oprot.writeFieldBegin('workingDir', TType.STRING, 9) - oprot.writeString(self.workingDir) - oprot.writeFieldEnd() - if self.stdOut is not None: - oprot.writeFieldBegin('stdOut', TType.STRING, 10) - oprot.writeString(self.stdOut) - oprot.writeFieldEnd() - if self.stdErr is not None: - oprot.writeFieldBegin('stdErr', TType.STRING, 11) - oprot.writeString(self.stdErr) - oprot.writeFieldEnd() - if self.exitCode is not None: - oprot.writeFieldBegin('exitCode', TType.I32, 12) - oprot.writeI32(self.exitCode) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - if self.jobId is None: - raise TProtocol.TProtocolException(message='Required field jobId is unset!') - if self.taskId is None: - raise TProtocol.TProtocolException(message='Required field taskId is unset!') - if self.processId is None: - raise TProtocol.TProtocolException(message='Required field processId is unset!') - if self.jobDescription is None: - raise TProtocol.TProtocolException(message='Required field jobDescription is unset!') - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.jobId) - value = (value * 31) ^ hash(self.taskId) - value = (value * 31) ^ hash(self.processId) - value = (value * 31) ^ hash(self.jobDescription) - value = (value * 31) ^ hash(self.creationTime) - value = (value * 31) ^ hash(self.jobStatuses) - value = (value * 31) ^ hash(self.computeResourceConsumed) - value = (value * 31) ^ hash(self.jobName) - value = (value * 31) ^ hash(self.workingDir) - value = (value * 31) ^ hash(self.stdOut) - value = (value * 31) ^ hash(self.stdErr) - value = (value * 31) ^ hash(self.exitCode) - 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 JobModel(object): + """ + Attributes: + - jobId + - taskId + - processId + - jobDescription + - creationTime + - jobStatuses + - computeResourceConsumed + - jobName + - workingDir + - stdOut + - stdErr + - exitCode + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'jobId', 'UTF8', None, ), # 1 + (2, TType.STRING, 'taskId', 'UTF8', None, ), # 2 + (3, TType.STRING, 'processId', 'UTF8', None, ), # 3 + (4, TType.STRING, 'jobDescription', 'UTF8', None, ), # 4 + (5, TType.I64, 'creationTime', None, None, ), # 5 + (6, TType.LIST, 'jobStatuses', (TType.STRUCT, (apache.airavata.model.status.ttypes.JobStatus, apache.airavata.model.status.ttypes.JobStatus.thrift_spec), False), None, ), # 6 + (7, TType.STRING, 'computeResourceConsumed', 'UTF8', None, ), # 7 + (8, TType.STRING, 'jobName', 'UTF8', None, ), # 8 + (9, TType.STRING, 'workingDir', 'UTF8', None, ), # 9 + (10, TType.STRING, 'stdOut', 'UTF8', None, ), # 10 + (11, TType.STRING, 'stdErr', 'UTF8', None, ), # 11 + (12, TType.I32, 'exitCode', None, None, ), # 12 + ) + + def __init__(self, jobId=None, taskId=None, processId=None, jobDescription=None, creationTime=None, jobStatuses=None, computeResourceConsumed=None, jobName=None, workingDir=None, stdOut=None, stdErr=None, exitCode=None,): + self.jobId = jobId + self.taskId = taskId + self.processId = processId + self.jobDescription = jobDescription + self.creationTime = creationTime + self.jobStatuses = jobStatuses + self.computeResourceConsumed = computeResourceConsumed + self.jobName = jobName + self.workingDir = workingDir + self.stdOut = stdOut + self.stdErr = stdErr + self.exitCode = exitCode + + def read(self, iprot): + if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None: + iprot._fast_decode(self, iprot, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.jobId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.taskId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.processId = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.jobDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.I64: + self.creationTime = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.LIST: + self.jobStatuses = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in range(_size0): + _elem5 = apache.airavata.model.status.ttypes.JobStatus() + _elem5.read(iprot) + self.jobStatuses.append(_elem5) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.STRING: + self.computeResourceConsumed = 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.jobName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 9: + if ftype == TType.STRING: + self.workingDir = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 10: + if ftype == TType.STRING: + self.stdOut = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 11: + if ftype == TType.STRING: + self.stdErr = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString() + else: + iprot.skip(ftype) + elif fid == 12: + if ftype == TType.I32: + self.exitCode = 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('JobModel') + if self.jobId is not None: + oprot.writeFieldBegin('jobId', TType.STRING, 1) + oprot.writeString(self.jobId.encode('utf-8') if sys.version_info[0] == 2 else self.jobId) + oprot.writeFieldEnd() + if self.taskId is not None: + oprot.writeFieldBegin('taskId', TType.STRING, 2) + oprot.writeString(self.taskId.encode('utf-8') if sys.version_info[0] == 2 else self.taskId) + oprot.writeFieldEnd() + if self.processId is not None: + oprot.writeFieldBegin('processId', TType.STRING, 3) + oprot.writeString(self.processId.encode('utf-8') if sys.version_info[0] == 2 else self.processId) + oprot.writeFieldEnd() + if self.jobDescription is not None: + oprot.writeFieldBegin('jobDescription', TType.STRING, 4) + oprot.writeString(self.jobDescription.encode('utf-8') if sys.version_info[0] == 2 else self.jobDescription) + oprot.writeFieldEnd() + if self.creationTime is not None: + oprot.writeFieldBegin('creationTime', TType.I64, 5) + oprot.writeI64(self.creationTime) + oprot.writeFieldEnd() + if self.jobStatuses is not None: + oprot.writeFieldBegin('jobStatuses', TType.LIST, 6) + oprot.writeListBegin(TType.STRUCT, len(self.jobStatuses)) + for iter6 in self.jobStatuses: + iter6.write(oprot) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.computeResourceConsumed is not None: + oprot.writeFieldBegin('computeResourceConsumed', TType.STRING, 7) + oprot.writeString(self.computeResourceConsumed.encode('utf-8') if sys.version_info[0] == 2 else self.computeResourceConsumed) + oprot.writeFieldEnd() + if self.jobName is not None: + oprot.writeFieldBegin('jobName', TType.STRING, 8) + oprot.writeString(self.jobName.encode('utf-8') if sys.version_info[0] == 2 else self.jobName) + oprot.writeFieldEnd() + if self.workingDir is not None: + oprot.writeFieldBegin('workingDir', TType.STRING, 9) + oprot.writeString(self.workingDir.encode('utf-8') if sys.version_info[0] == 2 else self.workingDir) + oprot.writeFieldEnd() + if self.stdOut is not None: + oprot.writeFieldBegin('stdOut', TType.STRING, 10) + oprot.writeString(self.stdOut.encode('utf-8') if sys.version_info[0] == 2 else self.stdOut) + oprot.writeFieldEnd() + if self.stdErr is not None: + oprot.writeFieldBegin('stdErr', TType.STRING, 11) + oprot.writeString(self.stdErr.encode('utf-8') if sys.version_info[0] == 2 else self.stdErr) + oprot.writeFieldEnd() + if self.exitCode is not None: + oprot.writeFieldBegin('exitCode', TType.I32, 12) + oprot.writeI32(self.exitCode) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.jobId is None: + raise TProtocolException(message='Required field jobId is unset!') + if self.taskId is None: + raise TProtocolException(message='Required field taskId is unset!') + if self.processId is None: + raise TProtocolException(message='Required field processId is unset!') + if self.jobDescription is None: + raise TProtocolException(message='Required field jobDescription 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/messaging/event/constants.py ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/messaging/event/constants.py b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/messaging/event/constants.py index 4a6492b..eb0d35a 100644 --- a/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/messaging/event/constants.py +++ b/airavata-api/airavata-client-sdks/airavata-python-sdk/src/main/resources/lib/apache/airavata/model/messaging/event/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 *
