Skip to content
Snippets Groups Projects
Commit a9b38bd8 authored by Patrick Godwin's avatar Patrick Godwin
Browse files

gstlal_inspiral_workflow: fix default locations of data products for data discovery

parent 93603bb7
No related branches found
No related tags found
1 merge request!41DAG Workflow Overhaul + OSG DAG support
......@@ -18,6 +18,7 @@
import argparse
import os
from gstlal.config.inspiral import Config
from gstlal.dags.inspiral import DAG
......@@ -39,7 +40,7 @@ dag.create_log_dir()
# generate dag layers
if args.workflow in set(("full", "filter")):
# input data products
split_bank = DataCache.find(DataType.SPLIT_BANK, root=config.data.rootdir)
split_bank = DataCache.find(DataType.SPLIT_BANK)
# generate filter dag layers
ref_psd = dag.reference_psd()
......@@ -49,10 +50,11 @@ if args.workflow in set(("full", "filter")):
triggers, dist_stats = dag.aggregate(triggers, dist_stats)
else:
# load filter data products
triggers = DataCache.find(DataType.TRIGGERS, root=config.data.rootdir)
svd_bank = DataCache.find(DataType.SVD_BANK, root=config.data.rootdir)
dist_stats = DataCache.find(DataType.DIST_STATS, root=config.data.rootdir)
median_psd = DataCache.find(DataType.MEDIAN_PSD, root=config.data.rootdir)
filter_dir = os.path.join(config.data.analysis_dir, "filter")
triggers = DataCache.find(DataType.TRIGGERS, root=filter_dir)
svd_bank = DataCache.find(DataType.SVD_BANK, root=filter_dir)
dist_stats = DataCache.find(DataType.DIST_STATS, root=filter_dir)
median_psd = DataCache.find(DataType.MEDIAN_PSD, root=config.data.analysis_dir)
if args.workflow in set(("full", "rerank")):
# generate rerank dag layers
......
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