diff --git a/codex-rs/core/src/client.rs b/codex-rs/core/src/client.rs index 3c21552dcb..2bded5eec8 100644 --- a/codex-rs/core/src/client.rs +++ b/codex-rs/core/src/client.rs @@ -22,6 +22,7 @@ use tokio::sync::mpsc; use tokio::time::timeout; use tokio_util::io::ReaderStream; use tracing::debug; +use tracing::error; use tracing::trace; use tracing::warn; @@ -655,7 +656,7 @@ async fn process_sse( { Ok(Some(Ok(sse))) => sse, Ok(Some(Err(e))) => { - debug!("SSE Error: {e:#}"); + error!("SSE Error: {e:#}"); let event = CodexErr::Stream(e.to_string(), None); let _ = tx_event.send(Err(event)).await; return; @@ -716,7 +717,7 @@ async fn process_sse( let event: SseEvent = match serde_json::from_str(&sse.data) { Ok(event) => event, Err(e) => { - debug!("Failed to parse SSE event: {e}, data: {}", &sse.data); + error!("Failed to parse SSE event: {e}, data: {}", &sse.data); continue; } }; @@ -743,7 +744,7 @@ async fn process_sse( "response.output_item.done" => { let Some(item_val) = event.item else { continue }; let Ok(item) = serde_json::from_value::(item_val) else { - debug!("failed to parse ResponseItem from output_item.done"); + error!("failed to parse ResponseItem from output_item.done"); continue; }; @@ -802,9 +803,7 @@ async fn process_sse( } } Err(e) => { - let error = format!("failed to parse ErrorResponse: {e}"); - debug!(error); - response_error = Some(CodexErr::Stream(error, None)) + error!("failed to parse ErrorResponse: {e}"); } } } @@ -818,9 +817,7 @@ async fn process_sse( response_completed = Some(r); } Err(e) => { - let error = format!("failed to parse ResponseCompleted: {e}"); - debug!(error); - response_error = Some(CodexErr::Stream(error, None)); + error!("failed to parse ResponseCompleted: {e}"); continue; } };