searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2025-05-25 09:03:59 +02:00
Code Issues Releases Wiki Activity

Stream errors

Browse Source
This commit is contained in:
Clément Renault 2025-05-20 12:23:22 +02:00
parent 42c95cf3c4
commit bae6c98aa3
No known key found for this signature in database
GPG Key ID: F250A4C4E3AE5F5F
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
crates/meilisearch/src/routes/chat.rs
View File

@ -400,13 +400,21 @@ async fn streamed_chat(
} }
} }
Err(err) => { Err(err) => {
// writeln!(lock, "error: {err}").unwrap();
tracing::error!("{err:?}"); tracing::error!("{err:?}");
if let Err(SendError(_)) = tx.send(Event::Data(sse::Data::new_json(&json!({
"object": "chat.completion.error",
"tool": err.to_string(),
})).unwrap())).await {
return;
}
break 'main; break 'main;
} }
} }
} }
} }
let _ = tx.send(Event::Data(sse::Data::new("[DONE]")));
}); });
Sse::from_infallible_receiver(rx).with_retry_duration(Duration::from_secs(10)) Sse::from_infallible_receiver(rx).with_retry_duration(Duration::from_secs(10))