mirror of
https://github.com/TauricResearch/TradingAgents.git
synced 2026-08-01 19:34:24 +03:00
daf1da9c35
- checkpoint resume keyed only by ticker+date silently continued the old graph under a different analyst selection / depth / asset mode; fold a run signature into the thread id #1089 - add llm_max_retries + TRADINGAGENTS_LLM_MAX_RETRIES, forwarded to every provider when set (int-coerced, rejects negatives/booleans), so a 429 burst can't abort a run #1091
101 lines
3.3 KiB
Python
101 lines
3.3 KiB
Python
"""Configurable LLM SDK retry budget (#1090/#1091).
|
|
|
|
A single transient 429 burst used to kill an otherwise-healthy multi-agent run
|
|
because each provider SDK's max_retries (default 2) was not exposed. This adds an
|
|
opt-in llm_max_retries knob forwarded to every provider chat client.
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
import importlib
|
|
|
|
import pytest
|
|
|
|
import tradingagents.default_config as default_config_module
|
|
from tradingagents.graph.trading_graph import TradingAgentsGraph, _coerce_max_retries
|
|
|
|
# --- coercion / validation -------------------------------------------------
|
|
|
|
@pytest.mark.unit
|
|
@pytest.mark.parametrize("value,expected", [(0, 0), (2, 2), (10, 10), ("6", 6)])
|
|
def test_coerce_accepts_non_negative_ints_and_numeric_strings(value, expected):
|
|
assert _coerce_max_retries(value) == expected
|
|
|
|
|
|
@pytest.mark.unit
|
|
@pytest.mark.parametrize("bad", [-1, "-3"])
|
|
def test_coerce_rejects_negative(bad):
|
|
with pytest.raises(ValueError, match=">= 0"):
|
|
_coerce_max_retries(bad)
|
|
|
|
|
|
@pytest.mark.unit
|
|
@pytest.mark.parametrize("bad", [True, False])
|
|
def test_coerce_rejects_booleans(bad):
|
|
with pytest.raises(ValueError, match="boolean"):
|
|
_coerce_max_retries(bad)
|
|
|
|
|
|
@pytest.mark.unit
|
|
@pytest.mark.parametrize("bad", ["abc", "1.5", None])
|
|
def test_coerce_rejects_non_integers(bad):
|
|
with pytest.raises(ValueError, match="integer"):
|
|
_coerce_max_retries(bad)
|
|
|
|
|
|
# --- forwarding into provider kwargs --------------------------------------
|
|
|
|
def _bare_graph(config):
|
|
g = object.__new__(TradingAgentsGraph)
|
|
g.config = config
|
|
return g
|
|
|
|
|
|
@pytest.mark.unit
|
|
def test_not_forwarded_when_unset():
|
|
kwargs = _bare_graph({"llm_provider": "openai", "llm_max_retries": None})._get_provider_kwargs()
|
|
assert "max_retries" not in kwargs
|
|
|
|
|
|
@pytest.mark.unit
|
|
@pytest.mark.parametrize("provider", ["openai", "anthropic", "google"])
|
|
def test_forwarded_across_providers(provider):
|
|
kwargs = _bare_graph({"llm_provider": provider, "llm_max_retries": 6})._get_provider_kwargs()
|
|
assert kwargs["max_retries"] == 6
|
|
|
|
|
|
@pytest.mark.unit
|
|
def test_forwarded_env_string_is_coerced():
|
|
# env vars arrive as strings; the consumer coerces (like temperature)
|
|
kwargs = _bare_graph({"llm_provider": "openai", "llm_max_retries": "4"})._get_provider_kwargs()
|
|
assert kwargs["max_retries"] == 4
|
|
|
|
|
|
@pytest.mark.unit
|
|
def test_invalid_config_value_fails_loudly():
|
|
with pytest.raises(ValueError):
|
|
_bare_graph({"llm_provider": "openai", "llm_max_retries": -1})._get_provider_kwargs()
|
|
|
|
|
|
# --- env overlay -----------------------------------------------------------
|
|
|
|
def _reload_with_env(monkeypatch, **overrides):
|
|
for key in list(default_config_module._ENV_OVERRIDES):
|
|
monkeypatch.delenv(key, raising=False)
|
|
for key, val in overrides.items():
|
|
monkeypatch.setenv(key, val)
|
|
return importlib.reload(default_config_module)
|
|
|
|
|
|
@pytest.mark.unit
|
|
def test_default_is_none(monkeypatch):
|
|
dc = _reload_with_env(monkeypatch)
|
|
assert dc.DEFAULT_CONFIG["llm_max_retries"] is None
|
|
|
|
|
|
@pytest.mark.unit
|
|
def test_env_override_sets_config(monkeypatch):
|
|
dc = _reload_with_env(monkeypatch, TRADINGAGENTS_LLM_MAX_RETRIES="8")
|
|
# None-default key: env value arrives as a string and is coerced downstream.
|
|
assert dc.DEFAULT_CONFIG["llm_max_retries"] == "8"
|
|
assert _coerce_max_retries(dc.DEFAULT_CONFIG["llm_max_retries"]) == 8
|