 |
LAL 7.7.0.1-5e288d3
|
|
|
LAL 7.7.0.1-5e288d3
|
|
A DataFindNode runs an instance of LSCdataFind in a Condor DAG.
Definition at line 2744 of file pipeline.py.
Inherits lal.pipeline.CondorDAGNode, and lal.pipeline.AnalysisNode.
Public Member Functions | |
| def | __init__ (self, job) |
| def | set_start (self, time, pad=None) |
| Set the start time of the datafind query. More... | |
| def | get_start (self) |
| Return the start time of the datafind query. More... | |
| def | set_end (self, time) |
| Set the end time of the datafind query. More... | |
| def | get_end (self) |
| Return the start time of the datafind query. More... | |
| def | set_observatory (self, obs) |
| Set the IFO to retrieve data for. More... | |
| def | get_observatory (self) |
| Return the start time of the datafind query. More... | |
| def | set_type (self, type) |
| sets the frame type that we are querying More... | |
| def | get_type (self) |
| gets the frame type that we are querying More... | |
| def | get_output_cache (self) |
| def | get_output (self) |
| Return the output file, i.e. More... | |
 Public Member Functions inherited from lal.pipeline.CondorDAGNode | |
| def | __init__ (self, job) |
| def | __repr__ (self) |
| def | job (self) |
| Return the CondorJob that this node is associated with. More... | |
| def | set_pre_script (self, script) |
| Sets the name of the pre script that is executed before the DAG node is run. More... | |
| def | add_pre_script_arg (self, arg) |
| Adds an argument to the pre script that is executed before the DAG node is run. More... | |
| def | set_post_script (self, script) |
| Sets the name of the post script that is executed before the DAG node is run. More... | |
| def | get_post_script (self) |
| returns the name of the post script that is executed before the DAG node is run. More... | |
| def | add_post_script_arg (self, arg) |
| Adds an argument to the post script that is executed before the DAG node is run. More... | |
| def | get_post_script_arg (self) |
| Returns and array of arguments to the post script that is executed before the DAG node is run. More... | |
| def | set_name (self, name) |
| Set the name for this node in the DAG. More... | |
| def | get_name (self) |
| Get the name for this node in the DAG. More... | |
| def | set_category (self, category) |
| Set the category for this node in the DAG. More... | |
| def | get_category (self) |
| Get the category for this node in the DAG. More... | |
| def | set_priority (self, priority) |
| Set the priority for this node in the DAG. More... | |
| def | get_priority (self) |
| Get the priority for this node in the DAG. 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 node. More... | |
| def | get_input_files (self) |
| Return list of input files for this DAG node and its job. More... | |
| def | get_output_files (self) |
| Return list of output files for this DAG node and its job. More... | |
| def | get_checkpoint_files (self) |
| Return a list of checkpoint files for this DAG node and its job. More... | |
| def | set_vds_group (self, group) |
| Set the name of the VDS group key when generating a DAX. More... | |
| def | get_vds_group (self) |
| Returns the VDS group key for this node. More... | |
| def | add_macro (self, name, value) |
| Add a variable (macro) for this node. More... | |
| def | add_io_macro (self, io, filename) |
| Add a variable (macro) for storing the input/output files associated with this node. More... | |
| def | add_input_macro (self, filename) |
| Add a variable (macro) for storing the input files associated with this node. More... | |
| def | add_output_macro (self, filename) |
| Add a variable (macro) for storing the output files associated with this node. More... | |
| def | add_checkpoint_macro (self, filename) |
| def | get_opts (self) |
| Return the opts for this node. More... | |
| def | add_var_condor_cmd (self, command, value) |
| Add a variable (macro) condor command for this node. More... | |
| def | add_var_opt (self, opt, value, short=False) |
| Add a variable (macro) option for this node. More... | |
| def | add_file_opt (self, opt, filename, file_is_output_file=False) |
| Add a variable (macro) option for this node. More... | |
| def | add_var_arg (self, arg, quote=False) |
| Add a variable (or macro) argument to the condor job. More... | |
| def | add_file_arg (self, filename) |
| Add a variable (or macro) file name argument to the condor job. More... | |
| def | get_args (self) |
| Return the arguments for this node. More... | |
| def | set_retry (self, retry) |
| Set the number of times that this node in the DAG should retry. More... | |
| def | get_retry (self) |
| Return the number of times that this node in the DAG should retry. More... | |
| def | write_job (self, fh) |
| Write the DAG entry for this node's job to the DAG file descriptor. More... | |
| def | write_category (self, fh) |
| Write the DAG entry for this node's category to the DAG file descriptor. More... | |
| def | write_priority (self, fh) |
| Write the DAG entry for this node's priority to the DAG file descriptor. More... | |
| def | write_vars (self, fh) |
| Write the variable (macro) options and arguments to the DAG file descriptor. More... | |
| def | write_parents (self, fh) |
| Write the parent/child relations for this job to the DAG file descriptor. More... | |
| def | write_pre_script (self, fh) |
| Write the pre script for the job, if there is one. More... | |
| def | write_post_script (self, fh) |
| Write the post script for the job, if there is one. More... | |
| def | write_input_files (self, fh) |
| Write as a comment into the DAG file the list of input files for this DAG node. More... | |
| def | write_output_files (self, fh) |
| Write as a comment into the DAG file the list of output files for this DAG node. More... | |
| def | set_log_file (self, log) |
| Set the Condor log file to be used by this CondorJob. More... | |
| def | add_parent (self, node) |
| Add a parent to this node. More... | |
| def | get_cmd_tuple_list (self) |
| Return a list of tuples containg the command line arguments. More... | |
| def | get_cmd_line (self) |
| Return the full command line that will be used when this node is run by DAGman. More... | |
| def | finalize (self) |
| The finalize method of a node is called before the node is finally added to the DAG and can be overridden to do any last minute clean up (such as setting extra command line arguments) More... | |
| Public Member Functions inherited from lal.pipeline.AnalysisNode | |
| def | __init__ (self) |
| def | set_start (self, time, pass_to_command_line=True) |
| Set the GPS start time of the analysis node by setting a –gps-start-time option to the node when it is executed. More... | |
| def | get_start (self) |
| Get the GPS start time of the node. More... | |
| def | set_end (self, time, pass_to_command_line=True) |
| Set the GPS end time of the analysis node by setting a –gps-end-time option to the node when it is executed. More... | |
| def | get_end (self) |
| Get the GPS end time of the node. More... | |
| def | set_data_start (self, time) |
| Set the GPS start time of the data needed by this analysis node. More... | |
| def | get_data_start (self) |
| Get the GPS start time of the data needed by this node. More... | |
| def | set_pad_data (self, pad) |
| Set the GPS start time of the data needed by this analysis node. More... | |
| def | get_pad_data (self) |
| Get the GPS start time of the data needed by this node. More... | |
| def | set_data_end (self, time) |
| Set the GPS end time of the data needed by this analysis node. More... | |
| def | get_data_end (self) |
| Get the GPS end time of the data needed by this node. More... | |
| def | set_trig_start (self, time, pass_to_command_line=True) |
| Set the trig start time of the analysis node by setting a –trig-start-time option to the node when it is executed. More... | |
| def | get_trig_start (self) |
| Get the trig start time of the node. More... | |
| def | set_trig_end (self, time, pass_to_command_line=True) |
| Set the trig end time of the analysis node by setting a –trig-end-time option to the node when it is executed. More... | |
| def | get_trig_end (self) |
| Get the trig end time of the node. More... | |
| def | set_input (self, filename, pass_to_command_line=True) |
| Add an input to the node by adding a –input option. More... | |
| def | get_input (self) |
| Get the file that will be passed as input. More... | |
| def | set_output (self, filename, pass_to_command_line=True) |
| Add an output to the node by adding a –output option. More... | |
| def | get_output (self) |
| Get the file that will be passed as output. More... | |
| def | set_ifo (self, ifo) |
| Set the ifo name to analyze. More... | |
| def | get_ifo (self) |
| Returns the two letter IFO code for this node. More... | |
| def | set_ifo_tag (self, ifo_tag, pass_to_command_line=True) |
| Set the ifo tag that is passed to the analysis code. More... | |
| def | get_ifo_tag (self) |
| Returns the IFO tag string. More... | |
| def | set_user_tag (self, usertag, pass_to_command_line=True) |
| Set the user tag that is passed to the analysis code. More... | |
| def | get_user_tag (self) |
| Returns the usertag string. More... | |
| def | set_cache (self, filename) |
| Set the LAL frame cache to to use. More... | |
| def | calibration_cache_path (self) |
| Determine the path to the correct calibration cache file to use. More... | |
| def | calibration (self) |
| Set the path to the calibration cache file for the given IFO. More... | |
| def | get_calibration (self) |
| Return the calibration cache file to be used by the DAG. More... | |
| def lal.pipeline.LSCDataFindNode.__init__ | ( | self, | |
| job | |||
| ) |
| job | A CondorDAGJob that can run an instance of LALdataFind. |
Reimplemented from lal.pipeline.CondorDAGNode.
Definition at line 2748 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.set_start | ( | self, | |
| time, | |||
pad = None |
|||
| ) |
Set the start time of the datafind query.
| time | GPS start time of query. |
| pad | pad |
Reimplemented from lal.pipeline.AnalysisNode.
Definition at line 2778 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.get_start | ( | self | ) |
Return the start time of the datafind query.
Reimplemented from lal.pipeline.AnalysisNode.
Definition at line 2789 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.set_end | ( | self, | |
| time | |||
| ) |
Set the end time of the datafind query.
| time | GPS end time of query. |
Reimplemented from lal.pipeline.AnalysisNode.
Definition at line 2796 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.get_end | ( | self | ) |
Return the start time of the datafind query.
Reimplemented from lal.pipeline.AnalysisNode.
Definition at line 2804 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.set_observatory | ( | self, | |
| obs | |||
| ) |
Set the IFO to retrieve data for.
Since the data from both Hanford interferometers is stored in the same frame file, this takes the first letter of the IFO (e.g. L or H) and passes it to the –observatory option of LSCdataFind.
| obs | IFO to obtain data for. |
Definition at line 2814 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.get_observatory | ( | self | ) |
Return the start time of the datafind query.
Definition at line 2822 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.set_type | ( | self, | |
| type | |||
| ) |
sets the frame type that we are querying
Definition at line 2828 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.get_type | ( | self | ) |
gets the frame type that we are querying
Definition at line 2836 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.get_output_cache | ( | self | ) |
Definition at line 2839 of file pipeline.py.
| def lal.pipeline.LSCDataFindNode.get_output | ( | self | ) |
Return the output file, i.e.
the file containing the frame cache data. or the files itself as tuple (for DAX)
Reimplemented from lal.pipeline.AnalysisNode.
Definition at line 2846 of file pipeline.py.
1.9.4