|
6 | 6 | from langchain_core.messages import ToolMessage |
7 | 7 | from pydantic import BaseModel, Field |
8 | 8 |
|
| 9 | +from codegen.shared.logging.get_logger import get_logger |
| 10 | + |
| 11 | +logger = get_logger(__name__) |
| 12 | + |
9 | 13 |
|
10 | 14 | class Observation(BaseModel): |
11 | 15 | """Base class for all tool observations. |
@@ -44,14 +48,18 @@ def __repr__(self) -> str: |
44 | 48 | """Get detailed string representation of the observation.""" |
45 | 49 | return f"{self.__class__.__name__}({self.model_dump_json()})" |
46 | 50 |
|
47 | | - def render_as_string(self) -> str: |
| 51 | + def render_as_string(self, max_tokens: int = 8000) -> str: |
48 | 52 | """Render the observation as a string. |
49 | 53 |
|
50 | 54 | This is used for string representation and as the content field |
51 | 55 | in the ToolMessage. Subclasses can override this to customize |
52 | 56 | their string output format. |
53 | 57 | """ |
54 | | - return json.dumps(self.model_dump(), indent=2) |
| 58 | + rendered = json.dumps(self.model_dump(), indent=2) |
| 59 | + if 3 * len(rendered) > max_tokens: |
| 60 | + logger.error(f"Observation is too long to render: {len(rendered) * 3} tokens") |
| 61 | + return rendered[:max_tokens] + "\n\n...truncated...\n\n" |
| 62 | + return rendered |
55 | 63 |
|
56 | 64 | def render(self, tool_call_id: Optional[str] = None) -> ToolMessage | str: |
57 | 65 | """Render the observation as a ToolMessage or string. |
|
0 commit comments