chore: fix repo issues for minor increment

Author: GabrielVasilescu04

src/uipath/runtime/__init__.py

@@ -11,7 +11,7 @@
 from uipath.runtime.chat.runtime import UiPathChatRuntime
 from uipath.runtime.context import UiPathRuntimeContext
 from uipath.runtime.debug.breakpoint import UiPathBreakpointResult
-from uipath.runtime.debug.bridge import UiPathDebugBridgeProtocol
+from uipath.runtime.debug.bridge import UiPathDebugProtocol
 from uipath.runtime.debug.exception import UiPathDebugQuitError
 from uipath.runtime.debug.runtime import (
     UiPathDebugRuntime,
@@ -63,7 +63,7 @@
     "UiPathResumeTriggerType",
     "UiPathResumableRuntime",
     "UiPathDebugQuitError",
-    "UiPathDebugBridgeProtocol",
+    "UiPathDebugProtocol",
     "UiPathDebugRuntime",
     "UiPathBreakpointResult",
     "UiPathStreamNotSupportedError",

src/uipath/runtime/debug/__init__.py

@@ -1,15 +1,15 @@
 """Initialization module for the debug package."""
 
 from uipath.runtime.debug.breakpoint import UiPathBreakpointResult
-from uipath.runtime.debug.bridge import UiPathDebugBridgeProtocol
+from uipath.runtime.debug.bridge import UiPathDebugProtocol
 from uipath.runtime.debug.exception import (
     UiPathDebugQuitError,
 )
 from uipath.runtime.debug.runtime import UiPathDebugRuntime
 
 __all__ = [
     "UiPathDebugQuitError",
-    "UiPathDebugBridgeProtocol",
+    "UiPathDebugProtocol",
     "UiPathDebugRuntime",
     "UiPathBreakpointResult",
 ]

src/uipath/runtime/debug/bridge.py

@@ -9,7 +9,7 @@
 )
 
 
-class UiPathDebugBridgeProtocol(Protocol):
+class UiPathDebugProtocol(Protocol):
     """Abstract interface for debug communication.
 
     Implementations: SignalR, Console, WebSocket, etc.

src/uipath/runtime/debug/runtime.py

@@ -14,7 +14,7 @@
 )
 from uipath.runtime.debug import (
     UiPathBreakpointResult,
-    UiPathDebugBridgeProtocol,
+    UiPathDebugProtocol,
     UiPathDebugQuitError,
 )
 from uipath.runtime.events import (
@@ -42,7 +42,7 @@ class UiPathDebugRuntime:
     def __init__(
         self,
         delegate: UiPathRuntimeProtocol,
-        debug_bridge: UiPathDebugBridgeProtocol,
+        debug_bridge: UiPathDebugProtocol,
         trigger_poll_interval: float = 5.0,
     ):
         """Initialize the UiPathDebugRuntime.
@@ -54,7 +54,7 @@ def __init__(
         """
         super().__init__()
         self.delegate = delegate
-        self.debug_bridge: UiPathDebugBridgeProtocol = debug_bridge
+        self.debug_bridge: UiPathDebugProtocol = debug_bridge
         if trigger_poll_interval < 0:
             raise ValueError("trigger_poll_interval must be >= 0")
         self.trigger_poll_interval = trigger_poll_interval

src/uipath/runtime/resumable/protocols.py

@@ -8,7 +8,7 @@
 class UiPathResumableStorageProtocol(Protocol):
     """Protocol for storing and retrieving resume triggers."""
 
-    async def save_trigger(self, trigger: UiPathResumeTrigger) -> None:
+    async def save_trigger(self, runtime_id: str, trigger: UiPathResumeTrigger) -> None:
         """Save a resume trigger to storage.
 
         Args:
@@ -19,7 +19,7 @@ async def save_trigger(self, trigger: UiPathResumeTrigger) -> None:
         """
         ...
 
-    async def get_latest_trigger(self) -> UiPathResumeTrigger | None:
+    async def get_latest_trigger(self, runtime_id: str) -> UiPathResumeTrigger | None:
         """Retrieve the most recent resume trigger from storage.
 
         Returns:

src/uipath/runtime/resumable/runtime.py

@@ -35,17 +35,20 @@ def __init__(
         delegate: UiPathRuntimeProtocol,
         storage: UiPathResumableStorageProtocol,
         trigger_manager: UiPathResumeTriggerProtocol,
+        runtime_id: str
     ):
         """Initialize the resumable runtime wrapper.
 
         Args:
             delegate: The underlying runtime to wrap
             storage: Storage for persisting/retrieving resume triggers
             trigger_manager: Manager for creating and reading resume triggers
+            runtime_id: Id used for runtime orchestration
         """
         self.delegate = delegate
         self.storage = storage
         self.trigger_manager = trigger_manager
+        self.runtime_id = runtime_id
 
     async def execute(
         self,
@@ -115,7 +118,7 @@ async def _restore_resume_input(
             return input
 
         # Otherwise, fetch from storage
-        trigger = await self.storage.get_latest_trigger()
+        trigger = await self.storage.get_latest_trigger(self.runtime_id)
         if not trigger:
             return None
 
@@ -141,7 +144,7 @@ async def _handle_suspension(
 
         # Check if trigger already exists in result
         if result.trigger:
-            await self.storage.save_trigger(result.trigger)
+            await self.storage.save_trigger(self.runtime_id, result.trigger)
             return result
 
         suspended_result = UiPathRuntimeResult(
@@ -154,7 +157,7 @@ async def _handle_suspension(
                 result.output
             )
 
-            await self.storage.save_trigger(suspended_result.trigger)
+            await self.storage.save_trigger(self.runtime_id, suspended_result.trigger)
 
         return suspended_result
 

tests/test_debugger.py

@@ -17,21 +17,21 @@
     UiPathStreamOptions,
 )
 from uipath.runtime.debug import (
-    UiPathDebugBridgeProtocol,
+    UiPathDebugProtocol,
     UiPathDebugQuitError,
     UiPathDebugRuntime,
 )
 from uipath.runtime.events import UiPathRuntimeEvent, UiPathRuntimeStateEvent
 from uipath.runtime.schema import UiPathRuntimeSchema
 
 
-def make_debug_bridge_mock() -> UiPathDebugBridgeProtocol:
+def make_debug_bridge_mock() -> UiPathDebugProtocol:
     """Create a debug bridge mock with all methods that UiPathDebugRuntime uses.
 
     We use `spec=UiPathDebugBridge` so invalid attributes raise at runtime,
     but still operate as a unittest.mock.Mock with AsyncMock methods.
     """
-    bridge_mock: Mock = Mock(spec=UiPathDebugBridgeProtocol)
+    bridge_mock: Mock = Mock(spec=UiPathDebugProtocol)
 
     bridge_mock.connect = AsyncMock()
     bridge_mock.disconnect = AsyncMock()
@@ -44,7 +44,7 @@ def make_debug_bridge_mock() -> UiPathDebugBridgeProtocol:
 
     bridge_mock.get_breakpoints = Mock(return_value=["node-1"])
 
-    return cast(UiPathDebugBridgeProtocol, bridge_mock)
+    return cast(UiPathDebugProtocol, bridge_mock)
 
 
 class StreamingMockRuntime: