diff --git a/gstlal-inspiral/python/inspiral_pipe.py b/gstlal-inspiral/python/inspiral_pipe.py index 4f2c130bd242772cd3c261f8d1f2f0126716eba8..5c8a79f0e0da2c31287853ed3697dd7b281e0ec9 100644 --- a/gstlal-inspiral/python/inspiral_pipe.py +++ b/gstlal-inspiral/python/inspiral_pipe.py @@ -291,6 +291,8 @@ def aggregator_layer(dag, jobs, options, job_tags): def dq_monitor_layer(dag, jobs, options): outpath = 'aggregator' + ll_dq_jobs = [] + for ifo in options.channel_dict: # Data source dag options if (options.data_source == "framexmit"): @@ -331,7 +333,9 @@ def dq_monitor_layer(dag, jobs, options): if options.enable_https: common_opts.update({"enable-https": ""}) - return dagparts.DAGNode(jobs['dq'], dag, [], opts = common_opts) + ll_dq_jobs.append(dagparts.DAGNode(jobs['dq'], dag, [], opts = common_opts)) + + return ll_dq_jobs def ref_psd_layer(dag, jobs, parent_nodes, segsdict, channel_dict, options):