(fix) confirmation mode bugfix for the EventStreamRuntime

agenthub/codeact_agent/codeact_agent.py

@@ -17,6 +17,7 @@
     AgentDelegateObservation,
     CmdOutputObservation,
     IPythonRunCellObservation,
+    UserRejectObservation,
 )
 from openhands.events.observation.error import ErrorObservation
 from openhands.events.observation.observation import Observation
@@ -153,6 +154,10 @@ def get_observation_message(self, obs: Observation) -> Message | None:
             text = 'OBSERVATION:\n' + truncate_content(obs.content, max_message_chars)
             text += '\n[Error occurred in processing last action]'
             return Message(role='user', content=[TextContent(text=text)])
+        elif isinstance(obs, UserRejectObservation):
+            text = 'OBSERVATION:\n' + truncate_content(obs.content, max_message_chars)
+            text += '\n[Last action has been rejected by the user]'
+            return Message(role='user', content=[TextContent(text=text)])
         else:
             # If an observation message is not returned, it will cause an error
             # when the LLM tries to return the next message

openhands/events/observation/reject.py

@@ -6,7 +6,7 @@
 
 @dataclass
 class UserRejectObservation(Observation):
-    """This data class represents the result of a successful action."""
+    """This data class represents the result of a rejected action."""
 
     observation: str = ObservationType.USER_REJECTED
 

openhands/runtime/client/runtime.py

@@ -13,6 +13,7 @@
 from openhands.core.logger import openhands_logger as logger
 from openhands.events import EventStream
 from openhands.events.action import (
+    ActionConfirmationStatus,
     BrowseInteractiveAction,
     BrowseURLAction,
     CmdRunAction,
@@ -25,6 +26,7 @@
     ErrorObservation,
     NullObservation,
     Observation,
+    UserRejectObservation,
 )
 from openhands.events.serialization import event_to_dict, observation_from_dict
 from openhands.events.serialization.action import ACTION_TYPE_TO_CLASS
@@ -333,13 +335,26 @@ def run_action(self, action: Action) -> Observation:
         with self.action_semaphore:
             if not action.runnable:
                 return NullObservation('')
+            if (
+                hasattr(action, 'is_confirmed')
+                and action.is_confirmed
+                == ActionConfirmationStatus.AWAITING_CONFIRMATION
+            ):
+                return NullObservation('')
             action_type = action.action  # type: ignore[attr-defined]
             if action_type not in ACTION_TYPE_TO_CLASS:
                 return ErrorObservation(f'Action {action_type} does not exist.')
             if not hasattr(self, action_type):
                 return ErrorObservation(
                     f'Action {action_type} is not supported in the current runtime.'
                 )
+            if (
+                hasattr(action, 'is_confirmed')
+                and action.is_confirmed == ActionConfirmationStatus.REJECTED
+            ):
+                return UserRejectObservation(
+                    'Action has been rejected by the user! Waiting for further user input.'
+                )
 
             logger.info('Awaiting session')
             self._wait_until_alive()