diff --git a/gstlal-burst/bin/gstlal_feature_extractor_pipe b/gstlal-burst/bin/gstlal_feature_extractor_pipe index 0db02bb23d5a459840baa049acbe9835d5cf14f5..e045aea3676db269907af3a810580845b8a2fdb4 100755 --- a/gstlal-burst/bin/gstlal_feature_extractor_pipe +++ b/gstlal-burst/bin/gstlal_feature_extractor_pipe @@ -214,12 +214,24 @@ condor_commands = dagparts.condor_command_dict_from_opts(options.condor_command, feature_extractor_job = dagparts.DAGJob("gstlal_feature_extractor", condor_commands = condor_commands) segsdict = analysis_segments(ifo, data_source_info.frame_segments, data_source_info.seg, options.segment_length, max_template_length=max_template_length) +combiner_condor_options = {"request_memory":"4GB", "request_cpus":2, "want_graceful_removal":"True", "kill_sig":"15"} +feature_combiner_job = dagparts.DAGJob("gstlal_feature_combiner", condor_commands = combiner_condor_options) + # # set up jobs # feature_extractor_nodes = feature_extractor_node_gen(feature_extractor_job, dag, [], segsdict, ifo, options, data_source_info, max_template_length=max_template_length) +feature_combiner_options = { + "verbose": options.verbose, + "rootdir": os.path.join(options.out_path, "gstlal_feature_extractor"), + "basename": options.description, + "instrument": ifo, + "tag": "offline", +} +feature_combiner_nodes = dagparts.DAGNode(feature_combiner_job, dag, parent_nodes = feature_extractor_nodes.values(), opts = feature_combiner_options) + # # write out dag and sub files #