Record a thinking-stage entry.
(self, node_id: str, thinking_mode: str, thinking_result: str, stage: str,
duration: float = None, details: Dict[str, Any] = None)
| 271 | ) |
| 272 | |
| 273 | def record_thinking_process(self, node_id: str, thinking_mode: str, thinking_result: str, stage: str, |
| 274 | duration: float = None, details: Dict[str, Any] = None) -> None: |
| 275 | """Record a thinking-stage entry.""" |
| 276 | thinking_details = { |
| 277 | "thinking_result": thinking_result, |
| 278 | "thinking_mode": thinking_mode, |
| 279 | "stage": stage, |
| 280 | **(details or {}) |
| 281 | } |
| 282 | |
| 283 | self.info( |
| 284 | f"Thinking process for node {node_id} ({thinking_mode} at {stage})", |
| 285 | node_id=node_id, |
| 286 | event_type=EventType.THINKING_PROCESS, |
| 287 | details=thinking_details, |
| 288 | duration=duration |
| 289 | ) |
| 290 | |
| 291 | def record_memory_operation(self, node_id: str, retrieved_memory: str, operation_type: str, stage: str, |
| 292 | duration: float = None, details: Dict[str, Any] = None) -> None: |
no test coverage detected