Function _input_items_for_result

src/agents/result.py:130–158

Return input items for the requested result view. ``preserve_all`` keeps the full converted history from ``new_items``. ``normalized`` returns the canonical continuation input when handoff filtering rewrote model history, otherwise it falls back to the same converted history.

(
    result: RunResultBase,
    *,
    mode: ToInputListMode,
    reasoning_item_id_policy: Literal["preserve", "omit"] | None,
)

def _input_items_for_result(
    result: RunResultBase,
    *,
    mode: ToInputListMode,
    reasoning_item_id_policy: Literal["preserve", "omit"] | None,
) -> list[TResponseInputItem]:
    """Return input items for the requested result view.

    ``preserve_all`` keeps the full converted history from ``new_items``. ``normalized`` returns
    the canonical continuation input when handoff filtering rewrote model history, otherwise it
    falls back to the same converted history.
    """
    session_items = run_items_to_input_items(result.new_items, reasoning_item_id_policy)
    if mode == "preserve_all":
        return session_items
    if mode != "normalized":
        raise ValueError(f"Unsupported to_input_list mode: {mode}")
    if not getattr(result, "_replay_from_model_input_items", False):
        # Most runs never rewrite continuation history, so normalized stays identical to the
        # historical preserve-all view unless the runner explicitly marked a divergence.
        return session_items

    model_input_items = getattr(result, "_model_input_items", None)
    if not isinstance(model_input_items, list):
        return session_items

    # When the runner marks a divergence, generated_items already reflect the continuation input
    # chosen for the next local run after applying handoff/input filtering.
    return run_items_to_input_items(model_input_items, reasoning_item_id_policy)


def _starting_agent_for_state(result: RunResultBase) -> Agent[Any]: