![]() |
Belle II Software
release-05-02-19
|
Public Member Functions | |
def | __init__ (self) |
The default constructor. More... | |
def | adjust_path (self, str path) |
This method can be used if path names are different on submission and execution hosts. More... | |
def | available (self) |
The cluster should always be available to accept new jobs. More... | |
def | execute (self, Script job, options='', dry=False, tag='current') |
Takes a Script object and a string with options and runs it on the cluster, either with ROOT or with basf2, depending on the file type. More... | |
def | is_job_finished (self, Script job) |
Checks whether the '.done'-file has been created for a job. More... | |
str | createDoneFileName (self, Script job) |
Generate the file name used for the done output. | |
def | prepareSubmission (self, Script job, options, tag) |
Setup output folders and create the wrapping shell script. More... | |
def | checkDoneFile (self, job) |
Checks whether the '.done'-file has been created for a job. More... | |
def | terminate (self, Script job) |
Terminate running job. | |
def | adjust_path (self, path) |
This method can be used if path names are different on submission and execution hosts. More... | |
Static Public Member Functions | |
def | is_supported () |
def | name () |
def | description () |
Public Attributes | |
native_spec | |
The command to submit a job. More... | |
requirement_vmem | |
required vmem by the job in GB, required on DESY NAF, otherwise jobs get killed due to memory consumption | |
requirement_storage | |
the storage IO in GB which can be performed by each job. More... | |
queuename | |
Queue best suitable for execution at DESY NAF. | |
path | |
The path, where the help files are being created Maybe there should be a special subfolder for them? | |
logger | |
Contains a reference to the logger-object from validate_basf2 Set up the logging functionality for the 'cluster execution'-Class, so we can log to validate_basf2.py's log what is going on in .execute and .is_finished. | |
tools | |
Path to the basf2 tools and central/local release. | |
b2setup | |
The command for b2setup (and b2code-option) | |
clusterlog | |
The file object to which all cluster messages will be written. | |
A class that provides the controls for running jobs on a (remote) Sun Grid Engine cluster. It provides two methods: - is_job_finished(job): Returns True or False, depending on whether the job has finished execution - execute(job): Takes a job and executes it by sending it to the cluster
Definition at line 11 of file clustercontroldrmaa.py.
def __init__ | ( | self | ) |
The default constructor.
Reimplemented from ClusterBase.
Definition at line 51 of file clustercontroldrmaa.py.
|
inherited |
This method can be used if path names are different on submission and execution hosts.
path | The past that needs to be adjusted |
Definition at line 165 of file clustercontrolbase.py.
def adjust_path | ( | self, | |
str | path | ||
) |
This method can be used if path names are different on submission and execution hosts.
path | The past that needs to be adjusted |
Definition at line 83 of file clustercontroldrmaa.py.
def available | ( | self | ) |
The cluster should always be available to accept new jobs.
Definition at line 94 of file clustercontroldrmaa.py.
|
inherited |
Checks whether the '.done'-file has been created for a job.
If so, it returns True, else it returns False in the first part of the tuple. Also deletes the .done-File it if exists. The second entry in the tuple will be the exit code read from the done file
Definition at line 127 of file clustercontrolbase.py.
|
static |
Returns description of this job control
Definition at line 45 of file clustercontroldrmaa.py.
def execute | ( | self, | |
Script | job, | ||
options = '' , |
|||
dry = False , |
|||
tag = 'current' |
|||
) |
Takes a Script object and a string with options and runs it on the cluster, either with ROOT or with basf2, depending on the file type.
job | The steering file object that should be executed |
options | Options that will be given to the basf2 command |
dry | Whether to perform a dry run or not |
tag | The folder within the results directory |
Definition at line 102 of file clustercontroldrmaa.py.
def is_job_finished | ( | self, | |
Script | job | ||
) |
Checks whether the '.done'-file has been created for a job.
If so, it returns True, else it returns False. Also deletes the .done-File once it has returned True.
job | The job of which we want to know if it finished |
Definition at line 152 of file clustercontroldrmaa.py.
|
static |
Check if qsub is available
Definition at line 21 of file clustercontroldrmaa.py.
|
static |
Returns name of this job contol
Definition at line 38 of file clustercontroldrmaa.py.
|
inherited |
Setup output folders and create the wrapping shell script.
Will return the full file name of the generated wrapper script.
Definition at line 71 of file clustercontrolbase.py.
native_spec |
The command to submit a job.
'LOGFILE' will be replaced by the actual log file name
Definition at line 62 of file clustercontroldrmaa.py.
requirement_storage |
the storage IO in GB which can be performed by each job.
By default, this is 3GB at DESY which is to small for some validation scripts
Definition at line 73 of file clustercontroldrmaa.py.