timestamp

This commit is contained in:
Ahmed Ibrahim
2025-09-08 20:19:28 -07:00
parent 28c57aded3
commit dfaa3fb242
2 changed files with 5 additions and 5 deletions

View File

@@ -613,10 +613,10 @@ impl Session {
let guard = self.rollout.lock_unchecked();
guard.as_ref().cloned()
};
if let Some(rec) = recorder {
if let Err(e) = rec.record_events(&[event.clone()]).await {
error!("failed to record rollout event: {e:#}");
}
if let Some(rec) = recorder
&& let Err(e) = rec.record_events(std::slice::from_ref(&event)).await
{
error!("failed to record rollout event: {e:#}");
}
if let Err(e) = self.tx_event.send(event).await {
error!("failed to send tool call event: {e}");

View File

@@ -78,7 +78,7 @@ async fn test_get_conversations_filtered_by_id() {
let target = u2.to_string();
let filter: ConversationFilter = std::sync::Arc::new(move |item: &ConversationItem| {
item.head
.get(0)
.first()
.and_then(|v| v.get("id"))
.and_then(|v| v.as_str())
.map(|s| s == target)