JobAgent

The Job Agent class instantiates a CE that acts as a client to a compute resource and also to the WMS. The Job Agent constructs a classAd based on the local resource description in the CS and the current resource status that is used for matching.

class DIRAC.WorkloadManagementSystem.Agent.JobAgent.JobAgent(agentName, loadName, baseAgentName=False, properties=None)

Bases: DIRAC.Core.Base.AgentModule.AgentModule

This agent is what runs in a worker node. The pilot runs it, after having prepared its configuration.

__init__(agentName, loadName, baseAgentName=False, properties=None)

Just defines some default parameters

am_Enabled()
am_checkStopAgentFile()
am_createStopAgentFile()
am_disableMonitoring()
am_getBasePath()
am_getControlDirectory()
am_getCyclesDone()
am_getMaxCycles()
am_getModuleParam(optionName)
am_getOption(optionName, defaultValue=None)
am_getPollingTime()
am_getShifterProxyLocation()
am_getStopAgentFile()
am_getWatchdogTime()
am_getWorkDirectory()
am_go()
am_initialize(*initArgs)
am_monitoringEnabled()
am_removeStopAgentFile()
am_secureCall(functor, args=(), name=False)
am_setModuleParam(optionName, value)
am_setOption(optionName, value)
am_stopExecution()
beginExecution()
endExecution()
execute()

The JobAgent execution method.

finalize()

Job Agent finalization method

initialize(loops=0)

Sets default parameters and creates CE instance