#
# Autogenerated by Thrift Compiler (0.10.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
#  options string: py
#

from thrift.Thrift import TType, TMessageType, TFrozenDict, TException, TApplicationException
from thrift.protocol.TProtocol import TProtocolException
import sys
import apache.airavata.model.commons.ttypes
import apache.airavata.model.appcatalog.computeresource.ttypes
import apache.airavata.model.data.movement.ttypes
import apache.airavata.model.application.io.ttypes
import apache.airavata.model.status.ttypes
import apache.airavata.model.job.ttypes

from thrift.transport import TTransport


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)