 |
LALBurst 2.0.7.1-5e288d3
|
|
|
LALBurst 2.0.7.1-5e288d3
|
|
Data Structures | |
| class | BinjfindJob |
| class | BinjfindNode |
| class | BuclusterJob |
| class | BuclusterNode |
| class | BucutJob |
| class | BucutNode |
| class | Burca2Job |
| class | BurcaJob |
| class | BurcaNode |
| class | BurcaTailorJob |
| class | BurcaTailorNode |
| class | BurstInjJob |
| A lalapps_binj job used by the power pipeline. More... | |
| class | BurstInjNode |
| class | LigolwAddNode |
| class | PowerJob |
| A lalapps_power job used by the power pipeline. More... | |
| class | PowerNode |
| class | RMJob |
| class | RMNode |
| class | SQLiteJob |
| class | SQLiteNode |
| class | TimingParameters |
| A class to hold timing parameter values. More... | |
Functions | |
| def | get_universe (config_parser) |
| def | get_accounting_group (config_parser) |
| def | get_executable (config_parser, name) |
| def | get_out_dir (config_parser) |
| def | get_cache_dir (config_parser) |
| def | get_triggers_dir (config_parser) |
| def | make_dir_if_not_exists (dir) |
| def | make_dag_directories (config_parser) |
| def | get_files_per_bucluster (config_parser) |
| def | get_files_per_bucut (config_parser) |
| def | get_files_per_burca (config_parser) |
| def | get_files_per_binjfind (config_parser) |
| def | make_cache_entry (input_cache, description, path) |
| def | collect_output_caches (parents) |
| def | match_nodes_to_caches (nodes, caches) |
| For each cache, get the set of nodes whose output files it contains. More... | |
| def | cache_span (cache) |
| def | write_output_cache (nodes, filename) |
| def | init_job_types (config_parser, job_types=("datafind", "rm", "binj", "power", "lladd", "binjfind", "bucluster", "bucut", "burca", "burca2", "sqlite", "burcatailor")) |
| Construct definitions of the submit files. More... | |
| def | psds_from_job_length (timing_params, t) |
| Return the number of PSDs that can fit into a job of length t seconds. More... | |
| def | job_length_from_psds (timing_params, psds) |
| From the analysis parameters and a count of PSDs, return the length of the job in seconds. More... | |
| def | split_segment (timing_params, segment, psds_per_job) |
| Split the data segment into correctly-overlaping segments. More... | |
| def | segment_ok (timing_params, segment) |
| Return True if the segment can be analyzed using lalapps_power. More... | |
| def | remove_too_short_segments (seglistdict, timing_params) |
| Remove segments from seglistdict that are too short to analyze. More... | |
| def | make_datafind_fragment (dag, instrument, seg) |
| def | make_lladd_fragment (dag, parents, tag, segment=None, input_cache=None, remove_input=False, preserve_cache=None, extra_input_cache=None) |
| def | make_power_fragment (dag, parents, instrument, seg, tag, framecache, injargs={}) |
| def | make_binj_fragment (dag, seg, time_slides_cache_entry, tag, offset, flow=None, fhigh=None) |
| def | make_binjfind_fragment (dag, parents, tag, verbose=False) |
| def | make_bucluster_fragment (dag, parents, tag, verbose=False) |
| def | make_bucut_fragment (dag, parents, tag, verbose=False) |
| def | make_burca_fragment (dag, parents, tag, coincidence_segments=None, verbose=False) |
| def | make_sqlite_fragment (dag, parents, tag, verbose=False) |
| def | make_burca_tailor_fragment (dag, input_cache, seg, tag) |
| def | make_burca2_fragment (dag, coinc_cache, likelihood_parents, tag) |
| def | make_datafind_stage (dag, seglists, verbose=False) |
| def | make_power_segment_fragment (dag, datafindnodes, instrument, segment, tag, timing_params, psds_per_job, binjnodes=set(), verbose=False) |
| Construct a DAG fragment for an entire segment, splitting the segment into multiple trigger generator jobs. More... | |
| def | make_single_instrument_stage (dag, datafinds, seglistdict, tag, timing_params, psds_per_job, binjnodes=set(), verbose=False) |
| def | group_coinc_parents (parents, offset_vectors, extentlimit=None, verbose=False) |
Variables | |
| datafindjob = None | |
| binjjob = None | |
| powerjob = None | |
| lladdjob = None | |
| binjfindjob = None | |
| bucutjob = None | |
| buclusterjob = None | |
| burcajob = None | |
| burca2job = None | |
| sqlitejob = None | |
| burcatailorjob = None | |
| int | datafind_pad = 512 |
| def lalburst.power.make_cache_entry | ( | input_cache, | |
| description, | |||
| path | |||
| ) |
| def lalburst.power.match_nodes_to_caches | ( | nodes, | |
| caches | |||
| ) |
| def lalburst.power.init_job_types | ( | config_parser, | |
job_types = ("datafind", "rm", "binj", "power", "lladd", "binjfind", "bucluster", "bucut", "burca", "burca2", "sqlite", "burcatailor") |
|||
| ) |
| def lalburst.power.psds_from_job_length | ( | timing_params, | |
| t | |||
| ) |
| def lalburst.power.job_length_from_psds | ( | timing_params, | |
| psds | |||
| ) |
| def lalburst.power.split_segment | ( | timing_params, | |
| segment, | |||
| psds_per_job | |||
| ) |
| def lalburst.power.segment_ok | ( | timing_params, | |
| segment | |||
| ) |
| def lalburst.power.remove_too_short_segments | ( | seglistdict, | |
| timing_params | |||
| ) |
| def lalburst.power.make_datafind_fragment | ( | dag, | |
| instrument, | |||
| seg | |||
| ) |
| def lalburst.power.make_lladd_fragment | ( | dag, | |
| parents, | |||
| tag, | |||
segment = None, |
|||
input_cache = None, |
|||
remove_input = False, |
|||
preserve_cache = None, |
|||
extra_input_cache = None |
|||
| ) |
| def lalburst.power.make_power_fragment | ( | dag, | |
| parents, | |||
| instrument, | |||
| seg, | |||
| tag, | |||
| framecache, | |||
injargs = {} |
|||
| ) |
| def lalburst.power.make_binj_fragment | ( | dag, | |
| seg, | |||
| time_slides_cache_entry, | |||
| tag, | |||
| offset, | |||
flow = None, |
|||
fhigh = None |
|||
| ) |
| def lalburst.power.make_binjfind_fragment | ( | dag, | |
| parents, | |||
| tag, | |||
verbose = False |
|||
| ) |
| def lalburst.power.make_bucluster_fragment | ( | dag, | |
| parents, | |||
| tag, | |||
verbose = False |
|||
| ) |
| def lalburst.power.make_bucut_fragment | ( | dag, | |
| parents, | |||
| tag, | |||
verbose = False |
|||
| ) |
| def lalburst.power.make_burca_fragment | ( | dag, | |
| parents, | |||
| tag, | |||
coincidence_segments = None, |
|||
verbose = False |
|||
| ) |
| def lalburst.power.make_sqlite_fragment | ( | dag, | |
| parents, | |||
| tag, | |||
verbose = False |
|||
| ) |
| def lalburst.power.make_burca_tailor_fragment | ( | dag, | |
| input_cache, | |||
| seg, | |||
| tag | |||
| ) |
| def lalburst.power.make_burca2_fragment | ( | dag, | |
| coinc_cache, | |||
| likelihood_parents, | |||
| tag | |||
| ) |
| def lalburst.power.make_datafind_stage | ( | dag, | |
| seglists, | |||
verbose = False |
|||
| ) |
| def lalburst.power.make_power_segment_fragment | ( | dag, | |
| datafindnodes, | |||
| instrument, | |||
| segment, | |||
| tag, | |||
| timing_params, | |||
| psds_per_job, | |||
binjnodes = set(), |
|||
verbose = False |
|||
| ) |
| def lalburst.power.make_single_instrument_stage | ( | dag, | |
| datafinds, | |||
| seglistdict, | |||
| tag, | |||
| timing_params, | |||
| psds_per_job, | |||
binjnodes = set(), |
|||
verbose = False |
|||
| ) |
| def lalburst.power.group_coinc_parents | ( | parents, | |
| offset_vectors, | |||
extentlimit = None, |
|||
verbose = False |
|||
| ) |
1.9.4