Skip to content
Snippets Groups Projects
Commit 0cc882f4 authored by Prathamesh Joshi's avatar Prathamesh Joshi
Browse files

Added support for non-inj only workflows

parent f0b57b87
No related branches found
No related tags found
2 merge requests!500First commit of gstlal_inspiral_generate_epochs,!488Draft: Online rerank dev
Pipeline #518521 canceled
......@@ -113,7 +113,8 @@ elif args.command == "create":
# load the rest of the filter data products
#segments = find_online(config.rank.segments_name, root = os.path.join(config.data.rerank_dir, 'segments'), svd_bins = bin_dict.keys(), subtype = "TRIGGERS")
triggers = find_online(config.rank.triggers_name, start = int(config.start), end = bin_dict, root = config.data.analysis_dir, svd_bins = bin_dict.keys(), subtype = "TRIGGERS")
inj_triggers = find_online(config.rank.inj_triggers_name, start = int(config.start), end = bin_dict, root = config.data.analysis_dir, svd_bins = bin_dict.keys(), subtype = "TRIGGERS")
if config.filter.injections:
inj_triggers = find_online(config.rank.inj_triggers_name, start = int(config.start), end = bin_dict, root = config.data.analysis_dir, svd_bins = bin_dict.keys(), subtype = "TRIGGERS")
## inverted segments are used as vetos for when the original analysis was off
#inverted_segments = find_online(config.rank.segments_name, root = os.path.join(config.data.rerank_dir, 'inverted_segments'), subtype = "TRIGGERS")
......@@ -126,7 +127,8 @@ elif args.command == "create":
ref_psd = DataCache.find(DataType.REFERENCE_PSD, root=config.data.rerank_dir)
dist_stats = dag.create_prior_seed(dist_stats, svd_bank, ref_psd)
triggers += inj_triggers
if config.filter.injections:
triggers += inj_triggers
triggers = dag.add_and_simplify(triggers)
triggers = dag.calc_likelihood(triggers, dist_stats)
triggers = dag.merge_and_reduce(triggers)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment