 |
LAL 7.7.0.1-5e288d3
|
|
|
LAL 7.7.0.1-5e288d3
|
|
An LSCdataFind job used to locate data.
The static options are read from the section [datafind] in the ini file. The stdout from LSCdataFind contains the paths to the frame files and is directed to a file in the cache directory named by site and GPS start and end times. The stderr is directed to the logs directory. The job always runs in the scheduler universe. The path to the executable is determined from the ini file.
Definition at line 2686 of file pipeline.py.
Inherits lal.pipeline.CondorDAGJob, and lal.pipeline.AnalysisJob.
Public Member Functions | |
| def | __init__ (self, cache_dir, log_dir, config_file, lsync_cache_file=None, lsync_type_regex=None) |
| def | get_cache_dir (self) |
| returns the directroy that the cache files are written to. More... | |
| def | get_config_file (self) |
| return the configuration file object More... | |
| def | lsync_cache (self) |
 Public Member Functions inherited from lal.pipeline.CondorDAGJob | |
| 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... | |
| Public Member Functions inherited from lal.pipeline.CondorJob | |
| 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... | |
| Public Member Functions inherited from lal.pipeline.AnalysisJob | |
| 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.LSCDataFindJob.__init__ | ( | self, | |
| cache_dir, | |||
| log_dir, | |||
| config_file, | |||
lsync_cache_file = None, |
|||
lsync_type_regex = None |
|||
| ) |
| cache_dir | the directory to write the output lal cache files to. |
| log_dir | the directory to write the stderr file to. |
| config_file | ConfigParser object containing the path to the LSCdataFind executable in the [condor] section and a [datafind] section from which the LSCdataFind options are read. |
| lsync_cache_file | lsync_cache_file |
| lsync_type_regex | lsync_type_regex |
Reimplemented from lal.pipeline.CondorDAGJob.
Definition at line 2694 of file pipeline.py.
| def lal.pipeline.LSCDataFindJob.get_cache_dir | ( | self | ) |
returns the directroy that the cache files are written to.
Definition at line 2728 of file pipeline.py.
| def lal.pipeline.LSCDataFindJob.get_config_file | ( | self | ) |
return the configuration file object
Definition at line 2734 of file pipeline.py.
| def lal.pipeline.LSCDataFindJob.lsync_cache | ( | self | ) |
Definition at line 2737 of file pipeline.py.
1.9.4