A LigolwSqlite job.
The static options are read from the section [ligolw_sqlite] in the ini file.
Definition at line 3050 of file pipeline.py.
Inherits lal.pipeline.SqliteJob.
Public Member Functions | |
def | __init__ (self, cp) |
def | set_replace (self) |
Sets the –replace option. More... | |
![]() | |
def | __init__ (self, cp, sections, exec_name) |
def | set_exec_name (self, exec_name) |
Set the exec_name name. More... | |
def | get_exec_name (self) |
Get the exec_name name. More... | |
![]() | |
def | __init__ (self, universe, executable) |
universe = the condor universe to run the job in. More... | |
def | create_node (self) |
Create a condor node from this job. More... | |
def | set_grid_site (self, site) |
Set the grid site to run on. More... | |
def | get_grid_site (self) |
Return the grid site for this node. More... | |
def | add_var_opt (self, opt, short=False) |
Add a variable (or macro) option to the condor job. More... | |
def | add_var_condor_cmd (self, command) |
Add a condor command to the submit file that allows variable (macro) arguments to be passes to the executable. More... | |
def | add_var_arg (self, arg_index, quote=False) |
Add a command to the submit file to allow variable (macro) arguments to be passed to the executable. More... | |
![]() | |
def | __init__ (self, universe, executable, queue) |
def | get_executable (self) |
Return the name of the executable for this job. More... | |
def | set_executable (self, executable) |
Set the name of the executable for this job. More... | |
def | get_universe (self) |
Return the condor universe that the job will run in. More... | |
def | set_universe (self, universe) |
Set the condor universe for the job to run in. More... | |
def | get_grid_type (self) |
Return the grid type of the job. More... | |
def | set_grid_type (self, grid_type) |
Set the type of grid resource for the job. More... | |
def | get_grid_server (self) |
Return the grid server on which the job will run. More... | |
def | set_grid_server (self, grid_server) |
Set the grid server on which to run the job. More... | |
def | get_grid_scheduler (self) |
Return the grid scheduler. More... | |
def | set_grid_scheduler (self, grid_scheduler) |
Set the grid scheduler. More... | |
def | set_executable_installed (self, installed) |
If executable installed is true, then no copying of the executable is done. More... | |
def | get_executable_installed (self) |
return whether or not the executable is installed More... | |
def | add_condor_cmd (self, cmd, value) |
Add a Condor command to the submit file (e.g. More... | |
def | get_condor_cmds (self) |
Return the dictionary of condor keywords to add to the job. More... | |
def | add_input_file (self, filename) |
Add filename as a necessary input file for this DAG node. More... | |
def | add_output_file (self, filename) |
Add filename as a output file for this DAG node. More... | |
def | add_checkpoint_file (self, filename) |
Add filename as a checkpoint file for this DAG job. More... | |
def | get_input_files (self) |
Return list of input files for this DAG node. More... | |
def | get_output_files (self) |
Return list of output files for this DAG node. More... | |
def | get_checkpoint_files (self) |
Return a list of checkpoint files for this DAG node. More... | |
def | add_arg (self, arg) |
Add an argument to the executable. More... | |
def | add_file_arg (self, filename) |
Add a file argument to the executable. More... | |
def | get_args (self) |
Return the list of arguments that are to be passed to the executable. More... | |
def | add_opt (self, opt, value) |
Add a command line option to the executable. More... | |
def | get_opt (self, opt) |
Returns the value associated with the given command line option. More... | |
def | add_file_opt (self, opt, filename) |
Add a command line option to the executable. More... | |
def | get_opts (self) |
Return the dictionary of opts for the job. More... | |
def | add_short_opt (self, opt, value) |
Add a command line option to the executable. More... | |
def | get_short_opts (self) |
Return the dictionary of short options for the job. More... | |
def | add_ini_opts (self, cp, section) |
Parse command line options from a given section in an ini file and pass to the executable. More... | |
def | set_notification (self, value) |
Set the email address to send notification to. More... | |
def | set_log_file (self, path) |
Set the Condor log file. More... | |
def | set_stdin_file (self, path) |
Set the file from which Condor directs the stdin of the job. More... | |
def | get_stdin_file (self) |
Get the file from which Condor directs the stdin of the job. More... | |
def | set_stderr_file (self, path) |
Set the file to which Condor directs the stderr of the job. More... | |
def | get_stderr_file (self) |
Get the file to which Condor directs the stderr of the job. More... | |
def | set_stdout_file (self, path) |
Set the file to which Condor directs the stdout of the job. More... | |
def | get_stdout_file (self) |
Get the file to which Condor directs the stdout of the job. More... | |
def | set_sub_file (self, path) |
Set the name of the file to write the Condor submit file to when write_sub_file() is called. More... | |
def | get_sub_file (self) |
Get the name of the file which the Condor submit file will be written to when write_sub_file() is called. More... | |
def | write_sub_file (self) |
Write a submit file for this Condor job. More... | |
![]() | |
def | __init__ (self, cp) |
def | get_config (self, sec, opt) |
Get the configration variable in a particular section of this jobs ini file. More... | |
def | set_channel (self, channel) |
Set the name of the channel that this job is filtering. More... | |
def | channel (self) |
Returns the name of the channel that this job is filtering. More... | |
def lal.pipeline.LigolwSqliteJob.__init__ | ( | self, | |
cp | |||
) |
cp | ConfigParser object from which options are read. |
Reimplemented from lal.pipeline.SqliteJob.
Definition at line 3054 of file pipeline.py.
def lal.pipeline.LigolwSqliteJob.set_replace | ( | self | ) |
Sets the –replace option.
This will cause the job to overwrite existing databases rather than add to them.
Definition at line 3063 of file pipeline.py.