CleanReqDBAgent¶
Cleaning the RequestDB from obsolete records and kicking assigned requests
CleanReqDBAgent
{
PollingTime = 60
ControlDirectory = control/RequestManagement/CleanReqDBAgent
# How many days, until finished requests are deleted
DeleteGraceDays = 60
# How many requests are deleted per cycle
DeleteLimit = 100
# If failed requests are deleted
DeleteFailed = False
# How many hours a request can stay assigned
KickGraceHours = 1
# How many requests are kicked per cycle
KickLimit = 10000
}
- class DIRAC.RequestManagementSystem.Agent.CleanReqDBAgent.CleanReqDBAgent(agentName, loadName, baseAgentName=False, properties={})¶
Bases:
AgentModule
- class CleanReqDBAgent¶
- DEL_FAILED = False¶
- DEL_GRACE_DAYS = 60¶
- DEL_LIMIT = 100¶
- KICK_GRACE_HOURS = 1¶
- KICK_LIMIT = 10000¶
- __init__(agentName, loadName, baseAgentName=False, properties={})¶
Common __init__ method for all Agents. All Agent modules must define: __doc__ __RCSID__ They are used to populate __codeProperties
The following Options are used from the Configuration: - /LocalSite/InstancePath - /DIRAC/Setup - Status - Enabled - PollingTime default = 120 - MaxCycles default = 500 - WatchdogTime default = 0 (disabled) - ControlDirectory control/SystemName/AgentName - WorkDirectory work/SystemName/AgentName - shifterProxy ‘’ - shifterProxyLocation WorkDirectory/SystemName/AgentName/.shifterCred
It defines the following default Options that can be set via Configuration (above): - MonitoringEnabled True - Enabled True if Status == Active - PollingTime 120 - MaxCycles 500 - ControlDirectory control/SystemName/AgentName - WorkDirectory work/SystemName/AgentName - shifterProxy False - shifterProxyLocation work/SystemName/AgentName/.shifterCred
different defaults can be set in the initialize() method of the Agent using am_setOption()
In order to get a shifter proxy in the environment during the execute() the configuration Option ‘shifterProxy’ must be set, a default may be given in the initialize() method.
- 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()¶
- endExecution()¶
- execute()¶
execution in one cycle
- finalize()¶
- initialize()¶
initialization
- requestClient()¶
request client getter