codex: clarify rollout request id field name

Rename the response stream field to request_id_for_rollout_log so its purpose is explicit at the call sites.

Co-authored-by: Codex <noreply@openai.com>
This commit is contained in:
Charles Cunningham
2026-03-06 10:01:24 -08:00
co-authored by Codex
parent 5d846acf72
commit c8e7500321
6 changed files with 12 additions and 9 deletions
+1 -1
View File
@@ -249,7 +249,7 @@ pub fn create_text_param_for_request(
pub struct ResponseStream {
pub rx_event: mpsc::Receiver<Result<ResponseEvent, ApiError>>,
pub rollout_request_id: Option<String>,
pub request_id_for_rollout_log: Option<String>,
}
impl Stream for ResponseStream {
@@ -271,7 +271,7 @@ impl ResponsesWebsocketConnection {
// Websocket upgrade response headers are scoped to the connection, not
// individual `stream_request` calls, so they cannot be used as per-turn
// request IDs in rollout metadata.
rollout_request_id: None,
request_id_for_rollout_log: None,
})
}
}
+6 -3
View File
@@ -49,7 +49,7 @@ pub fn stream_from_fixture(
tokio::spawn(process_sse(Box::pin(stream), tx_event, idle_timeout, None));
Ok(ResponseStream {
rx_event,
rollout_request_id: None,
request_id_for_rollout_log: None,
})
}
@@ -104,7 +104,7 @@ pub fn spawn_response_stream(
ResponseStream {
rx_event,
rollout_request_id: request_id,
request_id_for_rollout_log: request_id,
}
}
@@ -895,7 +895,10 @@ mod tests {
};
let stream = spawn_response_stream(stream_response, idle_timeout(), None, None);
assert_eq!(stream.rollout_request_id.as_deref(), Some("req_123"));
assert_eq!(
stream.request_id_for_rollout_log.as_deref(),
Some("req_123")
);
}
#[tokio::test]