diff --git a/src/codexmcp/server.py b/src/codexmcp/server.py
index 55987ea..fb5c805 100644
--- a/src/codexmcp/server.py
+++ b/src/codexmcp/server.py
@@ -218,8 +218,6 @@ async def codex(
             if "fail" in line_dict.get("type", ""):
                 success = False if len(agent_messages) == 0 else success
                 err_message = "codex error: " + line_dict.get("error", {}).get("message", "")
-                if "reconnecting" not in err_message.lower():
-                    break
             if "error" in line_dict.get("type", ""):
                 success = False if len(agent_messages) == 0 else success
                 err_message = "codex error: " + line_dict.get("message", "")   
@@ -233,11 +231,11 @@ async def codex(
             success = False
             break
 
-    if success and thread_id is None:
+    if thread_id is None:
         success = False
         err_message = "Failed to get `SESSION_ID` from the codex session. \n\n" + err_message
         
-    if success and len(agent_messages) == 0:
+    if len(agent_messages) == 0:
         success = False
         err_message = "Failed to get `agent_messages` from the codex session. \n\n You can try to set `return_all_messages` to `True` to get the full reasoning information. \n\n " + err_message