Skip to content
Snippets Groups Projects

Process injections in online analysis

Merged Wanting Niu requested to merge test_sim_row_kafka_2 into master
Compare and
4 files
+ 36
7
Compare changes
  • Side-by-side
  • Inline
Files
4
@@ -373,8 +373,10 @@ def parse_command_line():
raise ValueError("must supply exactly as many --svd-bank options as --output")
if options.ranking_stat_output and len(options.ranking_stat_output) != len(options.output):
raise ValueError("must supply either none or exactly as many --ranking-stat-output options as --output")
if options.likelihood_snapshot_interval and not options.ranking_stat_output:
if (options.likelihood_snapshot_interval and not options.ranking_stat_output) and not options.injections:
raise ValueError("must set --ranking-stat-output when --likelihood-snapshot-interval is set")
if options.ranking_stat_output and options.injections:
raise ValueError("must not set --ranking-stat-output when --injections is set")
if options.ranking_stat_output is None or len(options.ranking_stat_output) == 0:
options.ranking_stat_output = [None] * len(options.output)
@@ -403,9 +405,12 @@ def parse_command_line():
if options.data_source in ("lvshm", "framexmit"):
missing_options = []
for option in ["job_tag", "ranking_stat_input", "ranking_stat_pdf", "zerolag_rankingstat_pdf"]:
for option in ["job_tag", "ranking_stat_input", "ranking_stat_pdf"]:
if getattr(options, option) is None:
missing_options.append("--%s" %option.replace("_","-"))
if not options.injections:
if getattr(options, "zerolag_rankingstat_pdf") is None:
missing_options.append("--zerolag-rankingstat-pdf")
if missing_options:
raise ValueError("missing required option(s) %s when --data-source is lvshm or framexmit" % ", ".join(missing_options))
@@ -776,7 +781,7 @@ for output_file_number, (svd_bank_url_dict, output_url, ranking_stat_output_url,
# the new injection file to disk before the pipeline starts up
#
if options.injections and options.reference_psd:
if (options.injections and options.reference_psd) and not options.data_source in ("lvshm", "framexmit"):
if options.verbose:
print("calculating expected SNR for injections...", file=sys.stderr)
Loading