fix: thread listing (#10383)
This commit is contained in:
parent
4971e96a98
commit
e9a774e7ae
2 changed files with 6 additions and 1 deletions
|
|
@ -983,6 +983,11 @@ async fn read_head_summary(path: &Path, head_limit: usize) -> io::Result<HeadTai
|
|||
.created_at
|
||||
.clone()
|
||||
.or_else(|| Some(rollout_line.timestamp.clone()));
|
||||
if let codex_protocol::models::ResponseItem::Message { role, .. } = &item
|
||||
&& role == "user"
|
||||
{
|
||||
summary.saw_user_event = true;
|
||||
}
|
||||
if summary.head.len() < head_limit
|
||||
&& let Ok(val) = serde_json::to_value(item)
|
||||
{
|
||||
|
|
|
|||
|
|
@ -277,7 +277,7 @@ pub async fn apply_rollout_items(
|
|||
pub fn record_discrepancy(stage: &str, reason: &str) {
|
||||
// We access the global metric because the call sites might not have access to the broader
|
||||
// OtelManager.
|
||||
tracing::warn!("state db record_discrepancy: {stage}{reason}");
|
||||
tracing::warn!("state db record_discrepancy: {stage}, {reason}");
|
||||
if let Some(metric) = codex_otel::metrics::global() {
|
||||
let _ = metric.counter(
|
||||
DB_METRIC_COMPARE_ERROR,
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue