diff --git a/gstlal-inspiral/bin/gstlal_inspiral_workflow b/gstlal-inspiral/bin/gstlal_inspiral_workflow index e32b79dd51922348fb1b4350f63aac0074ffe2ba..83fa2a1c927f5433728f327f70f790eb6ea9b0ca 100755 --- a/gstlal-inspiral/bin/gstlal_inspiral_workflow +++ b/gstlal-inspiral/bin/gstlal_inspiral_workflow @@ -31,7 +31,6 @@ parser.add_argument("-w", "--workflow", default="full", help="Sets the type of w # load config args = parser.parse_args() config = Config.load(args.config) -config.load_svd_manifest(config.svd.manifest) # create dag dag = DAG(config) diff --git a/gstlal-inspiral/bin/gstlal_ll_inspiral_workflow b/gstlal-inspiral/bin/gstlal_ll_inspiral_workflow index d7ececd10c6e3c5a24515132abb3a9dd27647991..7af76544791d1bc96aa8d1c70cdaad907e01073a 100755 --- a/gstlal-inspiral/bin/gstlal_ll_inspiral_workflow +++ b/gstlal-inspiral/bin/gstlal_ll_inspiral_workflow @@ -31,7 +31,6 @@ parser.add_argument("-w", "--workflow", default="inspiral", help="Sets the type # load config args = parser.parse_args() config = Config.load(args.config) -config.load_svd_manifest(config.svd.manifest) # create dag dag = DAG(config) diff --git a/gstlal-inspiral/python/config/inspiral.py b/gstlal-inspiral/python/config/inspiral.py index a371d7216be5bc419cb2340cf6b9b5fb22de60c4..282826688697a5e74e8cbb11983edd7b762620dc 100644 --- a/gstlal-inspiral/python/config/inspiral.py +++ b/gstlal-inspiral/python/config/inspiral.py @@ -17,6 +17,8 @@ import json +from ligo.segments import segment + from gstlal.config import Config as BaseConfig from gstlal.config import dotdict, replace_keys @@ -40,6 +42,17 @@ class Config(BaseConfig): if "services" in kwargs: self.services = dotdict(replace_keys(kwargs["services"])) + # load manifest + self.load_svd_manifest(self.svd.manifest) + + # calculate start pad for filtering + max_duration = max(svd_bin["max_dur"] for svd_bin in self.svd.stats.bins.values()) + self.filter.start_pad = 16 * self.psd.fft_length + max_duration + + # create time bins + if self.span != segment(0, 0): + self.create_time_bins(start_pad=self.filter.start_pad) + def load_svd_manifest(self, manifest_file): with open(manifest_file, "r") as f: svd_stats = dotdict(replace_keys(json.load(f)))