Return the shared CLI console.

One RPT_LIFT_STOCK-shaped record.

Convert Tiingo's per-day records into the normalized OHLCV frame. Args: rows: JSON array decoded from the prices endpoint; each item carr

Run a tool-less worker against the given scripted LLM. Args: monkeypatch: pytest monkeypatch fixture (zeroes the retry sleep). tm

Persist conversation references (caller must hold _refs_guard).

Create a persisted hypothesis in an isolated registry.

Resolve the selected or explicit trading profile.

Return a process-wide :class:`SessionStore` rooted at ``agent/sessions``. Cached on the module so repeat ``_append_message`` / ``_new_session``

Map a numeric score to low/medium/high given (med_cutoff, high_cutoff).

Return True when *rel_path* falls in a skipped or allowed zone.

Build minimal data_map and signal_map for alignment tests.

Return a consistent Rich color for status labels.

Stop typing indicator updates for a chat.

Stop the typing indicator for a chat.

Build a callable that reads as ``ChatLLM(model_name=...)`` would. The worker does ``llm = ChatLLM(model_name=...)`` once per run; we swap tha

Return the active console width with a conservative fallback.

Safely cast to float; return default on failure.

Return a standard unsupported-capability payload.

上影线长度。 Args: o: 开盘价序列。 c: 收盘价序列。 h: 最高价序列。 Returns: 每根K线的上影线长度。

Build a committed, unexpired active-mandate snapshot for stubbing.

Write a minimal AgentConfig JSON file pinning a single MCP server. The server name is used in assertions to verify *which* file the resolver

Write a structurally valid mandate.json under the patched root.

Return all roots allowed for document and broker-file reads.

Return all roots allowed for file writes and edits.

First-digit Benford's-law check on a list of financial values. Args: values: Numeric values to inspect. Returns: Dict with `

Return the path to a per-broker kill-switch sentinel. Args: broker: Broker key, e.g. ``"robinhood"``. Returns: ``<runtime_ro

Per-exit-reason trade statistics. Args: trades: Completed round-trip trades. Returns: {reason: {count, total_pnl}}.

Per-symbol trade statistics. Args: trades: Completed round-trip trades. Returns: {symbol: {count, win_rate, total_pnl, avg_p

Return cross-sectional z-scored earnings yield.

Mean IC series across ``n_seeds`` row-shuffled random controls. Returns one IC value per date, averaged across **all** ``n_seeds`` seeds on d

Return the user-level IBKR local config path.

Return the default research goal acceptance checklist.

Attach a point-in-time-safe ``event_score`` column to price frames. For each bar ``t`` the score aggregates only events whose ``knowable_date``

Call ``POST /tools/execute`` and hydrate truncated results. Args: tool_id: QVeris tool identifier returned by search.

Find the trace directory for a run/session id. Args: run_id: Run or session ID. runs_dir: Base runs directory. Defaul

Render a duration as a short, human-readable string. Args: value: Numeric duration. Treated as milliseconds by default — this

Get a channel by name.

Return a runtime subdirectory for *name* under the VT data dir.

Get status of all channels.

Return the path to the global kill-switch sentinel. Returns: ``<runtime_root>/live/HALT``. The file is NOT created here; use :fun

Return whether a cached OAuth token already exists for a live channel. FastMCP's OAuth provider persists tokens through the same :func:`~src.

Return whether a QVeris API key is saved or provided.

Index a single message. Args: session_id: Session ID. role: Message role (user/assistant/tool). content:

Upsert a session record. Args: session_id: Session ID. title: Session title. ts: Session start time as a

Inspect all built-in channels and annotate configured/enabled state. Args: config: Optional channels config map or model. Extra keys are

Return the recurrence interval in ms, or ``None`` for one-shot jobs. Returns: The interval for an ``"interval:<ms>"`` schedule, `

Return whether *job* should fire at ``now_ms``. Cancelled and failed jobs are terminal and never re-dispatched; a failed job in particular ke

Return whether an account number is a Tiger paper account (17 digits).

Return all persisted memory entries, filename-sorted.

Return built-in trading connector profiles.

Resolve the canonical broker key for a config entry. Args: server_key: The MCP server key from config. server: The server config

Resolve a live broker key from an MCP server URL host. Args: url: The MCP server ``url`` from config. Returns: The canonical

Load the operator IM channel config from the structured agent config. Args: config_path: Optional explicit config path. Returns:

Load a JSON file if it exists. Args: path: JSON file path. Returns: The decoded object when the file exists and is valid JSO

Load normalized request context for a run detail page. Falls back to planner_output.json when req.json context is empty (common in session mo

Normalize a symbol to ccxt unified ``BASE/QUOTE`` format. Accepts ``BTC/USDT`` (passed through, uppercased), ``BTC-USDT`` (hyphen rewritten t

Pick a random verb suffixed with an ellipsis. Args: seed: Optional deterministic seed (used by tests). When ``None`` the modu

Read a positive float env var, warning and falling back on invalid values.

Read the event log with optional offset for SSE incremental streaming. Args: run_id: Run identifier. after_index: Ski

Register a tool.

Return a Rich :class:`Text` row with ``left`` and right-aligned ``right``. The bar always fits the terminal width: * If ``left + right``

Render the full Shadow Account report. Returns: Dict with keys: ``html_path`` : rendered HTML (always present) `

Options backtest entry point. Day-by-day simulation: 1. Read underlying price for the current day 2. Mark all open option positions to ma

Run all preflight checks and print results. Args: console: Rich console for output. Creates one if not provided. Returns: Li

Run configured validation checks. Reads from config["validation"]: - monte_carlo: {n_simulations, seed} - bootstrap: {n_bootstrap, co

Map a runner operation to a connector-specific remote MCP tool name.

Return the runtime state directory (``live_root()/runtime``). Returns: The directory path. Not created here; :meth:`JobStore.save` create

Resolve a bare run id to an existing allowed run directory. Args: run_id: Bare run directory name, not a path. Returns: Exis

Draw a random sample, clamped to [3, 30], ordered by line number. Args: points: Data points returned by :func:`extract_data_points`.

Persist a ShadowProfile to disk as JSON.

Persist a synthesized proposal so a later commit can re-validate it. Called by the read-only ``propose_mandate_profiles`` tool. Writing a pro