WorkflowTaskAgent

The Workflow Task Agent takes workflow tasks created in the transformation database and submits to the workload management system.

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

Bases: DIRAC.TransformationSystem.Agent.TaskManagerAgentBase.TaskManagerAgentBase

An AgentModule class to submit workflow 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