add itacac elem to pipeparts

gstlal/python/pipeparts/__init__.py

@@ -19,6 +19,7 @@ __version__ = "FIXME"
 __date__ = "FIXME"
 
 
+<<<<<<< HEAD
 __doc__ = """The `pipeparts` module contains all of the *elements* used to construct gstreamer pipelines
 for gravitational wave analysis. These elements are grouped into thematic submodules.
 """
@@ -81,6 +82,7 @@ from .filters import iir as mkiirfilter
 from .filters import inject as mkinjections
 from .transform import interpolator as mkinterpolator
 from .trigger import itac as mkitac
+from .trigger import itacac as mkitacac
 from .source import cache as mklalcachesrc
 from .transform import latency as mklatency
 from .transform import lho_coherent_null as mklhocoherentnull

gstlal/python/pipeparts/trigger.py

@@ -188,3 +188,31 @@ def itac(pipeline: pipetools.Pipeline, src: pipetools.Element, n: int, bank: str
 	if sigmasq is not None:
 		properties["sigmasq"] = sigmasq
 	return pipetools.make_element_with_src(pipeline, src, "lal_itac", **properties)
+
+
+def mkitacac(pipeline, srcs, **properties):
+	"""Find coincident inspiral triggers in snr streams from multiple detectors
+
+	Args:
+		pipeline:
+			Gst.Pipeline, the pipeline to which the new element will be added
+		srcs:
+			Mapping[str, Gst.Element], maps detector strings to Gst.Elements
+		**properties
+			maps detector strings to pad properties
+
+	References:
+		Implementation: gstlal-inspiral/gst/lal/gstlal_itacac.c
+
+	Returns:
+		Element
+	"""
+	elem = pipetools.make_element_with_src(pipeline, None, "lal_itacac")
+
+	for idx, (key, src) in enumerate(srcs.items()):
+		pad = elem.get_request_pad(f"sink{idx:d}")
+		for prop, val in properties[key].items():
+			pad.set_property(prop, val)
+		src.srcpads[0].link(pad)
+
+	return elem