diff --git a/agent/aux_accounting.py b/agent/aux_accounting.py index 6f851a642e..a6994d901c 100644 --- a/agent/aux_accounting.py +++ b/agent/aux_accounting.py @@ -63,11 +63,6 @@ def reset_accounting_context(token) -> None: _accounting.set(None) -def get_accounting_context() -> Optional[tuple]: - """Return ``(session_db, session_id)`` for the active turn, or ``None``.""" - return _accounting.get() - - def record_aux_usage( response: Any, task: Optional[str], diff --git a/agent/auxiliary_client.py b/agent/auxiliary_client.py index 173208fede..04f4325d02 100644 --- a/agent/auxiliary_client.py +++ b/agent/auxiliary_client.py @@ -30,7 +30,6 @@ fall through to the next provider in the chain. import contextlib import contextvars -import copy import functools import hashlib import inspect @@ -5517,21 +5516,6 @@ def _try_main_fallback_chain( return None, None, "" -def _resolve_single_provider( - provider: str, - model: Optional[str] = None, - base_url: Optional[str] = None, - api_key: Optional[str] = None, -) -> Optional[Any]: - """Resolve a single fallback_chain provider entry to an OpenAI client via resolve_provider_client.""" - client, resolved_model = resolve_provider_client( - provider=provider, - model=model, - explicit_base_url=base_url, - explicit_api_key=api_key, - ) - return client - def _resolve_auto_route( main_runtime: Optional[Dict[str, Any]] = None, task: Optional[str] = None, @@ -6634,23 +6618,6 @@ def get_text_auxiliary_client( ) -def get_async_text_auxiliary_client(task: str = "", *, main_runtime: Optional[Dict[str, Any]] = None): - """Return (async_client, model_slug); Codex yields an AsyncCodexAuxiliaryClient wrapper. - - Returns (None, None) when no provider is available. - """ - provider, model, base_url, api_key, api_mode = _resolve_task_provider_model(task or None) - return resolve_provider_client( - provider, - model=model, - async_mode=True, - explicit_base_url=base_url, - explicit_api_key=api_key, - api_mode=api_mode, - main_runtime=main_runtime, - ) - - _VISION_AUTO_PROVIDER_ORDER = ( "openrouter", "nous", @@ -8319,19 +8286,6 @@ def _client_streams_internally(client: Any) -> bool: )) -def _is_streaming_rejected_error(exc: Exception) -> bool: - """Provider explicitly refused a streamed chat.completions request.""" - err = str(exc).lower() - if "stream_options" in err: - return True - return "stream" in err and ( - "not supported" in err - or "unsupported" in err - or "not allowed" in err - or "disabled" in err - ) - - _MANAGED_LOCAL_STATE_TTL_S = 15.0 _managed_local_cache: "tuple[float, str]" = (0.0, "")