Method _refresh_guest_request

app/core/upstream.py:494–517

匿名会话失效或并发受限后切换会话并重签请求。

(
        self,
        request: OpenAIRequest,
        attempt: int,
        excluded_tokens: Set[str],
        excluded_guest_user_ids: Set[str],
        failed_transformed: Dict[str, Any],
        is_concurrency_limited: bool = False,
    )

        await guest_pool.report_failure(guest_user_id)

    async def _refresh_guest_request(
        self,
        request: OpenAIRequest,
        attempt: int,
        excluded_tokens: Set[str],
        excluded_guest_user_ids: Set[str],
        failed_transformed: Dict[str, Any],
        is_concurrency_limited: bool = False,
    ) -> Dict[str, Any]:
        """匿名会话失效或并发受限后切换会话并重签请求。"""
        retry_number = attempt + 2
        self.logger.warning(
            "🔄 匿名会话不可用，正在切换匿名会话并进行第 "
            f"{retry_number} 次请求"
        )
        await self._report_guest_session_failure(
            failed_transformed,
            is_concurrency_limited=is_concurrency_limited,
        )
        return await self.transform_request(
            request,
            excluded_tokens=excluded_tokens,
            excluded_guest_user_ids=excluded_guest_user_ids,
        )

    async def _refresh_authenticated_request(
        self,