JobPath

The Job Path executor determines the chain of Optimizing Agents that must work on the job prior to the scheduling decision.

Initially this takes jobs in the received state and starts the jobs on the optimizer chain.

class DIRAC.WorkloadManagementSystem.Executor.JobPath.JobPath

Bases: OptimizerExecutor

The specific Optimizer must provide the following methods: - optimizeJob() - the main method called for each job and it can provide: - initializeOptimizer() before each execution cycle

deserializeTask(taskStub)
disableFastTrackForTask()
classmethod ex_enabled()
classmethod ex_getExtraArguments()
classmethod ex_getMind()
classmethod ex_getOption(optName, defaultValue=None)
classmethod ex_getProperty(optName)
classmethod ex_optimizerName()
classmethod ex_setMind(mindName, **extraArgs)
classmethod ex_setOption(optName, value)
classmethod ex_setProperty(optName, value)
fastTrackDispatch(jid, jobState)
freezeTask(freezeTime)
classmethod initialize()
classmethod initializeOptimizer()
isTaskFrozen()
property jobLog
optimizeJob(jid, jobState)
processTask(jid, jobState)
retrieveOptimizerParam(name)
serializeTask(cjs)
setNextOptimizer(jobState=None)
storeOptimizerParam(name, value)