SiteDirector

The Site Director is a simple agent performing pilot job submission to particular sites.

class DIRAC.WorkloadManagementSystem.Agent.SiteDirector.SiteDirector(*args, **kwargs)

Bases: DIRAC.Core.Base.AgentModule.AgentModule

SiteDirector class provides an implementation of a DIRAC agent.

Used for submitting pilots to Computing Elements.

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()
endExecution()
execute()

Main execution method (what is called at each agent cycle).

It basically just calls self.submitJobs() method

finalize()
getExecutable(queue, pilotsToSubmit, bundleProxy=True, httpProxy='', jobExecDir='', **kwargs)

Prepare the full executable for queue

getQueueSlots(queue, manyWaitingPilotsFlag)

Get the number of available slots in the queue

getQueues(resourceDict)

Get the list of relevant CEs and their descriptions

initialize()

Initial settings

sendPilotAccounting(pilotDict)

Send pilot accounting record

submitJobs()

Go through defined computing elements and submit jobs if necessary

updatePilotStatus()

Update status of pilots in transient states

DIRAC.WorkloadManagementSystem.Agent.SiteDirector.getSubmitPools(group=None, vo=None)

This method gets submit pools