Functions
def	parse_command_line ()

def	make_dag_directories (top_level_directory, config_parser)

def	check_for_reused_offsetvectors (background_time_slides, injection_time_slides)

def	make_coinc_branch (dag, datafinds, seglists, time_slides, min_segment_length, pad, overlap, short_segment_duration, tag, vetoes_cache=set(), do_injections=False, injections_offset=0.0, verbose=False)

def	flatten_node_groups (node_groups)

def	round_robin_and_flatten (injection_coinc_node_groups, injection_likelihood_node_groups)

Variables
	options

	filenames

	basename = os.path.splitext(os.path.basename(options.config_file))[0]

	log_fh = open(basename + '.pipeline.log', 'w')

	file

	name_value

	config_parser = ConfigParser()

	job_types

list	injection_folders = []

list	noninjection_folders = []

	logfile = tempfile.mkstemp(prefix = basename, suffix = '.log', dir = options.log_path)[1]

	dag = pipeline.CondorDAG(logfile)

	clipsegments_sql_filename = os.path.abspath("clipsegments.sql")

	short_segment_duration = config_parser.getint('lalapps_StringSearch', 'short-segment-duration')

	pad = config_parser.getint('lalapps_StringSearch', 'pad')

	min_segment_length = config_parser.getint('pipeline', 'segment-length')

	trig_overlap = config_parser.getint('pipeline', 'trig_overlap')

int	overlap = short_segment_duration / 2 + 2 * pad

	instruments = lsctables.instrumentsproperty.get(config_parser.get('pipeline','ifos'))

	segments_cache = set([CacheEntry(None, "SEG", None, "file://localhost" + os.path.abspath(options.segments_file))])

	seglists = ligolw_segments.segmenttable_get_by_name(ligolw_utils.load_filename(options.segments_file, verbose = options.verbose), options.segments_name).coalesce()

dictionary	background_time_slides = {}

	background_seglists = segments.segmentlistdict()

	cache_entry = CacheEntry(None, "BG", None, "file://localhost" + os.path.abspath(filename))

dictionary	injection_time_slides = {}

	injection_seglists = segments.segmentlistdict()

	datafinds = power.make_datafind_stage(dag, injection_seglists \| background_seglists, verbose = options.verbose)

	user_tag = config_parser.get('pipeline', 'user_tag')

list	injection_coinc_nodes = []

list	injection_likelihood_nodes = []

	cwd = os.getcwd()

	vetoes_cache

	do_injections

	True

	injections_offset

	verbose

	background_coinc_nodes

	background_likelihood_nodes

	False

def	all_background_likelihood_nodes = flatten_node_groups(background_likelihood_nodes)

def	all_injection_likelihood_nodes = flatten_node_groups(injection_likelihood_nodes)

	coinc_nodes = set()

	these_inj_coinc_nodes = cosmicstring.make_calc_likelihood_fragment(dag, these_inj_coinc_nodes, these_inj_likelihood_nodes \| all_background_likelihood_nodes, "%s_INJ_%d" % (user_tag, n), verbose = options.verbose)

	files_per_calc_likelihood

Function Documentation

◆ parse_command_line()

def lalapps_cosmicstring_pipe.parse_command_line ( )

Definition at line 57 of file lalapps_cosmicstring_pipe.py.

◆ make_dag_directories()

def lalapps_cosmicstring_pipe.make_dag_directories	(	top_level_directory,
		config_parser
	)

Definition at line 131 of file lalapps_cosmicstring_pipe.py.

◆ check_for_reused_offsetvectors()

def lalapps_cosmicstring_pipe.check_for_reused_offsetvectors	(	background_time_slides,
		injection_time_slides
	)

Definition at line 228 of file lalapps_cosmicstring_pipe.py.

◆ make_coinc_branch()

def lalapps_cosmicstring_pipe.make_coinc_branch	(	dag,
		datafinds,
		seglists,
		time_slides,
		min_segment_length,
		pad,
		overlap,
		short_segment_duration,
		tag,
		vetoes_cache = `set()`,
		do_injections = `False`,
		injections_offset = `0.0`,
		verbose = `False`
	)

Definition at line 263 of file lalapps_cosmicstring_pipe.py.

◆ flatten_node_groups()

def lalapps_cosmicstring_pipe.flatten_node_groups ( node_groups )

Definition at line 445 of file lalapps_cosmicstring_pipe.py.

◆ round_robin_and_flatten()

def lalapps_cosmicstring_pipe.round_robin_and_flatten	(	injection_coinc_node_groups,
		injection_likelihood_node_groups
	)

Definition at line 462 of file lalapps_cosmicstring_pipe.py.

Variable Documentation

◆ options

lalapps_cosmicstring_pipe.options

Definition at line 88 of file lalapps_cosmicstring_pipe.py.

◆ filenames

lalapps_cosmicstring_pipe.filenames

Definition at line 88 of file lalapps_cosmicstring_pipe.py.

◆ basename

lalapps_cosmicstring_pipe.basename = os.path.splitext(os.path.basename(options.config_file))[0]

Definition at line 104 of file lalapps_cosmicstring_pipe.py.

◆ log_fh

lalapps_cosmicstring_pipe.log_fh = open(basename + '.pipeline.log', 'w')

Definition at line 105 of file lalapps_cosmicstring_pipe.py.

◆ file

lalapps_cosmicstring_pipe.file

Definition at line 108 of file lalapps_cosmicstring_pipe.py.

◆ name_value

lalapps_cosmicstring_pipe.name_value

Definition at line 110 of file lalapps_cosmicstring_pipe.py.

◆ config_parser

lalapps_cosmicstring_pipe.config_parser = ConfigParser()

Definition at line 117 of file lalapps_cosmicstring_pipe.py.

◆ job_types

lalapps_cosmicstring_pipe.job_types

Definition at line 124 of file lalapps_cosmicstring_pipe.py.

◆ injection_folders

list lalapps_cosmicstring_pipe.injection_folders = []

Definition at line 142 of file lalapps_cosmicstring_pipe.py.

◆ noninjection_folders

list lalapps_cosmicstring_pipe.noninjection_folders = []

Definition at line 146 of file lalapps_cosmicstring_pipe.py.

◆ logfile

lalapps_cosmicstring_pipe.logfile = tempfile.mkstemp(prefix = basename, suffix = '.log', dir = options.log_path)[1]

Definition at line 154 of file lalapps_cosmicstring_pipe.py.

◆ dag

lalapps_cosmicstring_pipe.dag = pipeline.CondorDAG(logfile)

Definition at line 160 of file lalapps_cosmicstring_pipe.py.

◆ clipsegments_sql_filename

lalapps_cosmicstring_pipe.clipsegments_sql_filename = os.path.abspath("clipsegments.sql")

Definition at line 162 of file lalapps_cosmicstring_pipe.py.

◆ short_segment_duration

lalapps_cosmicstring_pipe.short_segment_duration = config_parser.getint('lalapps_StringSearch', 'short-segment-duration')

Definition at line 168 of file lalapps_cosmicstring_pipe.py.

◆ pad

lalapps_cosmicstring_pipe.pad = config_parser.getint('lalapps_StringSearch', 'pad')

Definition at line 169 of file lalapps_cosmicstring_pipe.py.

◆ min_segment_length

lalapps_cosmicstring_pipe.min_segment_length = config_parser.getint('pipeline', 'segment-length')

Definition at line 170 of file lalapps_cosmicstring_pipe.py.

◆ trig_overlap

lalapps_cosmicstring_pipe.trig_overlap = config_parser.getint('pipeline', 'trig_overlap')

Definition at line 171 of file lalapps_cosmicstring_pipe.py.

◆ overlap

int lalapps_cosmicstring_pipe.overlap = short_segment_duration / 2 + 2 * pad

Definition at line 172 of file lalapps_cosmicstring_pipe.py.

◆ instruments

lalapps_cosmicstring_pipe.instruments = lsctables.instrumentsproperty.get(config_parser.get('pipeline','ifos'))

Definition at line 178 of file lalapps_cosmicstring_pipe.py.

◆ segments_cache

lalapps_cosmicstring_pipe.segments_cache = set([CacheEntry(None, "SEG", None, "file://localhost" + os.path.abspath(options.segments_file))])

Definition at line 179 of file lalapps_cosmicstring_pipe.py.

◆ seglists

lalapps_cosmicstring_pipe.seglists = ligolw_segments.segmenttable_get_by_name(ligolw_utils.load_filename(options.segments_file, verbose = options.verbose), options.segments_name).coalesce()

Definition at line 180 of file lalapps_cosmicstring_pipe.py.