MultiProcessorSiteDirector

The Multi Processor Site Director is an agent performing pilot job submission to particular sites. It is able to handle multicore jobs.

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

Bases: DIRAC.WorkloadManagementSystem.Agent.SiteDirector.SiteDirector

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