Merge pull request #189 from UiPath/fix/hitl-session-persistence

fix: HITL session persistence, tool events, and breakpoint interaction

Author: cristipufu

packages/uipath-agent-framework/pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-agent-framework"
-version = "0.0.6"
+version = "0.0.7"
 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/samples/hitl-workflow/main.py

@@ -54,7 +54,7 @@ def issue_refund(order_id: str, amount: float, reason: str) -> str:
     return f"Refund of ${amount:.2f} issued for order {order_id}: {reason}"
 
 
-client = UiPathOpenAIChatClient(model="gpt-5-mini-2025-08-07")
+client = UiPathOpenAIChatClient()
 
 triage = client.as_agent(
     name="triage",

packages/uipath-agent-framework/samples/hitl-workflow/pyproject.toml

@@ -18,4 +18,3 @@ dev = [
 
 [tool.uv]
 prerelease = "allow"
-

packages/uipath-agent-framework/src/uipath_agent_framework/chat/openai.py

@@ -67,15 +67,15 @@ class UiPathOpenAIChatClient(OpenAIChatClient):
 
         from uipath_agent_framework.chat import UiPathOpenAIChatClient
 
-        client = UiPathOpenAIChatClient(model="gpt-4o-mini")
+        client = UiPathOpenAIChatClient(model="gpt-4.1-mini-2025-04-14")
         agent = client.as_agent(
             name="assistant",
             instructions="You are a helpful assistant.",
             tools=[my_tool],
         )
     """
 
-    def __init__(self, model: str = "gpt-4o-mini", **kwargs: Any):
+    def __init__(self, model: str = "gpt-4.1-mini-2025-04-14", **kwargs: Any):
         uipath_url, token = get_uipath_config()
         gateway_url = build_gateway_url("openai", model, uipath_url)
 

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

@@ -184,12 +184,20 @@ def map_streaming_content(
 
     def close_message(self) -> list[UiPathConversationMessageEvent]:
         """Close the current message if open. Safety net for end of stream."""
+        events: list[UiPathConversationMessageEvent] = []
+        # Emit ToolCallEnd for any tool calls that were started but never
+        # completed (e.g. HITL suspension interrupted before function_result).
+        if self._pending_tool_calls:
+            for tool_call_id, message_id in self._pending_tool_calls.items():
+                events.append(
+                    self._make_tool_call_end_event(message_id, tool_call_id, {})
+                )
+            self._pending_tool_calls.clear()
         if self._message_started and self._current_message_id:
-            events = [self._make_message_end_event(self._current_message_id)]
+            events.append(self._make_message_end_event(self._current_message_id))
             self._message_started = False
             self._current_message_id = None
-            return events
-        return []
+        return events
 
     @staticmethod
     def _extract_text_from_content(content: Content) -> str: