gstlal_inspiral_create_dt_dphi_snr_ratio_pdfs_dag: add a final merging job

gstlal-inspiral/bin/gstlal_inspiral_create_dt_dphi_snr_ratio_pdfs_dag

@@ -28,13 +28,19 @@ except:
 	pass
 dag = inspiral_pipe.DAG("dt_dphi")
 
-margJob = inspiral_pipe.generic_job("gstlal_inspiral_create_dt_dphi_snr_ratio_pdfs", condor_commands = {"request_memory":"4GB", "want_graceful_removal":"True", "kill_sig":"15", "accounting_group":"ligo.prod.o2.cbc.uber.gstlaloffline"})
+margJob = inspiral_pipe.generic_job("gstlal_inspiral_create_dt_dphi_snr_ratio_pdfs", condor_commands = {"request_memory":"8GB", "want_graceful_removal":"True", "kill_sig":"15", "accounting_group":"ligo.prod.o2.cbc.uber.gstlaloffline"})
+addJob = inspiral_pipe.generic_job("gstlal_inspiral_add_dt_dphi_snr_ratio_pdfs", condor_commands = {"request_memory":"4GB", "want_graceful_removal":"True", "kill_sig":"15", "accounting_group":"ligo.prod.o2.cbc.uber.gstlaloffline"})
+
+num = 1000
+margnodes = []
+# FIXME dont hardcode 3345408, it comes from number of tiles in TimePhaseSNR
+for start in range(0, 3345408, num):
+	stop = start + num
+	margnodes.append(inspiral_pipe.generic_node(margJob, dag, parent_nodes = [], opts = {"start":str(start), "stop":str(stop)}, output_files = {"output":"%s/inspiral_dtdphi_pdf_%d_%d.h5" % (margJob.output_path, start, stop)}))
+
+addnode = inspiral_pipe.generic_node(addJob, dag, parent_nodes = margnodes, input_files = {"": [n.output_files["output"] for n in margnodes]})
 
-for start in range(0,3345408,10000):
-	stop = start + 10000
-	inspiral_pipe.generic_node(margJob, dag, parent_nodes = [], opts = {"" : [str(start), str(stop)]})
 dag.write_sub_files()
 dag.write_dag()
 dag.write_script()
 dag.write_cache()
-