From beb1edad5c74d5d70841ad85e45db3de38e91ea3 Mon Sep 17 00:00:00 2001
From: Chadwick Boulay <chadwick.boulay@gmail.com>
Date: Wed, 11 Feb 2026 00:26:31 -0500
Subject: [PATCH] MergeProcessor - compare time gains with math.isclose instead
 of ==

---
 src/ezmsg/sigproc/merge.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/ezmsg/sigproc/merge.py b/src/ezmsg/sigproc/merge.py
index 38cac463..70afe935 100644
--- a/src/ezmsg/sigproc/merge.py
+++ b/src/ezmsg/sigproc/merge.py
@@ -2,6 +2,7 @@
 
 from __future__ import annotations
 
+import math
 import typing
 
 import ezmsg.core as ez
@@ -165,7 +166,7 @@ def push_b(self, message: AxisArray) -> AxisArray | None:
 
         # Gain compatibility check.
         b_gain = self._extract_gain(message)
-        if self._state.gain is not None and b_gain != self._state.gain:
+        if self._state.gain is not None and not math.isclose(b_gain, self._state.gain):
             self._full_reset(align_axis)
             # Set the base-class hash so the next compatible A goes straight
             # to _process instead of triggering another full reset.