Commit 3fddfa47 authored by gstlalcbc's avatar gstlalcbc

FAR trials factor command line option

parent 371f44d5
...@@ -638,7 +638,7 @@ class Handler(simplehandler.Handler): ...@@ -638,7 +638,7 @@ class Handler(simplehandler.Handler):
dumps of segment information, trigger files and background dumps of segment information, trigger files and background
distribution statistics. distribution statistics.
""" """
def __init__(self, mainloop, pipeline, coincs_document, rankingstat, horizon_distance_func, gracedbwrapper, zerolag_rankingstatpdf_url = None, rankingstatpdf_url = None, ranking_stat_output_url = None, ranking_stat_input_url = None, likelihood_snapshot_interval = None, sngls_snr_threshold = None, tag = "", kafka_server = "10.14.0.112:9092", cluster = False, cap_singles = False, verbose = False): def __init__(self, mainloop, pipeline, coincs_document, rankingstat, horizon_distance_func, gracedbwrapper, zerolag_rankingstatpdf_url = None, rankingstatpdf_url = None, ranking_stat_output_url = None, ranking_stat_input_url = None, likelihood_snapshot_interval = None, sngls_snr_threshold = None, tag = "", kafka_server = "10.14.0.112:9092", cluster = False, cap_singles = False, FAR_trialsfactor = 1.0, verbose = False):
"""! """!
@param mainloop The main application's event loop @param mainloop The main application's event loop
@param pipeline The gstreamer pipeline that is being @param pipeline The gstreamer pipeline that is being
...@@ -664,6 +664,7 @@ class Handler(simplehandler.Handler): ...@@ -664,6 +664,7 @@ class Handler(simplehandler.Handler):
self.likelihood_snapshot_timestamp = None self.likelihood_snapshot_timestamp = None
self.cluster = cluster self.cluster = cluster
self.cap_singles = cap_singles self.cap_singles = cap_singles
self.FAR_trialsfactor = FAR_trialsfactor
self.gracedbwrapper = gracedbwrapper self.gracedbwrapper = gracedbwrapper
# FIXME: detangle this # FIXME: detangle this
...@@ -1112,7 +1113,7 @@ class Handler(simplehandler.Handler): ...@@ -1112,7 +1113,7 @@ class Handler(simplehandler.Handler):
if not self.stream_thinca.push(instrument, [event for event in events if event.ifo == instrument], buf_timestamp): if not self.stream_thinca.push(instrument, [event for event in events if event.ifo == instrument], buf_timestamp):
continue continue
flushed_sngls = self.stream_thinca.pull(self.rankingstat, fapfar = self.fapfar, zerolag_rankingstatpdf = self.zerolag_rankingstatpdf, coinc_sieve = self.rankingstat.fast_path_cut_from_triggers, cluster = self.cluster, cap_singles = self.cap_singles) flushed_sngls = self.stream_thinca.pull(self.rankingstat, fapfar = self.fapfar, zerolag_rankingstatpdf = self.zerolag_rankingstatpdf, coinc_sieve = self.rankingstat.fast_path_cut_from_triggers, cluster = self.cluster, cap_singles = self.cap_singles, FAR_trialsfactor = self.FAR_trialsfactor)
self.coincs_document.commit() self.coincs_document.commit()
# do GraceDB alerts and update eye candy # do GraceDB alerts and update eye candy
...@@ -1334,7 +1335,7 @@ class Handler(simplehandler.Handler): ...@@ -1334,7 +1335,7 @@ class Handler(simplehandler.Handler):
# whatever triggers remain in the queues, and processes # whatever triggers remain in the queues, and processes
# them # them
flushed_sngls = self.stream_thinca.pull(self.rankingstat, fapfar = self.fapfar, zerolag_rankingstatpdf = self.zerolag_rankingstatpdf, coinc_sieve = self.rankingstat.fast_path_cut_from_triggers, flush = True, cluster = self.cluster, cap_singles = self.cap_singles) flushed_sngls = self.stream_thinca.pull(self.rankingstat, fapfar = self.fapfar, zerolag_rankingstatpdf = self.zerolag_rankingstatpdf, coinc_sieve = self.rankingstat.fast_path_cut_from_triggers, flush = True, cluster = self.cluster, cap_singles = self.cap_singles, FAR_trialsfactor = self.FAR_trialsfactor)
self.coincs_document.commit() self.coincs_document.commit()
# do GraceDB alerts # do GraceDB alerts
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment