From 263b2b7796e8b3e801da9d0db1c64464a46ad268 Mon Sep 17 00:00:00 2001
From: Cody Messick <cody.messick@ligo.org>
Date: Mon, 22 Jul 2019 14:06:20 -0400
Subject: [PATCH] lloidparts: Added queue with max_size_buffers = 1 after
 itacac, which appears fix the issue people are having with injection jobs
 occasionally hanging

---
 gstlal-inspiral/python/lloidparts.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/gstlal-inspiral/python/lloidparts.py b/gstlal-inspiral/python/lloidparts.py
index a16cfa2d63..282b463bec 100644
--- a/gstlal-inspiral/python/lloidparts.py
+++ b/gstlal-inspiral/python/lloidparts.py
@@ -723,5 +723,7 @@ def mkLLOIDmulti(pipeline, detectors, banks, psd, psd_fft_length = 32, ht_gate_t
 	assert any(itacac_dict.values())
 	if verbose:
 		for bank_id, head in itacac_dict.items():
-			itacac_dict[bank_id] = pipeparts.mkprogressreport(pipeline, head, "progress_xml_bank_%s" % bank_id)
+			# FIXME Not sure why we need a queue here, but without
+			# the queue one injection job in ~5000 hangs
+			itacac_dict[bank_id] = pipeparts.mkprogressreport(pipeline, pipeparts.mkqueue(pipeline, head, max_size_buffers = 1, max_size_bytes = 0, max_size_time = 0), "progress_xml_bank_%s" % bank_id)
 	return itacac_dict
-- 
GitLab