ValidateOutputDataAgent

Runs few integrity checks

The following options can be set for the ValidateOutputDataAgent.

ValidateOutputDataAgent options
ValidateOutputDataAgent
{
  #Time between cycles in seconds
  PollingTime = 120
}
class DIRAC.TransformationSystem.Agent.ValidateOutputDataAgent.ValidateOutputDataAgent(*args, **kwargs)

Bases: AgentModule

__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()
checkTransformationIntegrity(transID)

This method contains the real work

endExecution()
execute()

The VerifyOutputData execution method

finalize()
finalizeCheck(transID)

Move to ‘WaitingIntegrity’ or ‘ValidatedOutput’

getTransformationDirectories(transID)

Get the directories for the supplied transformation from the transformation system

initialize()

Sets defaults

updateWaitingIntegrity()

Get ‘WaitingIntegrity’ transformations, update to ‘ValidatedOutput’