fix(codex): public session_id accessor + fix pyright lint in test [greptile]

- Add CodexTurn.session_id property so multi-turn callers resume sessions
  without reaching into the private _result dict; update the async-base and
  temporal tutorials to use it.
- Fix the CI pyright failure in test_codex_sync.py: pull tool_call_id inside the
  isinstance comprehension so the content-union narrowing holds (a later
  attribute access on req[0].content did not narrow, tripping reportAttribute).

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: declan-scale

examples/tutorials/10_async/00_base/harness_codex/project/acp.py

@@ -196,10 +196,10 @@ async def handle_task_event_send(params: SendEventParams):
         if usage.model:
             # usage() is valid now that the stream is exhausted
             pass
-        # CodexTurn exposes the session_id via its on_result callback; we access
-        # it via the underlying processor through the result dict stored on the turn.
-        if turn._result and turn._result.get("session_id"):
-            state.codex_thread_id = turn._result["session_id"]
+        # Persist the codex session id (public accessor; valid post-stream) so the
+        # next turn resumes the same session.
+        if turn.session_id:
+            state.codex_thread_id = turn.session_id
 
         await adk.state.update(
             state_id=task_state.id,

examples/tutorials/10_async/10_temporal/harness_codex/project/workflow.py

@@ -173,8 +173,8 @@ async def on_task_event_send(self, params: SendEventParams) -> None:
 
             await process.wait()
 
-            if turn._result and turn._result.get("session_id"):
-                self._codex_thread_id = turn._result["session_id"]
+            if turn.session_id:
+                self._codex_thread_id = turn.session_id
 
             if span:
                 span.output = {

src/agentex/lib/adk/_modules/_codex_turn.py

@@ -185,6 +185,16 @@ def events(self) -> AsyncIterator[StreamTaskMessage]:
     def _on_result(self, result: dict[str, Any]) -> None:
         self._result = result
 
+    @property
+    def session_id(self) -> str | None:
+        """The codex session id, for resuming a multi-turn session.
+
+        Valid only after ``events`` has been fully consumed (populated by the
+        ``on_result`` callback). Returns ``None`` if the stream is not yet
+        exhausted or codex reported no session id.
+        """
+        return self._result.get("session_id") if self._result else None
+
     def usage(self) -> TurnUsage:
         """Return normalized ``TurnUsage`` for this turn.
 

tests/lib/adk/test_codex_sync.py

@@ -236,10 +236,20 @@ async def test_empty_item_id_request_response_ids_match(self) -> None:
             },
         ]
         out = await _collect(convert_codex_to_agentex_events(_aiter(events)))
-        req = [e for e in out if isinstance(e, StreamTaskMessageStart) and isinstance(e.content, ToolRequestContent)]
-        resp = [e for e in out if isinstance(e, StreamTaskMessageFull) and isinstance(e.content, ToolResponseContent)]
-        assert len(req) == 1 and len(resp) == 1
-        assert req[0].content.tool_call_id == resp[0].content.tool_call_id
+        # Pull tool_call_id inside the comprehension so the isinstance narrows the
+        # content union (the narrowing would not survive a later attribute access).
+        req_ids = [
+            e.content.tool_call_id
+            for e in out
+            if isinstance(e, StreamTaskMessageStart) and isinstance(e.content, ToolRequestContent)
+        ]
+        resp_ids = [
+            e.content.tool_call_id
+            for e in out
+            if isinstance(e, StreamTaskMessageFull) and isinstance(e.content, ToolResponseContent)
+        ]
+        assert len(req_ids) == 1 and len(resp_ids) == 1
+        assert req_ids[0] == resp_ids[0]
 
     async def test_file_change_synthesizes_start(self) -> None:
         """file_change items may only emit item.completed (no started)."""