PilotLoggingAgent

mod:

PilotLoggingAgent

PilotLoggingAgent sends Pilot log files to an SE.

PilotLoggingAgent options

PilotLoggingAgent
{
  PollingTime = 600
}

class DIRAC.WorkloadManagementSystem.Agent.PilotLoggingAgent.PilotLoggingAgent(*args, **kwargs)

Bases: AgentModule

class PilotLoggingAgent

The agent sends completed pilot log files to permanent storage for analysis.

__init__(*args, **kwargs): c’tor

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()

clearOldPilotLogs(pilotLogPath)

Delete old pilot log files unconditionally. Assumes that pilotLogPath exists.

Parameters:: pilotLogPath (str) – log files directory
Returns:: None
Return type:: None

endExecution()

execute()

Execute one agent cycle. Upload log files to the SE and register them in the DFC. Consider only VOs we have proxies for.

Parameters:: self – self reference

executeForVO(**kwargs)

finalize()

initialize()

agent’s initialisation. Use this agent’s CS information to: Determine VOs with remote logging enabled, Determine what Defaults/Shifter shifter proxy to use., download the proxies.

Parameters:: self – self reference