Function build_assistant_message

tutorials/11_error_recovery_and_retry.py:365–407

从流事件构建 AI 回复。如果流中断（没收到 message_stop），标记为未完成。 对应源码: conversation.rs:353-390 fn build_assistant_message(events) { ... if !finished { return Err("assistant stream ended without a message stop event"); } if blocks.is_empty

(events: list[dict])

def build_assistant_message(events: list[dict]) -> AssistantMessage:
    """
    从流事件构建 AI 回复。如果流中断（没收到 message_stop），标记为未完成。

    对应源码: conversation.rs:353-390
        fn build_assistant_message(events) {
            ...
            if !finished {
                return Err("assistant stream ended without a message stop event");
            }
            if blocks.is_empty() {
                return Err("assistant stream produced no content");
            }
        }
    """
    text = ""
    text_blocks = []
    tool_calls = []
    finished = False

    for event in events:
        if event["type"] == "text_delta":
            text += event["text"]
        elif event["type"] == "tool_use":
            if text:
                text_blocks.append(text)
                text = ""
            tool_calls.append({
                "id": event["id"],
                "name": event["name"],
                "input": event["input"],
            })
        elif event["type"] == "message_stop":
            finished = True

    if text:
        text_blocks.append(text)

    return AssistantMessage(
        text_blocks=text_blocks,
        tool_calls=tool_calls,
        finished=finished,
    )


def run_turn_with_recovery(api_fn, tool_executor, max_iterations=10):