Load execution checkpoint for resume.
(self, plan_id: str)
| 798 | logger.warning("Failed to save checkpoint for plan %s: %s", plan_id, e) |
| 799 | |
| 800 | def load_checkpoint(self, plan_id: str) -> dict[str, Any] | None: |
| 801 | """Load execution checkpoint for resume.""" |
| 802 | checkpoint_path = self.context.plans_dir / f"{plan_id}_state.json" |
| 803 | if not checkpoint_path.exists(): |
| 804 | return None |
| 805 | |
| 806 | try: |
| 807 | data: dict[str, Any] = json.loads( |
| 808 | checkpoint_path.read_text(encoding="utf-8") |
| 809 | ) |
| 810 | return data |
| 811 | except Exception as e: |
| 812 | logger.warning("Failed to load checkpoint for plan %s: %s", plan_id, e) |
| 813 | return None |
| 814 | |
| 815 | |
| 816 | # ── Topological Batching ─────────────────────────────────────────────────── |
no outgoing calls