fix: debugger emit interrupt hit

Author: cristipufu

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "uipath-runtime"
-version = "0.1.3"
+version = "0.2.0"
 description = "Runtime abstractions and interfaces for building agents and automation scripts in the UiPath ecosystem"
 readme = { file = "README.md", content-type = "text/markdown" }
 requires-python = ">=3.11"

src/uipath/runtime/debug/bridge.py

@@ -37,6 +37,10 @@ async def emit_breakpoint_hit(
         """Notify debugger that a breakpoint was hit."""
         ...
 
+    async def emit_interrupt_hit(self, result: UiPathRuntimeResult) -> None:
+        """Notify debugger that an interrupt was hit."""
+        ...
+
     async def emit_execution_completed(
         self,
         runtime_result: UiPathRuntimeResult,

src/uipath/runtime/debug/runtime.py

@@ -27,7 +27,10 @@
 )
 from uipath.runtime.resumable.protocols import UiPathResumeTriggerReaderProtocol
 from uipath.runtime.resumable.runtime import UiPathResumableRuntime
-from uipath.runtime.resumable.trigger import UiPathResumeTrigger
+from uipath.runtime.resumable.trigger import (
+    UiPathResumeTrigger,
+    UiPathResumeTriggerType,
+)
 from uipath.runtime.schema import UiPathRuntimeSchema
 
 logger = logging.getLogger(__name__)
@@ -192,9 +195,19 @@ async def _stream_and_debug(
 
                             resume_data: dict[str, Any] | None = None
                             try:
-                                resume_data = await self._poll_trigger(
-                                    final_result.trigger, self.delegate.trigger_manager
-                                )
+                                if (
+                                    final_result.trigger.trigger_type
+                                    == UiPathResumeTriggerType.API
+                                ):
+                                    await self.debug_bridge.emit_interrupt_hit(event)
+                                    resume_data = (
+                                        await self.debug_bridge.wait_for_resume()
+                                    )
+                                else:
+                                    resume_data = await self._poll_trigger(
+                                        final_result.trigger,
+                                        self.delegate.trigger_manager,
+                                    )
                             except UiPathDebugQuitError:
                                 final_result = UiPathRuntimeResult(
                                     status=UiPathRuntimeStatus.SUCCESSFUL,

src/uipath/runtime/resumable/runtime.py

@@ -146,6 +146,7 @@ async def _handle_suspension(
 
         suspended_result = UiPathRuntimeResult(
             status=UiPathRuntimeStatus.SUSPENDED,
+            output=result.output,
         )
 
         if result.output: