ExecutorDispatcher

Used by the executors for dispatching events (IIUC)

class DIRAC.Core.Utilities.ExecutorDispatcher.ExecutorDispatcher(monitor=None)
class ETask(taskId, taskObj)
addExecutor(eId, eTypes, maxTasks=1)
addTask(taskId, taskObj)
freezeTask(eId, taskId, freezeTime, taskObj=False)
getExecutorsConnected()
getTask(taskId)
getTaskIds()
removeExecutor(eId)
removeTask(taskId)
retryTask(eId, taskId)
setCallbacks(callbacksObj)
setFailedOnTooFrozen(value)
setFreezeOnFailedDispatch(value)
setFreezeOnUnknownExecutor(value)
taskProcessed(eId, taskId, taskObj=False)
class DIRAC.Core.Utilities.ExecutorDispatcher.ExecutorDispatcherCallbacks
cbDisconectExecutor(eId)
cbDispatch(taskId, taskObj, pathExecuted)
cbSendTask(taskId, taskObj, eId, eType)
cbTaskError(taskId, taskObj, errorMsg)
cbTaskFreeze(taskId, taskObj, eType)
cbTaskProcessed(taskId, taskObj, eType)
class DIRAC.Core.Utilities.ExecutorDispatcher.ExecutorQueues(log=False)
deleteTask(taskId)
getExecutorList()
getState()
popTask(eTypes)
pushTask(eType, taskId, ahead=False)
waitingTasks(eType)
class DIRAC.Core.Utilities.ExecutorDispatcher.ExecutorState(log=False)

Bases: object

addExecutor(eId, eTypes, maxTasks=1)
addTask(eId, taskId)
freeSlots(eId)
full(eId)
getExecutorOfTask(taskId)
getFreeExecutors(eType)
getIdleExecutor(eType)
getTasksForExecutor(eId)
removeExecutor(eId)
removeTask(taskId, eId=None)