fix(agent): clamp flush cursor after repair_message_sequence compaction (#44837)

2026-06-12 16:29:01 -07:00
parent aec38855b5
commit 5d0408d9fe
2 changed files with 14 additions and 1 deletions
@@ -602,6 +602,14 @@ def run_conversation(
                repaired_seq,
                agent.session_id or "-",
            )
+            # Clamp the SessionDB flush cursor after compaction.  If repair
+            # merged or dropped messages, _last_flushed_db_idx may now point
+            # past the new end of `messages`, causing turn-end flush to skip
+            # the assistant/tool chain entirely (#44837).
+            if hasattr(agent, "_last_flushed_db_idx"):
+                agent._last_flushed_db_idx = min(
+                    agent._last_flushed_db_idx, len(messages)
+                )

        api_messages = []
        for idx, msg in enumerate(messages):