JobPath

The Job Path Agent 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. The next development will be to explicitly specify the path through the optimizers.

class DIRAC.WorkloadManagementSystem.Executor.JobPath.JobPath

Bases: DIRAC.WorkloadManagementSystem.Executor.Base.OptimizerExecutor.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

class JobLog(log, jid)
class LogWrap(log, jid, funcName)
__init__(log, jid, funcName)
__init__(log, jid)
__init__

x.__init__(…) initializes x; see help(type(x)) for signature

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()
jobLog
optimizeJob(jid, jobState)
processTask(jid, jobState)
retrieveOptimizerParam(name)
serializeTask(cjs)
setNextOptimizer(jobState=None)
storeOptimizerParam(name, value)