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:
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)¶
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_monitoringEnabled()¶
- am_removeStopAgentFile()¶
- am_secureCall(functor, args=(), name=False)¶
- am_setModuleParam(optionName, value)¶
- am_setOption(optionName, value)¶
- am_stopExecution()¶
- beginExecution()¶
- computeCPUWorkLeft(processors=1)¶
Compute CPU Work Left in hepspec06 seconds
- Parameters
processors (int) – number of processors available
- Returns
cpu work left (cpu time left * cpu power of the cpus)
- endExecution()¶
- execute()¶
The JobAgent execution method.
- finalize()¶
Job Agent finalization method
- initialize()¶
Sets default parameters and creates CE instance