Function _serialize_trajectory

src/observability/persistence.py:89–104

Reduce a trajectory to plain JSON-friendly Python. Handles the two shapes in this repo: SDK runners' ``Trajectory`` dataclass, and plan-execute's ``list[StepResult]`` (also dataclasses).

(trajectory: Any)

def _serialize_trajectory(trajectory: Any) -> Any:
    """Reduce a trajectory to plain JSON-friendly Python.

    Handles the two shapes in this repo: SDK runners' ``Trajectory``
    dataclass, and plan-execute's ``list[StepResult]`` (also dataclasses).
    """
    if trajectory is None:
        return None
    if dataclasses.is_dataclass(trajectory):
        return dataclasses.asdict(trajectory)
    if isinstance(trajectory, list):
        return [
            dataclasses.asdict(item) if dataclasses.is_dataclass(item) else item
            for item in trajectory
        ]
    return trajectory