subconscious: strain reaches the wire, not just the log
turn.rs sends InferenceStrain to the stream; the subconscious path only ever logged it, so a provider refusing her was invisible to every surface. Same event, same shape, emitted where the primary emits it.
This commit is contained in:
parent
3b11903365
commit
5a5b647bde
1 changed files with 17 additions and 1 deletions
|
|
@ -924,7 +924,10 @@ Resolve entries: `[YYYY-MM-DD HH:MM] RESOLVED — note`"#;
|
|||
|
||||
for event in &strain {
|
||||
if let crate::bridge::bifrost::InferenceStrain::Transient {
|
||||
status, model, ..
|
||||
attempt,
|
||||
status,
|
||||
model,
|
||||
..
|
||||
} = event
|
||||
{
|
||||
tracing::info!(
|
||||
|
|
@ -932,6 +935,19 @@ Resolve entries: `[YYYY-MM-DD HH:MM] RESOLVED — note`"#;
|
|||
status,
|
||||
model
|
||||
);
|
||||
// The primary turn reports strain to the wire
|
||||
// (`turn.rs:378`); this path only ever logged it, so a
|
||||
// provider refusing the subconscious was invisible to
|
||||
// every surface. Same event, same shape.
|
||||
if let Some(tx) = stream_tx {
|
||||
let _ = tx
|
||||
.send(Ok(BackendEvent::InferenceStrain {
|
||||
attempt: *attempt,
|
||||
status: *status,
|
||||
model: model.clone(),
|
||||
}))
|
||||
.await;
|
||||
}
|
||||
if *status == 429 {
|
||||
let current = self.rate_delay.load(Ordering::Relaxed);
|
||||
let bumped = (current + 200).min(3000);
|
||||
|
|
|
|||
Loading…
Reference in a new issue