style: apply ruff format to all source files

Auto-formatted 19 files to satisfy 'ruff format --check' CI step.
No logic changes — whitespace, line length, and import spacing only.

Co-Authored-By: AdaL <adal@sylph.ai>

Author: chindris-mihai-alexandru

src/agents/base_agent.py

@@ -27,7 +27,6 @@
 from typing import Any
 
 import json
-import os
 import re
 from pathlib import Path
 from typing import TypeVar
@@ -107,7 +106,7 @@ def _extract_json(raw: str) -> str:
         raw = raw.strip()
         if raw.startswith("```"):
             # handles ```json, ```JSON, ``` (no lang tag)
-            raw = raw[3:]                      # strip opening ```
+            raw = raw[3:]  # strip opening ```
             if raw.startswith("json") or raw.startswith("JSON"):
                 raw = raw[4:]
             # strip closing ```
@@ -136,7 +135,10 @@ def call(self, input: adal.GeneratorOutput, extra_fields: dict | None = None) ->
             if self.model_class.__name__ == "InvestmentThesis":
                 data["reasoning_blocks"] = []
                 # Clamp time_horizon_days to minimum 1 (schema requires gt=0)
-                if data.get("time_horizon_days") is not None and int(data.get("time_horizon_days", 1)) < 1:
+                if (
+                    data.get("time_horizon_days") is not None
+                    and int(data.get("time_horizon_days", 1)) < 1
+                ):
                     data["time_horizon_days"] = 1
             # Strip unknown fields to prevent extra="forbid" crashes from LLM hallucinations.
             # The schema is strict by design (no junk in IPFS), but we sanitize at parse time.
@@ -315,12 +317,18 @@ def _repair_and_parse_once(
         extra_fields: dict[str, Any] | None = None,
     ) -> BaseModel | None:
         """Run exactly one JSON-repair pass, then parse again. Fail closed on error."""
-        raw = getattr(output, "raw_response", None) or getattr(output, "data", None) or str(output or "")
+        raw = (
+            getattr(output, "raw_response", None)
+            or getattr(output, "data", None)
+            or str(output or "")
+        )
         try:
             repaired_output = self.json_repair(
                 prompt_kwargs={
                     "schema_name": parser.model_class.__name__,
-                    "schema_json": json.dumps(parser.model_class.model_json_schema(), ensure_ascii=False),
+                    "schema_json": json.dumps(
+                        parser.model_class.model_json_schema(), ensure_ascii=False
+                    ),
                     "raw_output": _sanitize_untrusted_text(raw, max_len=16000),
                 }
             )
@@ -384,7 +392,10 @@ async def analyze(self, ticker: str, prior_feedback: str = "") -> InvestmentThes
                     _wait = 2 ** (_sub_attempt + 2)
                     logger.warning(
                         "Sub-agent 503 for %s/%s — retrying in %ds (attempt %d/3)",
-                        role.value, safe_ticker, _wait, _sub_attempt + 1,
+                        role.value,
+                        safe_ticker,
+                        _wait,
+                        _sub_attempt + 1,
                     )
                     await asyncio.sleep(_wait)
                     continue
@@ -398,7 +409,7 @@ async def analyze(self, ticker: str, prior_feedback: str = "") -> InvestmentThes
                     extra_fields={"agent_role": role.value},
                 )
             if not isinstance(block, ReasoningBlock):
-                raw_snippet = (getattr(block_output, 'raw_response', None) or '')[:300]
+                raw_snippet = (getattr(block_output, "raw_response", None) or "")[:300]
                 raise RuntimeError(
                     f"{role} sub-agent failed to produce a ReasoningBlock after one repair pass. "
                     f"raw: {raw_snippet}"
@@ -430,12 +441,15 @@ async def analyze(self, ticker: str, prior_feedback: str = "") -> InvestmentThes
             "learned_guidelines": _sanitize_untrusted_text(_guidelines_str, max_len=4000),
         }
         import asyncio as _asyncio
+
         thesis_output = None
         for _attempt in range(3):
             thesis_output = self.synthesizer(prompt_kwargs=synthesis_kwargs)
             if getattr(thesis_output, "error", None) and "503" in str(thesis_output.error):
                 wait = 2 ** (_attempt + 2)  # 4s, 8s, 16s
-                logger.warning("Synthesizer 503 — retrying in %ds (attempt %d/3)", wait, _attempt + 1)
+                logger.warning(
+                    "Synthesizer 503 — retrying in %ds (attempt %d/3)", wait, _attempt + 1
+                )
                 await _asyncio.sleep(wait)
                 continue
             break
@@ -450,7 +464,7 @@ async def analyze(self, ticker: str, prior_feedback: str = "") -> InvestmentThes
                 extra_fields={"region": self.region.value, "ticker_or_asset": safe_ticker},
             )
         if not isinstance(thesis, InvestmentThesis):
-            raw_snippet = (getattr(thesis_output, 'raw_response', None) or '')[:300]
+            raw_snippet = (getattr(thesis_output, "raw_response", None) or "")[:300]
             raise RuntimeError(f"Synthesizer failed after one repair pass. raw: {raw_snippet}")
 
         # 3. Splice the sub-agent blocks back in (synthesizer may have summarized them).
@@ -463,6 +477,7 @@ async def analyze(self, ticker: str, prior_feedback: str = "") -> InvestmentThes
         entry_price_1e8: int | None = None
         try:
             from data.yfinance_client import YFinanceClient as _YFC
+
             # Normalize ticker for yfinance:
             # - Tushare .SH → Yahoo .SS  (Shanghai A-shares)
             # - Bare crypto symbols (BTC, ETH) → BTC-USD, ETH-USD
@@ -472,7 +487,12 @@ async def analyze(self, ticker: str, prior_feedback: str = "") -> InvestmentThes
             price = await _YFC().get_current_price(_yf_ticker)
             if price and price > 0:
                 entry_price_1e8 = int(price * 1e8)
-                logger.debug("Live price for %s: %.4f → entry_price_1e8=%d", _yf_ticker, price, entry_price_1e8)
+                logger.debug(
+                    "Live price for %s: %.4f → entry_price_1e8=%d",
+                    _yf_ticker,
+                    price,
+                    entry_price_1e8,
+                )
         except Exception as _price_exc:
             logger.debug("Price fetch skipped for %s: %s", safe_ticker, _price_exc)
 

src/agents/china_agent.py

@@ -124,50 +124,70 @@ def __init__(
             if deepseek_key and not _use_groq:
                 # Probe DeepSeek to detect 402 (Insufficient Balance) before full analysis.
                 import httpx as _httpx
+
                 try:
                     _r = _httpx.post(
                         "https://api.deepseek.com/v1/chat/completions",
-                        json={"model": _DEEPSEEK_MODEL, "messages": [{"role": "user", "content": "hi"}], "max_tokens": 1},
+                        json={
+                            "model": _DEEPSEEK_MODEL,
+                            "messages": [{"role": "user", "content": "hi"}],
+                            "max_tokens": 1,
+                        },
                         headers={"Authorization": f"Bearer {deepseek_key}"},
                         timeout=10,
                     )
                     if _r.status_code == 402:
-                        logger.warning("DeepSeek 402 Insufficient Balance — falling back to Groq for CN desk")
+                        logger.warning(
+                            "DeepSeek 402 Insufficient Balance — falling back to Groq for CN desk"
+                        )
                         _use_groq = True
                 except Exception as _probe_exc:
-                    logger.warning("DeepSeek probe failed (%s) — falling back to Groq for CN desk", _probe_exc)
+                    logger.warning(
+                        "DeepSeek probe failed (%s) — falling back to Groq for CN desk", _probe_exc
+                    )
                     _use_groq = True
             if _use_groq:
                 # Try OpenRouter (DeepSeek V4 Flash, free tier) before falling back to Groq.
                 openrouter_key = os.environ.get("OPENROUTER_API_KEY", "")
                 if openrouter_key:
                     logger.info("CN desk: using OpenRouter DeepSeek V4 Flash (free tier)")
                     from data.deepseek_client import DeepSeekClient as _DSC
+
                     model_client = _DSC(
                         api_key=openrouter_key,
                         base_url="https://openrouter.ai/api/v1",
                     )
                     if model_kwargs is None:
-                        model_kwargs = {"model": "deepseek/deepseek-v4-flash", "temperature": 0.2, "max_tokens": 2048}
+                        model_kwargs = {
+                            "model": "deepseek/deepseek-v4-flash",
+                            "temperature": 0.2,
+                            "max_tokens": 2048,
+                        }
                 else:
                     logger.warning("Using Groq fallback for CN desk")
                     model_client = adal.GroqAPIClient()  # type: ignore[attr-defined]
                     if model_kwargs is None:
-                        model_kwargs = {"model": "llama-3.3-70b-versatile", "temperature": 0.2, "max_tokens": 2048}
+                        model_kwargs = {
+                            "model": "llama-3.3-70b-versatile",
+                            "temperature": 0.2,
+                            "max_tokens": 2048,
+                        }
             else:
                 model_client = DeepSeekClient(api_key=deepseek_key)
                 if model_kwargs is None:
-                    model_kwargs = {"model": _DEEPSEEK_MODEL, "temperature": 0.2, "max_tokens": 2048}
+                    model_kwargs = {
+                        "model": _DEEPSEEK_MODEL,
+                        "temperature": 0.2,
+                        "max_tokens": 2048,
+                    }
         if model_kwargs is None:
             model_kwargs = {"model": _DEEPSEEK_MODEL, "temperature": 0.2, "max_tokens": 2048}
 
         # Call parent — it initialises self._block_parser / self._thesis_parser.
         super().__init__(model_client=model_client, model_kwargs=model_kwargs)
 
         # Rebuild generators with Chinese-language templates.
-        schema_str = json.dumps(
-            InvestmentThesis.model_json_schema(), ensure_ascii=False, indent=2
-        )
+        schema_str = json.dumps(InvestmentThesis.model_json_schema(), ensure_ascii=False, indent=2)
         cn_synthesis = _CN_SYNTHESIS_TEMPLATE.replace("{{schema}}", schema_str)
 
         self.sub_agent = adal.Generator(
@@ -237,6 +257,7 @@ async def get_data_sources(self, ticker: str) -> dict[AgentRole, str]:
         yf_ticker = _tushare_to_yf(ticker)  # 600519.SH → 600519.SS
         try:
             import yfinance as yf
+
             loop = asyncio.get_event_loop()
             yf_info = await loop.run_in_executor(
                 None,
@@ -253,11 +274,23 @@ async def get_data_sources(self, ticker: str) -> dict[AgentRole, str]:
             logger.debug("yfinance snapshot skipped for %s: %s", yf_ticker, _yf_exc)
             price_snapshot = {}
 
-        daily_summary = json.dumps(daily, ensure_ascii=False, default=str)[:3000] if daily else "[无日线数据]"
-        fina_summary = json.dumps(fina, ensure_ascii=False, default=str)[:2000] if fina else "[无财务数据]"
-        info_summary = json.dumps(info, ensure_ascii=False, default=str)[:1500] if info else "[无公司信息]"
-        news_summary = json.dumps(news, ensure_ascii=False, default=str)[:1500] if news else "[无新闻数据]"
-        price_summary = json.dumps(price_snapshot, ensure_ascii=False)[:500] if price_snapshot else "[无价格快照]"
+        daily_summary = (
+            json.dumps(daily, ensure_ascii=False, default=str)[:3000] if daily else "[无日线数据]"
+        )
+        fina_summary = (
+            json.dumps(fina, ensure_ascii=False, default=str)[:2000] if fina else "[无财务数据]"
+        )
+        info_summary = (
+            json.dumps(info, ensure_ascii=False, default=str)[:1500] if info else "[无公司信息]"
+        )
+        news_summary = (
+            json.dumps(news, ensure_ascii=False, default=str)[:1500] if news else "[无新闻数据]"
+        )
+        price_summary = (
+            json.dumps(price_snapshot, ensure_ascii=False)[:500]
+            if price_snapshot
+            else "[无价格快照]"
+        )
 
         fundamental_data = (
             f"【股票代码】{ticker} (yfinance: {yf_ticker}) | 数据来源: {source_used}\n"

src/agents/crypto_agent.py

@@ -32,8 +32,8 @@ class CryptoAgent(RegionalAgent):
     working_language = "en"
     sub_agent_roles = (
         AgentRole.FUNDAMENTAL_ANALYST,  # on-chain metrics, tokenomics
-        AgentRole.SENTIMENT_ANALYST,    # market sentiment, news
-        AgentRole.MACRO_ANALYST,        # DeFi ecosystem, TVL trends
+        AgentRole.SENTIMENT_ANALYST,  # market sentiment, news
+        AgentRole.MACRO_ANALYST,  # DeFi ecosystem, TVL trends
     )
 
     @property
@@ -54,10 +54,15 @@ def __init__(
             if groq_key:
                 model_client = adal.GroqAPIClient()  # type: ignore[attr-defined]
                 if model_kwargs is None:
-                    model_kwargs = {"model": "llama-3.3-70b-versatile", "temperature": 0.2, "max_tokens": 2048}
+                    model_kwargs = {
+                        "model": "llama-3.3-70b-versatile",
+                        "temperature": 0.2,
+                        "max_tokens": 2048,
+                    }
             elif gemini_key:
                 logger.warning("GROQ_API_KEY not set — falling back to Gemini for Crypto desk")
                 from data.gemini_client import GeminiClient
+
                 _gemini_model = os.environ.get("GEMINI_MODEL", "gemini-3.1-flash-lite")
                 model_client = GeminiClient(api_key=gemini_key)
                 if model_kwargs is None:
@@ -107,9 +112,7 @@ async def get_data_sources(self, ticker: str) -> dict[AgentRole, str]:
             coin_task = cg.get_coin(cg_id)
             # DefiLlama protocol slug often matches CoinGecko id — soft-fail if not
             protocol_task = dl.get_protocol(dl_slug)
-            coin, protocol = await asyncio.gather(
-                coin_task, protocol_task, return_exceptions=True
-            )
+            coin, protocol = await asyncio.gather(coin_task, protocol_task, return_exceptions=True)
 
         # ---- Binance fallback when CoinGecko is rate-limited or down ----
         binance_ticker: dict | None = None
@@ -129,16 +132,19 @@ async def get_data_sources(self, ticker: str) -> dict[AgentRole, str]:
         # ---- fundamental: tokenomics + market data from CoinGecko (or Binance) ----
         if isinstance(coin, Exception):
             if binance_ticker:
-                fundamental_data = json.dumps({
-                    "source": "Binance (CoinGecko unavailable)",
-                    "symbol": binance_ticker.get("symbol"),
-                    "lastPrice": binance_ticker.get("lastPrice"),
-                    "priceChangePercent": binance_ticker.get("priceChangePercent"),
-                    "quoteVolume": binance_ticker.get("quoteVolume"),
-                    "highPrice": binance_ticker.get("highPrice"),
-                    "lowPrice": binance_ticker.get("lowPrice"),
-                    "recent_daily_ohlcv": binance_klines,
-                }, indent=2)[:4000]
+                fundamental_data = json.dumps(
+                    {
+                        "source": "Binance (CoinGecko unavailable)",
+                        "symbol": binance_ticker.get("symbol"),
+                        "lastPrice": binance_ticker.get("lastPrice"),
+                        "priceChangePercent": binance_ticker.get("priceChangePercent"),
+                        "quoteVolume": binance_ticker.get("quoteVolume"),
+                        "highPrice": binance_ticker.get("highPrice"),
+                        "lowPrice": binance_ticker.get("lowPrice"),
+                        "recent_daily_ohlcv": binance_klines,
+                    },
+                    indent=2,
+                )[:4000]
             else:
                 fundamental_data = f"[CoinGecko ERROR: {coin}] [Binance fallback unavailable]"
         else:
@@ -181,12 +187,15 @@ async def get_data_sources(self, ticker: str) -> dict[AgentRole, str]:
         # ---- sentiment: derive from CoinGecko community + market sentiment ----
         if isinstance(coin, Exception):
             if binance_ticker:
-                sentiment_data = json.dumps({
-                    "source": "Binance (CoinGecko unavailable)",
-                    "priceChangePercent_24h": binance_ticker.get("priceChangePercent"),
-                    "count": binance_ticker.get("count"),  # number of trades
-                    "weightedAvgPrice": binance_ticker.get("weightedAvgPrice"),
-                }, indent=2)
+                sentiment_data = json.dumps(
+                    {
+                        "source": "Binance (CoinGecko unavailable)",
+                        "priceChangePercent_24h": binance_ticker.get("priceChangePercent"),
+                        "count": binance_ticker.get("count"),  # number of trades
+                        "weightedAvgPrice": binance_ticker.get("weightedAvgPrice"),
+                    },
+                    indent=2,
+                )
             else:
                 sentiment_data = "[No sentiment data — CoinGecko and Binance both unavailable]"
         else:
@@ -197,7 +206,12 @@ async def get_data_sources(self, ticker: str) -> dict[AgentRole, str]:
                     "community_data": coin.get("community_data", {}),
                     "developer_data": {
                         k: coin.get("developer_data", {}).get(k)
-                        for k in ["stars", "forks", "pull_request_contributors", "commit_count_4_weeks"]
+                        for k in [
+                            "stars",
+                            "forks",
+                            "pull_request_contributors",
+                            "commit_count_4_weeks",
+                        ]
                     },
                 },
                 indent=2,

src/agents/eu_agent.py

@@ -119,23 +119,26 @@ def __init__(
             gemini_key = os.environ.get("GEMINI_API_KEY", "")
             if gemini_key:
                 from data.gemini_client import GeminiClient
+
                 model_client = GeminiClient(api_key=gemini_key)
                 if model_kwargs is None:
                     model_kwargs = {"model": _GEMINI_MODEL, "temperature": 0.2, "max_tokens": 2048}
             else:
                 logger.warning("GEMINI_API_KEY not set — falling back to Groq for EU desk")
                 model_client = adal.GroqAPIClient()  # type: ignore[attr-defined]
                 if model_kwargs is None:
-                    model_kwargs = {"model": "llama-3.3-70b-versatile", "temperature": 0.2, "max_tokens": 2048}
+                    model_kwargs = {
+                        "model": "llama-3.3-70b-versatile",
+                        "temperature": 0.2,
+                        "max_tokens": 2048,
+                    }
 
         if model_kwargs is None:
             model_kwargs = {"model": _GEMINI_MODEL, "temperature": 0.2, "max_tokens": 2048}
 
         super().__init__(model_client=model_client, model_kwargs=model_kwargs)
 
-        schema_str = json.dumps(
-            InvestmentThesis.model_json_schema(), ensure_ascii=False, indent=2
-        )
+        schema_str = json.dumps(InvestmentThesis.model_json_schema(), ensure_ascii=False, indent=2)
         eu_synthesis = _EU_SYNTHESIS_TEMPLATE.replace("{{schema}}", schema_str)
 
         self.sub_agent = adal.Generator(