diff --git a/gstlal-inspiral/bin/gstlal_ll_inspiral_pipe b/gstlal-inspiral/bin/gstlal_ll_inspiral_pipe index 96a6664081269a62fa8833715f8040de51dee22a..70a486b2a9ebb73beb6cf84f92767076770dc54c 100755 --- a/gstlal-inspiral/bin/gstlal_ll_inspiral_pipe +++ b/gstlal-inspiral/bin/gstlal_ll_inspiral_pipe @@ -391,9 +391,18 @@ for ifo in channel_dict: "dq-vector-on-bits":options.dq_vector_on_bits, "dq-vector-off-bits":options.dq_vector_off_bits, "data-source":options.data_source, - "out-path": outpath + "out-path": outpath, + "data-backend": options.agg_data_backend, } common_opts.update(datasource_opts) + + if options.agg_data_backend == 'influx': + common_opts.update({ + "influx-database-name": options.influx_database_name, + "influx-hostname": options.influx_hostname, + "influx-port": options.influx_port, + }) + dagparts.DAGNode(dqJob, dag, [], opts = common_opts) #