(self, session_id: str, items: list[Any])
| 99 | return [] |
| 100 | |
| 101 | async def _write_items(self, session_id: str, items: list[Any]) -> None: |
| 102 | file_path = self._items_path(session_id) |
| 103 | payload = json.dumps(items, indent=2, ensure_ascii=False) |
| 104 | await asyncio.to_thread(self._dir.mkdir, parents=True, exist_ok=True) |
| 105 | await asyncio.to_thread(file_path.write_text, payload, encoding="utf-8") |
| 106 | |
| 107 | async def load_state_json(self) -> dict[str, Any] | None: |
| 108 | """Load a previously saved RunState JSON payload, if present.""" |
no test coverage detected