diff --git a/codex-rs/app-server/src/request_processors/thread_processor.rs b/codex-rs/app-server/src/request_processors/thread_processor.rs
index 730f194c08..dd2dd6a57e 100644
--- 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(),