This commit is contained in:
Ahmed Ibrahim
2025-11-01 15:09:43 -07:00
parent d9118c04bf
commit 0493221e8b
3 changed files with 7 additions and 2 deletions

View File

@@ -26,6 +26,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;
@@ -251,6 +252,7 @@ impl ModelClient {
prompt_cache_key: Some(self.conversation_id.to_string()),
text,
};
error!("payload: {:?}", payload);
let mut payload_json = serde_json::to_value(&payload)?;
if azure_workaround {

View File

@@ -3,6 +3,7 @@ use crate::codex::TurnContext;
use codex_protocol::models::FunctionCallOutputPayload;
use codex_protocol::models::ResponseInputItem;
use codex_protocol::models::ResponseItem;
use tracing::error;
use tracing::warn;
/// Process streamed `ResponseItem`s from the model into the pair of:
@@ -86,6 +87,10 @@ pub(crate) async fn process_items(
encrypted_content: encrypted_content.clone(),
});
}
(ResponseItem::WebSearchCall { .. }, None) => {
items_to_record_in_conversation_history.push(item.clone());
error!("WebSearchCall: {item:?}");
}
_ => {
warn!("Unexpected response item: {item:?} with response: {response:?}");
}

View File

@@ -120,8 +120,6 @@ pub enum ResponseItem {
// "action": {"type":"search","query":"weather: San Francisco, CA"}
// }
WebSearchCall {
#[serde(default, skip_serializing)]
#[ts(skip)]
id: Option<String>,
#[serde(default, skip_serializing_if = "Option::is_none")]
#[ts(optional)]