Class Journal

src/workflow/journal.py:53–80

class Journal:
    def __init__(self, prior: Optional[Mapping[CallKey, JournalRecord]] = None) -> None:
        self._prior = dict(prior or {})
        self._records: dict[CallKey, JournalRecord] = {}

    def lookup(self, key: CallKey, spec: AgentSpec):
        """Return the cached result for an unchanged call at ``key``, else MISS."""
        prior = self._prior.get(key)
        if prior is not None and prior.fingerprint == fingerprint(spec):
            return prior.result
        return _MISS

    def record(self, key: CallKey, spec: AgentSpec, result: Any) -> None:
        self._records[key] = JournalRecord(fingerprint(spec), result)

    @property
    def records(self) -> dict[CallKey, JournalRecord]:
        return dict(self._records)

    # ── persistence (string-keyed for JSON) ───────────────────────────────────

    def to_json(self) -> str:
        return records_to_json(self._records)

    @staticmethod
    def load(text: str) -> dict[CallKey, JournalRecord]:
        raw = json.loads(text)
        return {key_from_str(k): JournalRecord(v["fingerprint"], v["result"]) for k, v in raw.items()}


def records_to_json(records: Mapping[CallKey, JournalRecord]) -> str: