fix: preserve checkpoint on breakpoint resume to prevent duplicate events

When a breakpoint fired before any new checkpoint was created during a
workflow.run() call, the stale checkpoint detection (baseline == latest)
saved checkpoint_id=None.  The next resume then replayed from
original_input, re-executing already-completed executors like triage,
which re-emitted handoff_to_billing_agent events (4x duplicates).

Fix: fall back to self._resumed_from_checkpoint_id instead of None when
no new checkpoint was created.  This preserves the checkpoint we resumed
from (still valid) instead of losing it.  For fresh turns,
_resumed_from_checkpoint_id is None, so the multi-turn stale checkpoint
fix from 5c6dc25 is preserved.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: cristipufu

packages/uipath-agent-framework/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-agent-framework"
-version = "0.0.7"
+version = "0.0.8"
 description = "Python SDK that enables developers to build and deploy Microsoft Agent Framework agents to the UiPath Cloud Platform"
 readme = "README.md"
 requires-python = ">=3.11"

packages/uipath-agent-framework/src/uipath_agent_framework/runtime/runtime.py

@@ -443,11 +443,15 @@ async def execute(
                 # Only save checkpoint_id if it was created during THIS run.
                 # If latest == baseline, no new checkpoint was created (e.g.
                 # breakpoint on the first executor of a fresh turn) — save
-                # None so the resume replays from original_input with skips.
+                # the checkpoint we resumed from (if any) so we don't lose
+                # it and replay from scratch on the next resume.
+                # For fresh turns _resumed_from_checkpoint_id is None, which
+                # correctly prevents using a stale checkpoint from the
+                # previous turn.
                 effective_checkpoint = (
                     latest_checkpoint
                     if latest_checkpoint != baseline_checkpoint_id
-                    else None
+                    else self._resumed_from_checkpoint_id
                 )
                 await self._save_breakpoint_state(
                     original_input, checkpoint_id=effective_checkpoint
@@ -655,13 +659,8 @@ async def _stream_workflow(
                         ):
                             if tool_event.phase not in emitted_phases:
                                 # Track pending tool nodes
-                                if (
-                                    tool_event.phase
-                                    == UiPathRuntimeStatePhase.STARTED
-                                ):
-                                    self._pending_tool_nodes.add(
-                                        tool_event.node_name
-                                    )
+                                if tool_event.phase == UiPathRuntimeStatePhase.STARTED:
+                                    self._pending_tool_nodes.add(tool_event.node_name)
                                 elif (
                                     tool_event.phase
                                     == UiPathRuntimeStatePhase.COMPLETED
@@ -683,9 +682,9 @@ async def _stream_workflow(
                         event.data, executor_id
                     )
                     for tool_event in tool_events:
-                        executor_tool_phases.setdefault(
-                            executor_id, set()
-                        ).add(tool_event.phase)
+                        executor_tool_phases.setdefault(executor_id, set()).add(
+                            tool_event.phase
+                        )
                         # Track pending tool nodes across stream iterations
                         if tool_event.phase == UiPathRuntimeStatePhase.STARTED:
                             self._pending_tool_nodes.add(tool_event.node_name)
@@ -738,10 +737,12 @@ async def _stream_workflow(
                 )
                 self._last_breakpoint_node = node_id
                 # Only save checkpoint_id if it was created during THIS run.
+                # Fall back to the checkpoint we resumed from (if any) to
+                # avoid replaying from scratch on the next resume.
                 effective_checkpoint = (
                     latest_checkpoint
                     if latest_checkpoint != baseline_checkpoint_id
-                    else None
+                    else self._resumed_from_checkpoint_id
                 )
                 await self._save_breakpoint_state(
                     user_input, checkpoint_id=effective_checkpoint