feat(codex): republish todo_list revisions as they are ticked off

[declan-scale]

What

Codex does not reopen its plan. One todo_list item is opened at the start of a turn and revised in place through item.updated, with item.completed only arriving at the very end. The tap dropped those updates, so a consumer saw the plan exactly twice:

• as first written, nothing done
• at end of turn, everything done

Real trace from the golden agent (item_1), request vs response of the same call:

arguments: [{"text": "Probe safe local utility tools", "completed": false}, ... x4]
result:    [{"text": "Probe safe local utility tools", "completed": true},  ... x4]

Nothing in between, though the agent ticked them off over ~7 minutes.

This forwards each revision as a ToolResponseContent under the item's existing tool_call_id. Consumers that key responses by call id (the GenAI Ops Hub chat does) now render the checklist filling in as the turn runs, and the last response received is still the final state.

Scope

_PROGRESSIVE_TOOL_ITEMS is {"todo_list"} only. The other tool item types carry no intermediate state worth acting on, and republishing command_execution output on every chunk would be pure noise. Updates for an item that was never opened are ignored — there is no request for them to answer.

tool_call_count still counts the call once, not once per revision.

Testing

• pytest tests/lib/adk/test_codex_sync.py — 55 pass, 4 new (TestTodoListUpdates: republish per revision, call counted once, orphan update ignored, other tool items unaffected)
• pytest tests/lib/core/harness/test_harness_codex_sync.py — 9 pass
• ./scripts/lint — ruff + pyright clean

Paired change

The GenAI Ops Hub side of this is scaleapi/scaleapi#153721's follow-up, which maps every codex tool name onto a real chat block. It already takes the newest response per call id, so it picks these up with no further change.

🤖 Generated with Claude Code

Greptile Summary

This PR fixes a gap in the Codex event-stream tap where todo_list plan revisions were invisible to consumers: previously only the initial state and the final completed state were forwarded, with nothing in between even though Codex ticks items off over the course of a turn. Now each item.updated for a todo_list item is republished as a ToolResponseContent under the same tool_call_id, so consumers (e.g. the GenAI Ops Hub chat) can render the checklist filling in progressively.

• _codex_sync.py: Adds _PROGRESSIVE_TOOL_ITEMS = frozenset({"todo_list"}) and a new branch in _handle_item that, for item.updated events on progressive items, emits a StreamTaskMessageFull(ToolResponseContent) under the existing tool_call_id — guarded by item_id in self._tool_open so orphan updates are silently dropped. tool_call_count is still incremented only once on item.started.
• obs_ids.py: Updates the ddtrace import from the deprecated ddtrace.tracer to ddtrace.trace.tracer (ddtrace v3 API path); the existing except ImportError guard ensures graceful degradation on older installs.
• performing_deep_research.py (example): Pins mcp<2 via uvx --with for all MCP server invocations to avoid the McpError→MCPError rename introduced in mcp 2.0.0.

Confidence Score: 5/5

Safe to merge. The new progressive-update path is narrowly scoped to todo_list items, guarded by the _tool_open membership check, and covered by four targeted tests.

The change is purely additive — a new elif branch that only fires for todo_list item.updated events. The existing item.started / item.completed paths are untouched. The orphan-update guard and unchanged tool_call_count semantics both hold up under the new tests.

Files Needing Attention: No files require special attention.

Important Files Changed

Filename	Overview
src/agentex/lib/adk/_modules/_codex_sync.py	Adds progressive republishing of todo_list item.updated events as ToolResponseContent under the same tool_call_id; logic is sound, guarded by the _tool_open membership check, and tool_call_count is correctly incremented only once on item.started.
tests/lib/adk/test_codex_sync.py	Four new tests in TestTodoListUpdates covering: progressive republish, single call count, orphan update ignored, and other tool types unaffected.
src/agentex/lib/core/tracing/obs_ids.py	Updates ddtrace import to ddtrace.trace.tracer for ddtrace v3 compatibility; gracefully falls back via the existing ImportError catch.
examples/tutorials/10_async/10_temporal/020_state_machine/project/workflows/deep_research/performing_deep_research.py	Pins mcp<2 via uvx --with to avoid mcp 2.x breaking import. Well-commented with a drop condition.

Sequence Diagram

sequenceDiagram
    participant Codex as Codex CLI
    participant Tap as _CodexStreamProcessor
    participant Consumer as Consumer

    Codex->>Tap: "item.started {id: item_1, type: todo_list}"
    Tap->>Consumer: "StreamTaskMessageStart(ToolRequestContent, tool_call_id=item_1)"
    Tap->>Consumer: StreamTaskMessageDone

    Note over Codex,Consumer: Agent ticks items off over many minutes

    Codex->>Tap: "item.updated {id: item_1, items: [true, false]}"
    Tap->>Consumer: "StreamTaskMessageFull(ToolResponseContent, tool_call_id=item_1)"

    Codex->>Tap: "item.updated {id: item_1, items: [true, true]}"
    Tap->>Consumer: "StreamTaskMessageFull(ToolResponseContent, tool_call_id=item_1)"

    Codex->>Tap: "item.completed {id: item_1, items: [true, true]}"
    Tap->>Consumer: "StreamTaskMessageFull(ToolResponseContent, tool_call_id=item_1)"

Loading

_{Reviews (4): Last reviewed commit: "fix(tutorials): pin mcp<2 for uvx-spawne..." | Re-trigger Greptile}