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:
AgentModuleThis 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_getControlDirectory()
- am_getCyclesDone()
- am_getMaxCycles()
- am_getModuleParam(optionName)
- am_getOption(optionName, defaultValue=None)
Gets an option from the agent’s configuration section. The section will be a subsection of the /Systems section in the CS.
- am_getPollingTime()
- am_getShifterProxyLocation()
- am_getStopAgentFile()
- am_getWatchdogTime()
- am_getWorkDirectory()
- am_go()
- am_initialize(*initArgs)
Common initialization for all the agents.
This is executed every time an agent (re)starts. This is called by the AgentReactor, should not be overridden.
- 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()
Sets default parameters and creates CE instance