From ce5344da691145922983b8d53a72dd213945d311 Mon Sep 17 00:00:00 2001
From: codex <codex@local>
Date: Thu, 15 Oct 2026 21:32:08 +0200
Subject: [PATCH] Match receiver exclusive reconciliation end boundary

Assistant: codex
Assistant-Model: gpt-6-astra
Assistant-Session: 01a13eab-1e6a-7b33-9c37-372e90ada3a2
---
 scripts/cadence_observer_readback.py    | 2 +-
 tests/test_cadence_observer_readback.py | 6 ++++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/scripts/cadence_observer_readback.py b/scripts/cadence_observer_readback.py
index 75d12a3..f2be88d 100644
--- a/scripts/cadence_observer_readback.py
+++ b/scripts/cadence_observer_readback.py
@@ -102,7 +102,7 @@ def sanitize_record(record, source, tenant, instance, event_id, since, until):
     )
     accepted = record["accepted_at"]
     require(
-        stamp(since) <= stamp(accepted) <= stamp(until),
+        stamp(since) <= stamp(accepted) < stamp(until),
         "record_outside_acceptance_window",
     )
     action = record["action"]
diff --git a/tests/test_cadence_observer_readback.py b/tests/test_cadence_observer_readback.py
index 63136a5..4a08987 100644
--- a/tests/test_cadence_observer_readback.py
+++ b/tests/test_cadence_observer_readback.py
@@ -66,6 +66,12 @@ class ReadbackBounds(unittest.TestCase):
         with self.assertRaisesRegex(lane.LaneError, "acceptance_window"):
             self.sanitize(record)
 
+    def test_exact_until_is_excluded_like_receiver_sql(self):
+        record = self.record()
+        record["accepted_at"] = UNTIL
+        with self.assertRaisesRegex(lane.LaneError, "acceptance_window"):
+            self.sanitize(record)
+
     def test_paths_are_bounded_to_exact_approved_coordinates(self):
         result = lane.paths(
             "qonto-assistant",