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

gstlal_etg_pipe: changed directory structure of where triggers are written to disk

parent bf4c0f66
No related branches found
No related tags found
No related merge requests found
...@@ -156,6 +156,7 @@ def etg_node_gen(gstlalETGJob, dag, parent_nodes, segsdict, ifo, options, channe ...@@ -156,6 +156,7 @@ def etg_node_gen(gstlalETGJob, dag, parent_nodes, segsdict, ifo, options, channe
cumsum_rates += n_rates cumsum_rates += n_rates
outstr = outstr + channel + ":" + str(int(samp_rate)) outstr = outstr + channel + ":" + str(int(samp_rate))
channel_list.append(channel + " " + str(int(samp_rate))) channel_list.append(channel + " " + str(int(samp_rate)))
outpath = os.path.join(options.out_path, "gstlal_etg")
# Adds channel to current process # Adds channel to current process
if cumsum_rates < n_threads and ii < len(data_source_info.channel_dict.keys()): if cumsum_rates < n_threads and ii < len(data_source_info.channel_dict.keys()):
...@@ -164,7 +165,6 @@ def etg_node_gen(gstlalETGJob, dag, parent_nodes, segsdict, ifo, options, channe ...@@ -164,7 +165,6 @@ def etg_node_gen(gstlalETGJob, dag, parent_nodes, segsdict, ifo, options, channe
# Finalise each process once number of threads passes threshold # Finalise each process once number of threads passes threshold
if cumsum_rates >= n_threads or ii == len(data_source_info.channel_dict.keys()): if cumsum_rates >= n_threads or ii == len(data_source_info.channel_dict.keys()):
out_index += 1 out_index += 1
outpath = options.out_path + "/gstlal_etg/gstlal_etg_%04d" %(out_index)
etg_nodes[channel] = \ etg_nodes[channel] = \
inspiral_pipe.generic_node(gstlalETGJob, dag, parent_nodes = parent_nodes, inspiral_pipe.generic_node(gstlalETGJob, dag, parent_nodes = parent_nodes,
opts = {"gps-start-time":int(seg[0]), opts = {"gps-start-time":int(seg[0]),
...@@ -176,6 +176,7 @@ def etg_node_gen(gstlalETGJob, dag, parent_nodes, segsdict, ifo, options, channe ...@@ -176,6 +176,7 @@ def etg_node_gen(gstlalETGJob, dag, parent_nodes, segsdict, ifo, options, channe
"mismatch":options.mismatch, "mismatch":options.mismatch,
"qhigh":options.qhigh, "qhigh":options.qhigh,
"cadence":options.cadence, "cadence":options.cadence,
"job-id": out_index,
"disable-web-service":"", "disable-web-service":"",
"frame-segments-name": options.frame_segments_name, "frame-segments-name": options.frame_segments_name,
"save-hdf": options.save_hdf "save-hdf": options.save_hdf
......
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