ExecutorMindHandler

The mind is a service the distributes “task” to executors

class DIRAC.Core.Base.ExecutorMindHandler.ExecutorMindHandler(handlerInitDict, trid)

Bases: DIRAC.Core.DISET.RequestHandler.RequestHandler

MSG_DEFINITIONS = {'ExecutorError': {'eType': (<class 'str'>, <class 'str'>), 'errorMsg': (<class 'str'>, <class 'str'>), 'taskId': (<class 'int'>,)}, 'ProcessTask': {'eType': (<class 'str'>, <class 'str'>), 'taskId': (<class 'int'>,), 'taskStub': (<class 'str'>, <class 'str'>)}, 'TaskDone': {'taskId': (<class 'int'>,), 'taskStub': (<class 'str'>, <class 'str'>)}, 'TaskError': {'eType': (<class 'str'>, <class 'str'>), 'errorMsg': (<class 'str'>, <class 'str'>), 'taskId': (<class 'int'>,), 'taskStub': (<class 'str'>, <class 'str'>)}, 'TaskFreeze': {'freezeTime': (<class 'int'>,), 'taskId': (<class 'int'>, <class 'str'>), 'taskStub': (<class 'str'>, <class 'str'>)}}
class MindCallbacks(sendTaskCB, dispatchCB, disconnectCB, taskProcCB, taskFreezeCB, taskErrCB)

Bases: DIRAC.Core.Utilities.ExecutorDispatcher.ExecutorDispatcherCallbacks

__init__(sendTaskCB, dispatchCB, disconnectCB, taskProcCB, taskFreezeCB, taskErrCB)
cbDisconectExecutor(eId)
cbDispatch(taskId, taskObj, pathExecuted)
cbSendTask(taskId, taskObj, eId, eType)
cbTaskError(taskId, taskObj, errorMsg)
cbTaskFreeze(taskId, taskObj, eType)
cbTaskProcessed(taskId, taskObj, eType)
__init__(handlerInitDict, trid)

Constructor

Parameters
  • handlerInitDict (dictionary) – Information vars for the service

  • trid (object) – Transport to use

auth_conn_connected = ['all']
auth_conn_drop = ['all']
auth_conn_new = ['all']
auth_msg_ExecutorError = ['all']
auth_msg_TaskDone = ['all']
auth_msg_TaskError = ['all']
auth_msg_TaskFreeze = ['all']
auth_ping = ['all']
auth_refreshConfiguration = ['CSAdministrator']
auth_whoami = ['all']
conn_connected(trid, identity, kwargs)
conn_drop(trid)
conn_new(trid, identity, kwargs)
classmethod exec_deserializeTask(taskStub)
classmethod exec_dispatch(taskId, taskObj, pathExecuted)
classmethod exec_executorConnected(execName, trid)
classmethod exec_executorDisconnected(trid)
classmethod exec_prepareToSend(taskId, taskObj, eId)
classmethod exec_serializeTask(taskObj)
classmethod exec_taskError(taskId, taskObj, errorMsg)
classmethod exec_taskFreeze(taskId, taskObj, eType)
classmethod exec_taskProcessed(taskId, taskObj, eType)
classmethod executeTask(taskId, taskObj)
static export_echo(data)

This method is used for testing performance of the service

Parameters

data (str) – data to be sent back to the caller

Returns

S_OK, Value is the input data

export_ping()
static export_refreshConfiguration(fromMaster)

Force refreshing the configuration data

Parameters

fromMaster (bool) – flag to refresh from the master configuration service

export_whoami()

A simple whoami, returns all credential dictionary, except certificate chain object.

classmethod forgetTask(taskId)
classmethod getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns

Value for serviceSection/optionName in the CS being defaultValue the default

classmethod getExecutorsConnected()
getRemoteAddress()

Get the address of the remote peer.

Returns

Address of remote peer.

getRemoteCredentials()

Get the credentials of the remote peer.

Returns

Credentials dictionary of remote peer.

classmethod getTaskIds()
initialize()

Initialize this instance of the handler (to be overwritten)

classmethod initializeHandler(serviceInfoDict)
msg_ExecutorError(msgObj)
msg_TaskDone(msgObj)
msg_TaskError(msgObj)
msg_TaskFreeze(msgObj)
classmethod setAllowedClients(aClients)
classmethod setFailedOnTooFrozen(value)
classmethod setFreezeOnFailedDispatch(value)
classmethod setFreezeOnUnknownExecutor(value)
srv_disconnect(trid=None)
classmethod srv_disconnectClient(trid)
srv_getActionTuple()
classmethod srv_getCSOption(optionName, defaultValue=False)

Get an option from the CS section of the services

Returns

Value for serviceSection/optionName in the CS being defaultValue the default

srv_getClientSetup()
srv_getClientVO()
srv_getClientVersion()
srv_getFormattedRemoteCredentials()
classmethod srv_getMonitor()
srv_getRemoteAddress()

Get the address of the remote peer.

Returns

Address of remote peer.

srv_getRemoteCredentials()

Get the credentials of the remote peer.

Returns

Credentials dictionary of remote peer.

classmethod srv_getServiceName()
srv_getTransportID()
classmethod srv_getURL()
classmethod srv_msgCreate(msgName)
srv_msgReply(msgObj)
classmethod srv_msgSend(trid, msgObj)
transfer_bulkFromClient(bulkId, token, bulkSize, fileHelper)
transfer_bulkToClient(bulkId, token, fileHelper)
transfer_fromClient(fileId, token, fileSize, fileHelper)
transfer_listBulk(bulkId, token, fileHelper)
transfer_toClient(fileId, token, fileHelper)
types_echo = [(<class 'str'>,)]
types_ping = []
types_refreshConfiguration = [<class 'bool'>]
types_whoami = []