File-based persistent memory that survives across sessions. Design: - Frozen snapshot injected into system prompt at session start (prese

LLM response. Attributes: content: Text content (final answer or thinking text). tool_calls: List of tool call requests.

File-based persistence store for SwarmRun. Each run is stored under base_dir/{run_id}/. run.json uses atomic writes (write to .tmp then renam

An open position in a single instrument. Args: symbol: Instrument identifier. direction: 1 for long, -1 for short. entry_

In-memory registry of all discoverable alphas across zoo subdirectories.

SQLite-backed store for finance research goals.

Root configuration model composing all environment variable groups. Instantiating with no arguments reads every recognised env var from ``os.

File-backed registry for research hypotheses.

Durable, crash-safe persistence for scheduled research jobs. The store is a thin envelope around a dict of :class:`~src.scheduled_research.mo

Load skills from bundled skills/ directory and user skills directory. Attributes: skills: Loaded skill list (bundled + user-created).

Records the order in which the runner reaches each tick stage.

One immutable live-action audit record (SPEC.md Consent §5). Attributes: kind: The live-action kind (``order_placed`` | ``order_rejected`

Tool call request returned by the LLM. Attributes: id: Tool call ID (used to match tool_result messages). name: Tool name.

Input for appending traceable evidence to a goal.

Role definition for a single agent in a Swarm. Parsed from YAML presets, describes the agent's identity, available tools, and constraints. A

Fetch order-bucket net capital inflow (main/large/medium/small) for stocks.

Look up sector / concept board membership for a stock, or rank boards.

Complete state of a single Swarm preset execution. Persisted as .swarm/runs/{id}/run.json; the top-level aggregate root. Attributes:

A task node in the Swarm DAG. Each task is bound to an agent. Dependencies are declared via depends_on, and blocked_by tracks remaining incom

ReAct Agent core loop. Attributes: registry: Tool registry. llm: ChatLLM client. memory: Workspace memory. max_it

A-share market engine. Config keys: - commission_rate: default 0.00025 (万2.5) - commission_min: default 5.0 (RMB) - stamp_tax:

Fetch a stock's three financial statements or key per-period indicators.

One human-readable if-then rule distilled from profitable roundtrips. Attributes: rule_id: Stable ID like "R1", "R2". human_text:

Validates backtest config.json before execution.

File-based persistence layer for tasks. Each task is stored at run_dir/tasks/task-{id}.json. Attributes: run_dir: Root directory of

Return value after worker execution completes. Attributes: status: WorkerStatus — completed|failed|timeout|token_limit|incomplete.

Minimal stand-in for ChatLLM's response object.

Rank a full market's listed instruments by change%, volume or turnover.

Background thread that emits keepalive ticks while a tool runs. Use as a context manager around a single tool invocation: with Heartbeat

Crash-safe, on-disk persistence for the scheduler's job set. The store is a thin durable envelope around a list of :class:`Job`. It owns only

Swarm event log entry. Appended to events.jsonl; supports SSE streaming and post-run audit. Attributes: type: Event type, e.g. "run_

A user-selectable trading connector profile. Args: id: Stable profile id used by CLI/tools. connector: Broker/connector key, e.g.

Mean-variance weights penalized for turnover against prior weights. Attributes: risk_aversion: Weight on the variance term (lambda).

Immutable bounded-autonomy mandate for one live broker channel. Loaded read-only at session boot from the user-side protected store. The agen

Spinu (2013)-style inverse-vol seed + Newton-style refinement.

Read-only per-stock and global financial news headlines.

Completion audit row for one criterion.

Finnhub US-equity daily OHLCV loader (key-gated, throttled HTTP).

Eastmoney OHLCV loader (free, throttled HTTP, no auth).

Financial Modeling Prep US-equity OHLCV loader (key-gated, HTTP).

Fetch US-equity daily OHLCV bars from Tiingo (key-gated REST).

Surface Chinese A-share restricted-share unlock (限售解禁) schedules.

Synchronous wrapper around the async FastMCP client.

Fetch A-share sell-side research reports plus market consensus EPS.

Layer (b): user-set universe the agent picks symbols WITHIN. Not a ticker whitelist — that would kill agent discovery. The agent selects indi

Minimal connector module stand-in capturing place_order calls.

Mimic the slice of ``Registry`` interface ``run_bench_strict`` uses.

Provenance proving the user (not the agent) authored this mandate. Attributes: created_at: ISO-8601 UTC timestamp the user committed the

Mootdx-backed A-share OHLCV loader (TCP-direct, no auth).

Tushare-backed OHLCV loader.

Fetch a single FRED macroeconomic time series from the St. Louis Fed.

US / HK equity engine, selected by *market* parameter. Config keys: - slippage_us: default 0.0005 - slippage_hk: default 0.001

State bag handed to slash-command handlers and the run loop. Attributes: session_id: Active session id (populated lazily on first turn).

Swarm DAG orchestration engine. Manages the full lifecycle of a swarm run: creation, scheduling, execution, and cancellation. Each run execut

Small DataProvider contract for Tushare financial statement tables.

Search the web via ddgs across several free engines and return top results.

In-memory broker stub recording the order of injected calls.

Small response stub for the loader's embedded HTTP client.

Scripted ChatLLM that returns queued responses in order.

Top-level structured agent config.

Result of a single preflight check.

Sina Finance US-equity daily OHLCV loader (free, HTTP/JSONP, no auth).

Yahoo Finance US/HK equity OHLCV loader (free, direct HTTP, no auth).

Query the Eastmoney A-share dragon-tiger (龙虎榜) disclosure board.

Machine-readable metadata for one RSSHub feed route. Attributes: name: Stable feed identifier used in configs (e.g. ``"sina_announcements

Layer (a): user-set quantitative ceilings. Funding is enforced BROKER-SIDE (Robinhood dedicated agentic account balance) and is the absolute

Resolved metadata for one remote MCP tool. Attributes: annotations: Server-asserted MCP tool annotations (``readOnlyHint`` /

Configurable mock advisory provider. Args: verdict: Verdict to return on every :meth:`review` call. concerns: Concern strings att

Broker-agnostic normalized order, units explicit. Attributes: symbol: Normalized upper-case symbol (e.g. ``AAPL``, ``BTC-USDT``).

Raised when provider streaming fails before a complete response.

Point-in-time-safe event/sentiment provider backed by RSSHub. Attributes: base_url: Root of the RSSHub instance (no trailing slash).

Raised on registry-level configuration errors.

Immutable record describing a scheduled research / backtest job. Attributes: id: Unique job identifier (caller-supplied UUID or slug).

List recent SEC filings and optionally one XBRL us-gaap metric series.

User's extracted trading shadow. Attributes: shadow_id: "shadow_<8-hex>" unique ID. created_at: ISO8601 UTC timestamp. jo

Fetch A-share quarterly shareholder counts with QoQ change and avg holding.

Minimal MCPServerAdapter stand-in with recording call_tool.

Delta PnL attribution between user's realized trades and shadow. All PnL fields are in the journal's account currency.

Session-scoped event bus with subscribers and buffered events. V5: Inject the asyncio event loop with ``set_loop()``, and use ``call_soon_thr

Run an iWenCai (问财) natural-language A-share research query.

A scheduled live-runtime job. ``next_run_at`` is mutable by design: the scheduler advances it in place after each fire (a frozen DTO would fo

Read run_card.json metrics and link the run to a hypothesis. After a backtest completes, its metrics live in ``run_card.json``. The existing

Fetch daily A-share margin-financing / short-selling balances.

Async message bus that decouples chat channels from the agent core. Channels push messages to the inbound queue, and the agent processes them

QVeris local configuration.

Write a contract-correct ``signal_engine.py`` stub for a hypothesis. The backtest runner requires a ``SignalEngine`` class that is constructi

Filesystem-backed persistent storage. Directory structure:: sessions/ ├── {session_id}/ │ ├── session.json │

A completed round-trip trade. Args: symbol: Instrument identifier. direction: 1 for long, -1 for short. entry_price: Entr

LLM stub returning scripted content_filter_triggered responses.

Compare >= 2 named alphas head-to-head and rank them by an IC metric.

Strict metadata schema; matches the ``__alpha_meta__`` dict literal.

Manages chat channels and coordinates message routing. Responsibilities: - Initialize enabled channels (Telegram, Discord, Slack, etc.) -

AKShare universal OHLCV loader (free, no auth).

OKX crypto OHLCV loader.

Fetch HK and China A-share bars from Futu OpenAPI. Requires FutuOpenD running locally (https://www.futunn.com/download/openAPI) and the envir

NSE / BSE cash-equity (delivery) engine. Config keys (all optional; defaults shown in the module docstring): - allow_short: bool, default F

A session message such as user input or system output. Attributes: message_id: Unique identifier. session_id: Owning session ID.