SSHBatchComputingElement
SSH (Virtual) Computing Element: For a given list of ip/cores pair it will send jobs directly through ssh
- class DIRAC.Resources.Computing.SSHBatchComputingElement.SSHBatchComputingElement(ceUniqueID)
Bases:
SSHComputingElement
- __init__(ceUniqueID)
Standard constructor.
- available()
This method returns the number of available slots in the target CE. The CE instance polls for waiting and running jobs and compares to the limits in the CE parameters.
- getCEStatus()
Method to return information on running and pending jobs.
- getDescription()
Get CE description as a dictionary.
This is called by the JobAgent for the case of “inner” CEs.
- getJobOutput(jobID, localDir=None)
Get the specified job standard output and error files. If the localDir is provided, the output is returned as file in this directory. Otherwise, the output is returned as strings.
- getJobStatus(jobIDList)
Get status of the jobs in the given list
- initializeParameters()
Initialize the CE parameters after they are collected from various sources
- isValid()
Check the sanity of the Computing Element definition
- killJob(jobIDs)
Kill specified jobs
- loadBatchSystem(batchSystemName)
Instantiate object representing the backend batch system
- Parameters:
batchSystemName (str) – name of the batch system
- sendOutput(stdid, line)
Callback function such that the results from the CE may be returned.
- setCPUTimeLeft(cpuTimeLeft=None)
Update the CPUTime parameter of the CE classAd, necessary for running in filling mode
- setParameters(ceOptions)
Add parameters from the given dictionary overriding the previous values
- Parameters:
ceOptions (dict) – CE parameters dictionary to update already defined ones
- setProxy(proxy)
Set and prepare proxy to use
- Parameters:
proxy (str) – proxy to use
- Returns:
S_OK/S_ERROR
- setToken(token)
- shutdown()
Optional method to shutdown the (Inner) Computing Element
- submitJob(executableFile, proxy, numberOfJobs=1)
Method to submit job
- writeProxyToFile(proxy)
CE helper function to write a CE proxy string to a file.