RequestTaskAgent

The Request Task Agent takes request tasks created in the transformation database and submits to the request management system

class DIRAC.TransformationSystem.Agent.RequestTaskAgent.RequestTaskAgent(*args, **kwargs)

Bases: DIRAC.TransformationSystem.Agent.TaskManagerAgentBase.TaskManagerAgentBase

An AgentModule to submit requests tasks

am_Enabled()
am_checkStopAgentFile()
am_createStopAgentFile()
am_disableMonitoring()
am_getBasePath()
am_getControlDirectory()
am_getCyclesDone()
am_getMaxCycles()
am_getModuleParam(optionName)
am_getOption(optionName, defaultValue=None)
am_getPollingTime()
am_getShifterProxyLocation()
am_getStopAgentFile()
am_getWatchdogTime()
am_getWorkDirectory()
am_go()
am_initialize(*initArgs)
am_monitoringEnabled()
am_removeStopAgentFile()
am_secureCall(functor, args=(), name=False)
am_setModuleParam(optionName, value)
am_setOption(optionName, value)
am_stopExecution()
beginExecution()
checkReservedTasks(transIDOPBody, clients)

Checking Reserved tasks

endExecution()
execute()

The TaskManagerBase execution method is just filling the Queues of transformations that need to be processed

finalize()

graceful finalization

initialize()

Standard initialize method

submitTasks(transIDOPBody, clients)

Submit the tasks to an external system, using the taskManager provided

updateFileStatus(transIDOPBody, clients)

Update the files status

updateTaskStatus(transIDOPBody, clients)

Updates the task status