Defer running resume subscription to listener

2026-09-08 15:50:34 +00:00 · 2026-05-18 20:23:29 -07:00
parent c8a56c1ce0
commit e7d5ddc46e
1 changed files with 2 additions and 11 deletions
--- a/codex-rs/app-server/src/request_processors/thread_processor.rs
+++ b/codex-rs/app-server/src/request_processors/thread_processor.rs
@@ -2690,17 +2690,8 @@ impl ThreadRequestProcessor {

            let thread_state = self
                .thread_state_manager
-                .try_ensure_connection_subscribed(
-                    existing_thread_id,
-                    request_id.connection_id,
-                    /*experimental_raw_events*/ false,
-                )
-                .await
-                .ok_or_else(|| {
-                    internal_error(format!(
-                        "failed to subscribe connection for running thread {existing_thread_id}"
-                    ))
-                })?;
+                .thread_state(existing_thread_id)
+                .await;
            self.ensure_listener_task_running(
                existing_thread_id,
                existing_thread.clone(),