Function _record_stream_failure

uncommon_route/proxy.py:5345–5370

()

                    stream_record_state["done"] = True

                async def _record_stream_failure() -> None:
                    await _spend_reservation.release(request_id)
                    if is_virtual:
                        _model_experience.observe(
                            selected_model,
                            mode_value,
                            tier_value,
                            success=False,
                        )
                        _circuit_breaker.record_failure(selected_model)
                        _record_route_trace(
                            status_code=502,
                            streaming=True,
                            error_code="stream_failure",
                            error_stage="stream",
                            error_message="Streaming response interrupted",
                        )
                    else:
                        _record_route_trace(
                            status_code=502,
                            streaming=True,
                            error_code="stream_failure",
                            error_stage="stream",
                            error_message="Streaming response interrupted",
                        )
                    stream_record_state["done"] = True

                async def _record_stream_aborted(
                    stream_chunks: list[bytes] | None = None,