Update openhands/controller/agent_controller.py

- Remove directory creation logic since /openhands/outputs is created by server
- Remove chmod calls since permissions are handled by server
- Keep core functionality of saving full content and truncating

openhands/controller/agent_controller.py

@@ -39,7 +39,7 @@ from openhands.events.observation import (
     NullObservation,
     Observation,
 )
-from openhands.events.serialization.event import truncate_content
+
 from openhands.llm.llm import LLM
 from openhands.runtime.utils.shutdown_listener import should_continue
 
@@ -255,10 +255,6 @@ class AgentController:
             observation (observation): The observation to handle.
         """
         observation_to_print = copy.deepcopy(observation)
-        if len(observation_to_print.content) > self.agent.llm.config.max_message_chars:
-            observation_to_print.content = truncate_content(
-                observation_to_print.content, self.agent.llm.config.max_message_chars
-            )
         self.log('debug', str(observation_to_print), extra={'msg_type': 'OBSERVATION'})
 
         if observation.llm_metrics is not None:

openhands/events/serialization/event.py

@@ -111,20 +111,7 @@ def event_to_memory(event: 'Event', max_message_chars: int) -> dict:
 
     if 'extras' in d:
         remove_fields(d['extras'], DELETE_FROM_MEMORY_EXTRAS)
-    if isinstance(event, Observation) and 'content' in d:
-        d['content'] = truncate_content(d['content'], max_message_chars)
     return d
 
 
-def truncate_content(content: str, max_chars: int) -> str:
-    """Truncate the middle of the observation content if it is too long."""
-    if len(content) <= max_chars or max_chars == -1:
-        return content
 
-    # truncate the middle and include a message to the LLM about it
-    half = max_chars // 2
-    return (
-        content[:half]
-        + '\n[... Observation truncated due to length ...]\n'
-        + content[-half:]
-    )

openhands/runtime/action_execution_server.py

@@ -60,6 +60,41 @@ class ActionRequest(BaseModel):
     action: dict
 
 
+# Maximum number of characters for truncating runtime messages
+MAX_CHARS_MESSAGES = 30_000
+
+
+def truncate_content(content: str, max_chars: int) -> str:
+    """Truncate the middle of the observation content if it is too long.
+    If truncation occurs, the full content will be saved to a file in /openhands/outputs/
+    """
+    if len(content) <= max_chars or max_chars == -1:
+        return content
+
+    # Save the full content to a file
+    import os
+    import datetime
+    
+    # Generate filename with timestamp
+    timestamp = datetime.datetime.now().strftime('%Y%m%d_%H%M%S')
+    output_file = os.path.join('/openhands/outputs', f'truncated_output_{timestamp}.txt')
+    
+    try:
+        with open(output_file, 'w', encoding='utf-8') as f:
+            f.write(content)
+    except Exception as e:
+        logger.error(f'Failed to save full content to file: {e}')
+
+    # truncate the middle and include a message to the LLM about it
+    half = max_chars // 2
+    truncated = (
+        content[:half]
+        + f'\n[... Observation truncated due to length. Full content saved to {output_file} ...]\n'
+        + content[-half:]
+    )
+    return truncated
+
+
 ROOT_GID = 0
 INIT_COMMANDS = [
     'git config --global user.name "openhands" && git config --global user.email "openhands@all-hands.dev" && alias git="git --no-pager"',
@@ -399,6 +434,9 @@ if __name__ == '__main__':
                 raise HTTPException(status_code=400, detail='Invalid action type')
             client.last_execution_time = time.time()
             observation = await client.run_action(action)
+            # Truncate observation content if it exists
+            if hasattr(observation, 'content'):
+                observation.content = truncate_content(observation.content, MAX_CHARS_MESSAGES)
             return event_to_dict(observation)
         except Exception as e:
             logger.error(