#
# 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.parallelism.ttypes

from thrift.transport import TTransport


class SetEnvPaths(object):
    """
    Key Value pairs to be used to set environments

    name:
      Name of the environment variable such as PATH, LD_LIBRARY_PATH, NETCDF_HOME.

    value:
      Value of the environment variable to set

    envPathOrder:
      The order of the setting of the env variables when there are multiple env variables

    Attributes:
     - name
     - value
     - envPathOrder
    """

    thrift_spec = (
        None,  # 0
        (1, TType.STRING, 'name', 'UTF8', None, ),  # 1
        (2, TType.STRING, 'value', 'UTF8', None, ),  # 2
        (3, TType.I32, 'envPathOrder', None, None, ),  # 3
    )

    def __init__(self, name=None, value=None, envPathOrder=None,):
        self.name = name
        self.value = value
        self.envPathOrder = envPathOrder

    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.name = 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.value = 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.envPathOrder = 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('SetEnvPaths')
        if self.name is not None:
            oprot.writeFieldBegin('name', TType.STRING, 1)
            oprot.writeString(self.name.encode('utf-8') if sys.version_info[0] == 2 else self.name)
            oprot.writeFieldEnd()
        if self.value is not None:
            oprot.writeFieldBegin('value', TType.STRING, 2)
            oprot.writeString(self.value.encode('utf-8') if sys.version_info[0] == 2 else self.value)
            oprot.writeFieldEnd()
        if self.envPathOrder is not None:
            oprot.writeFieldBegin('envPathOrder', TType.I32, 3)
            oprot.writeI32(self.envPathOrder)
            oprot.writeFieldEnd()
        oprot.writeFieldStop()
        oprot.writeStructEnd()

    def validate(self):
        if self.name is None:
            raise TProtocolException(message='Required field name is unset!')
        if self.value is None:
            raise TProtocolException(message='Required field value 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 CommandObject(object):
    """
    Job commands to be used in Pre Job, Post Job and Module Load Commands

    command:
      The actual command in string format

    commandOrder:
      Order of the command in the multiple command situation

    Attributes:
     - command
     - commandOrder
    """

    thrift_spec = (
        None,  # 0
        (1, TType.STRING, 'command', 'UTF8', None, ),  # 1
        (2, TType.I32, 'commandOrder', None, None, ),  # 2
    )

    def __init__(self, command=None, commandOrder=None,):
        self.command = command
        self.commandOrder = commandOrder

    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.command = 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.commandOrder = 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('CommandObject')
        if self.command is not None:
            oprot.writeFieldBegin('command', TType.STRING, 1)
            oprot.writeString(self.command.encode('utf-8') if sys.version_info[0] == 2 else self.command)
            oprot.writeFieldEnd()
        if self.commandOrder is not None:
            oprot.writeFieldBegin('commandOrder', TType.I32, 2)
            oprot.writeI32(self.commandOrder)
            oprot.writeFieldEnd()
        oprot.writeFieldStop()
        oprot.writeStructEnd()

    def validate(self):
        if self.command is None:
            raise TProtocolException(message='Required field command 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 ApplicationModule(object):
    """
    Application Module Information. A module has to be registered before registering a deployment.

    appModuleId: Airavata Internal Unique Job ID. This is set by the registry.

    appModuleName:
      Name of the application module.

    appModuleVersion:
      Version of the application.

    appModuleDescription:
       Descriprion of the Module


    Attributes:
     - appModuleId
     - appModuleName
     - appModuleVersion
     - appModuleDescription
    """

    thrift_spec = (
        None,  # 0
        (1, TType.STRING, 'appModuleId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ),  # 1
        (2, TType.STRING, 'appModuleName', 'UTF8', None, ),  # 2
        (3, TType.STRING, 'appModuleVersion', 'UTF8', None, ),  # 3
        (4, TType.STRING, 'appModuleDescription', 'UTF8', None, ),  # 4
    )

    def __init__(self, appModuleId=thrift_spec[1][4], appModuleName=None, appModuleVersion=None, appModuleDescription=None,):
        self.appModuleId = appModuleId
        self.appModuleName = appModuleName
        self.appModuleVersion = appModuleVersion
        self.appModuleDescription = appModuleDescription

    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.appModuleId = 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.appModuleName = 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.appModuleVersion = 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.appModuleDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
                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('ApplicationModule')
        if self.appModuleId is not None:
            oprot.writeFieldBegin('appModuleId', TType.STRING, 1)
            oprot.writeString(self.appModuleId.encode('utf-8') if sys.version_info[0] == 2 else self.appModuleId)
            oprot.writeFieldEnd()
        if self.appModuleName is not None:
            oprot.writeFieldBegin('appModuleName', TType.STRING, 2)
            oprot.writeString(self.appModuleName.encode('utf-8') if sys.version_info[0] == 2 else self.appModuleName)
            oprot.writeFieldEnd()
        if self.appModuleVersion is not None:
            oprot.writeFieldBegin('appModuleVersion', TType.STRING, 3)
            oprot.writeString(self.appModuleVersion.encode('utf-8') if sys.version_info[0] == 2 else self.appModuleVersion)
            oprot.writeFieldEnd()
        if self.appModuleDescription is not None:
            oprot.writeFieldBegin('appModuleDescription', TType.STRING, 4)
            oprot.writeString(self.appModuleDescription.encode('utf-8') if sys.version_info[0] == 2 else self.appModuleDescription)
            oprot.writeFieldEnd()
        oprot.writeFieldStop()
        oprot.writeStructEnd()

    def validate(self):
        if self.appModuleId is None:
            raise TProtocolException(message='Required field appModuleId is unset!')
        if self.appModuleName is None:
            raise TProtocolException(message='Required field appModuleName 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 ApplicationDeploymentDescription(object):
    """
    Application Deployment Description

    appDeploymentId: Airavata Internal Unique Job ID. This is set by the registry.

    appModuleName:
      Application Module Name. This has to be precise describing the binary.

    computeHostId:
      This ID maps application deployment to a particular resource previously described within Airavata.
      Example: Stampede is first registered and refered when registering WRF.

    moduleLoadCmd:
     Command string to load modules. This will be placed in the job submisison
     Ex: module load amber

    libPrependPaths:
     prepend to a path variable the value

    libAppendPaths:
     append to a path variable the value

    setEnvironment:
     assigns to the environment variable "NAME" the value


    Attributes:
     - appDeploymentId
     - appModuleId
     - computeHostId
     - executablePath
     - parallelism
     - appDeploymentDescription
     - moduleLoadCmds
     - libPrependPaths
     - libAppendPaths
     - setEnvironment
     - preJobCommands
     - postJobCommands
     - defaultQueueName
     - defaultNodeCount
     - defaultCPUCount
     - editableByUser
    """

    thrift_spec = (
        None,  # 0
        (1, TType.STRING, 'appDeploymentId', 'UTF8', "DO_NOT_SET_AT_CLIENTS", ),  # 1
        (2, TType.STRING, 'appModuleId', 'UTF8', None, ),  # 2
        (3, TType.STRING, 'computeHostId', 'UTF8', None, ),  # 3
        (4, TType.STRING, 'executablePath', 'UTF8', None, ),  # 4
        (5, TType.I32, 'parallelism', None, 0, ),  # 5
        (6, TType.STRING, 'appDeploymentDescription', 'UTF8', None, ),  # 6
        (7, TType.LIST, 'moduleLoadCmds', (TType.STRUCT, (CommandObject, CommandObject.thrift_spec), False), None, ),  # 7
        (8, TType.LIST, 'libPrependPaths', (TType.STRUCT, (SetEnvPaths, SetEnvPaths.thrift_spec), False), None, ),  # 8
        (9, TType.LIST, 'libAppendPaths', (TType.STRUCT, (SetEnvPaths, SetEnvPaths.thrift_spec), False), None, ),  # 9
        (10, TType.LIST, 'setEnvironment', (TType.STRUCT, (SetEnvPaths, SetEnvPaths.thrift_spec), False), None, ),  # 10
        (11, TType.LIST, 'preJobCommands', (TType.STRUCT, (CommandObject, CommandObject.thrift_spec), False), None, ),  # 11
        (12, TType.LIST, 'postJobCommands', (TType.STRUCT, (CommandObject, CommandObject.thrift_spec), False), None, ),  # 12
        (13, TType.STRING, 'defaultQueueName', 'UTF8', None, ),  # 13
        (14, TType.I32, 'defaultNodeCount', None, None, ),  # 14
        (15, TType.I32, 'defaultCPUCount', None, None, ),  # 15
        (16, TType.BOOL, 'editableByUser', None, None, ),  # 16
    )

    def __init__(self, appDeploymentId=thrift_spec[1][4], appModuleId=None, computeHostId=None, executablePath=None, parallelism=thrift_spec[5][4], appDeploymentDescription=None, moduleLoadCmds=None, libPrependPaths=None, libAppendPaths=None, setEnvironment=None, preJobCommands=None, postJobCommands=None, defaultQueueName=None, defaultNodeCount=None, defaultCPUCount=None, editableByUser=None,):
        self.appDeploymentId = appDeploymentId
        self.appModuleId = appModuleId
        self.computeHostId = computeHostId
        self.executablePath = executablePath
        self.parallelism = parallelism
        self.appDeploymentDescription = appDeploymentDescription
        self.moduleLoadCmds = moduleLoadCmds
        self.libPrependPaths = libPrependPaths
        self.libAppendPaths = libAppendPaths
        self.setEnvironment = setEnvironment
        self.preJobCommands = preJobCommands
        self.postJobCommands = postJobCommands
        self.defaultQueueName = defaultQueueName
        self.defaultNodeCount = defaultNodeCount
        self.defaultCPUCount = defaultCPUCount
        self.editableByUser = editableByUser

    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.appDeploymentId = 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.appModuleId = 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.computeHostId = 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.executablePath = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
                else:
                    iprot.skip(ftype)
            elif fid == 5:
                if ftype == TType.I32:
                    self.parallelism = iprot.readI32()
                else:
                    iprot.skip(ftype)
            elif fid == 6:
                if ftype == TType.STRING:
                    self.appDeploymentDescription = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
                else:
                    iprot.skip(ftype)
            elif fid == 7:
                if ftype == TType.LIST:
                    self.moduleLoadCmds = []
                    (_etype3, _size0) = iprot.readListBegin()
                    for _i4 in range(_size0):
                        _elem5 = CommandObject()
                        _elem5.read(iprot)
                        self.moduleLoadCmds.append(_elem5)
                    iprot.readListEnd()
                else:
                    iprot.skip(ftype)
            elif fid == 8:
                if ftype == TType.LIST:
                    self.libPrependPaths = []
                    (_etype9, _size6) = iprot.readListBegin()
                    for _i10 in range(_size6):
                        _elem11 = SetEnvPaths()
                        _elem11.read(iprot)
                        self.libPrependPaths.append(_elem11)
                    iprot.readListEnd()
                else:
                    iprot.skip(ftype)
            elif fid == 9:
                if ftype == TType.LIST:
                    self.libAppendPaths = []
                    (_etype15, _size12) = iprot.readListBegin()
                    for _i16 in range(_size12):
                        _elem17 = SetEnvPaths()
                        _elem17.read(iprot)
                        self.libAppendPaths.append(_elem17)
                    iprot.readListEnd()
                else:
                    iprot.skip(ftype)
            elif fid == 10:
                if ftype == TType.LIST:
                    self.setEnvironment = []
                    (_etype21, _size18) = iprot.readListBegin()
                    for _i22 in range(_size18):
                        _elem23 = SetEnvPaths()
                        _elem23.read(iprot)
                        self.setEnvironment.append(_elem23)
                    iprot.readListEnd()
                else:
                    iprot.skip(ftype)
            elif fid == 11:
                if ftype == TType.LIST:
                    self.preJobCommands = []
                    (_etype27, _size24) = iprot.readListBegin()
                    for _i28 in range(_size24):
                        _elem29 = CommandObject()
                        _elem29.read(iprot)
                        self.preJobCommands.append(_elem29)
                    iprot.readListEnd()
                else:
                    iprot.skip(ftype)
            elif fid == 12:
                if ftype == TType.LIST:
                    self.postJobCommands = []
                    (_etype33, _size30) = iprot.readListBegin()
                    for _i34 in range(_size30):
                        _elem35 = CommandObject()
                        _elem35.read(iprot)
                        self.postJobCommands.append(_elem35)
                    iprot.readListEnd()
                else:
                    iprot.skip(ftype)
            elif fid == 13:
                if ftype == TType.STRING:
                    self.defaultQueueName = iprot.readString().decode('utf-8') if sys.version_info[0] == 2 else iprot.readString()
                else:
                    iprot.skip(ftype)
            elif fid == 14:
                if ftype == TType.I32:
                    self.defaultNodeCount = iprot.readI32()
                else:
                    iprot.skip(ftype)
            elif fid == 15:
                if ftype == TType.I32:
                    self.defaultCPUCount = iprot.readI32()
                else:
                    iprot.skip(ftype)
            elif fid == 16:
                if ftype == TType.BOOL:
                    self.editableByUser = iprot.readBool()
                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('ApplicationDeploymentDescription')
        if self.appDeploymentId is not None:
            oprot.writeFieldBegin('appDeploymentId', TType.STRING, 1)
            oprot.writeString(self.appDeploymentId.encode('utf-8') if sys.version_info[0] == 2 else self.appDeploymentId)
            oprot.writeFieldEnd()
        if self.appModuleId is not None:
            oprot.writeFieldBegin('appModuleId', TType.STRING, 2)
            oprot.writeString(self.appModuleId.encode('utf-8') if sys.version_info[0] == 2 else self.appModuleId)
            oprot.writeFieldEnd()
        if self.computeHostId is not None:
            oprot.writeFieldBegin('computeHostId', TType.STRING, 3)
            oprot.writeString(self.computeHostId.encode('utf-8') if sys.version_info[0] == 2 else self.computeHostId)
            oprot.writeFieldEnd()
        if self.executablePath is not None:
            oprot.writeFieldBegin('executablePath', TType.STRING, 4)
            oprot.writeString(self.executablePath.encode('utf-8') if sys.version_info[0] == 2 else self.executablePath)
            oprot.writeFieldEnd()
        if self.parallelism is not None:
            oprot.writeFieldBegin('parallelism', TType.I32, 5)
            oprot.writeI32(self.parallelism)
            oprot.writeFieldEnd()
        if self.appDeploymentDescription is not None:
            oprot.writeFieldBegin('appDeploymentDescription', TType.STRING, 6)
            oprot.writeString(self.appDeploymentDescription.encode('utf-8') if sys.version_info[0] == 2 else self.appDeploymentDescription)
            oprot.writeFieldEnd()
        if self.moduleLoadCmds is not None:
            oprot.writeFieldBegin('moduleLoadCmds', TType.LIST, 7)
            oprot.writeListBegin(TType.STRUCT, len(self.moduleLoadCmds))
            for iter36 in self.moduleLoadCmds:
                iter36.write(oprot)
            oprot.writeListEnd()
            oprot.writeFieldEnd()
        if self.libPrependPaths is not None:
            oprot.writeFieldBegin('libPrependPaths', TType.LIST, 8)
            oprot.writeListBegin(TType.STRUCT, len(self.libPrependPaths))
            for iter37 in self.libPrependPaths:
                iter37.write(oprot)
            oprot.writeListEnd()
            oprot.writeFieldEnd()
        if self.libAppendPaths is not None:
            oprot.writeFieldBegin('libAppendPaths', TType.LIST, 9)
            oprot.writeListBegin(TType.STRUCT, len(self.libAppendPaths))
            for iter38 in self.libAppendPaths:
                iter38.write(oprot)
            oprot.writeListEnd()
            oprot.writeFieldEnd()
        if self.setEnvironment is not None:
            oprot.writeFieldBegin('setEnvironment', TType.LIST, 10)
            oprot.writeListBegin(TType.STRUCT, len(self.setEnvironment))
            for iter39 in self.setEnvironment:
                iter39.write(oprot)
            oprot.writeListEnd()
            oprot.writeFieldEnd()
        if self.preJobCommands is not None:
            oprot.writeFieldBegin('preJobCommands', TType.LIST, 11)
            oprot.writeListBegin(TType.STRUCT, len(self.preJobCommands))
            for iter40 in self.preJobCommands:
                iter40.write(oprot)
            oprot.writeListEnd()
            oprot.writeFieldEnd()
        if self.postJobCommands is not None:
            oprot.writeFieldBegin('postJobCommands', TType.LIST, 12)
            oprot.writeListBegin(TType.STRUCT, len(self.postJobCommands))
            for iter41 in self.postJobCommands:
                iter41.write(oprot)
            oprot.writeListEnd()
            oprot.writeFieldEnd()
        if self.defaultQueueName is not None:
            oprot.writeFieldBegin('defaultQueueName', TType.STRING, 13)
            oprot.writeString(self.defaultQueueName.encode('utf-8') if sys.version_info[0] == 2 else self.defaultQueueName)
            oprot.writeFieldEnd()
        if self.defaultNodeCount is not None:
            oprot.writeFieldBegin('defaultNodeCount', TType.I32, 14)
            oprot.writeI32(self.defaultNodeCount)
            oprot.writeFieldEnd()
        if self.defaultCPUCount is not None:
            oprot.writeFieldBegin('defaultCPUCount', TType.I32, 15)
            oprot.writeI32(self.defaultCPUCount)
            oprot.writeFieldEnd()
        if self.editableByUser is not None:
            oprot.writeFieldBegin('editableByUser', TType.BOOL, 16)
            oprot.writeBool(self.editableByUser)
            oprot.writeFieldEnd()
        oprot.writeFieldStop()
        oprot.writeStructEnd()

    def validate(self):
        if self.appDeploymentId is None:
            raise TProtocolException(message='Required field appDeploymentId is unset!')
        if self.appModuleId is None:
            raise TProtocolException(message='Required field appModuleId is unset!')
        if self.computeHostId is None:
            raise TProtocolException(message='Required field computeHostId is unset!')
        if self.executablePath is None:
            raise TProtocolException(message='Required field executablePath is unset!')
        if self.parallelism is None:
            raise TProtocolException(message='Required field parallelism 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)