JobParameters

DIRAC Workload Management System utility module to get available memory and processors from mjf

DIRAC.WorkloadManagementSystem.Utilities.JobParameters.getJobFeatures()
DIRAC.WorkloadManagementSystem.Utilities.JobParameters.getMemoryFromMJF()
DIRAC.WorkloadManagementSystem.Utilities.JobParameters.getMemoryFromProc()
DIRAC.WorkloadManagementSystem.Utilities.JobParameters.getNumberOfProcessors(siteName, gridCE, queue)

gets the number of processors on a certain CE/queue/node

Tries to find it in this order: 1) from the /Resources/Computing/CEDefaults/NumberOfProcessors (which is what the pilot fill up) 2) if not present from JobFeatures 3) if not present looks in CS for “NumberOfProcessors” Queue or CE option 4) if not present looks in CS for “%dProcessors” Queue or CE Tag 5) if not present but there’s WholeNode tag, look what the WN provides using multiprocessing.cpu_count() 6) return 1

DIRAC.WorkloadManagementSystem.Utilities.JobParameters.getProcessorFromMJF()