fix: revert stream timeout that broke message processing
All checks were successful
BotServer CI/CD / build (push) Successful in 4m40s
All checks were successful
BotServer CI/CD / build (push) Successful in 4m40s
This commit is contained in:
parent
ed3406dd80
commit
dc97813614
1 changed files with 1 additions and 11 deletions
|
|
@ -859,17 +859,7 @@ impl BotOrchestrator {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
let stream_timeout = tokio::time::Duration::from_secs(60);
|
while let Some(chunk) = stream_rx.recv().await {
|
||||||
'stream_loop: loop {
|
|
||||||
let chunk_result = tokio::time::timeout(stream_timeout, stream_rx.recv()).await;
|
|
||||||
let chunk = match chunk_result {
|
|
||||||
Ok(Some(c)) => c,
|
|
||||||
Ok(None) => break 'stream_loop,
|
|
||||||
Err(_) => {
|
|
||||||
error!("LLM stream timeout after {}s - aborting response", stream_timeout.as_secs());
|
|
||||||
break 'stream_loop
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
// ===== GENERIC TOOL EXECUTION =====
|
// ===== GENERIC TOOL EXECUTION =====
|
||||||
// Add chunk to tool_call_buffer and try to parse
|
// Add chunk to tool_call_buffer and try to parse
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue