Account usage and move the goal to budget_limited if needed.

Advance a fired job's ``next_run_at``; report whether it should remain. Recurring jobs are re-scheduled one interval past ``now_ms`` (not past th

Append a message to the session JSONL log. Args: message: Message to append.

Symbol-aware slippage with correct spread. Args: symbol: Forex pair. price: Mid price. direction: 1 (buy)

Symbol-aware commission calculation. Args: symbol: Futures code. size: Number of contracts. price: Execut

Signal cancellation for a running swarm. Args: run_id: ID of the run to cancel. Returns: True if cancellatio

Resolve a ticker symbol to its zero-padded 10-digit CIK. Args: ticker: A U.S. equity ticker (case-insensitive), e.g. ``"AAPL"``. Ret

Remove all registered advisory providers.

Clear a tripped kill switch by deleting its sentinel. Clearing is a privileged surface action (never an agent tool). Clearing the global swit

Check selected or explicit trading connector profile.

Start a live remote MCP connector runner.

Show connector status.

Interactive mode with welcome screen, slash commands, and agent conversation.

Clear a tripped kill switch (privileged, explicit re-enable). Args: broker: Broker key, or ``None`` for the global switch. Each scope is

Revoke the OAuth token and delete the mandate — full channel off. Deletes the broker's OAuth token cache directory and its ``mandate.json`` s

Start the persistent live runner in the background (SPEC §7.5). Relays a start request to the R6 surface endpoint (``POST /live/runner/start`

List chat sessions.

List available skills.

Run a swarm preset with Rich Live dashboard.

Bench a hand-picked set of alphas head-to-head and rank them. Args: alpha_ids: The alpha ids to compare (>= 2 after de-duplication). Ids

Compare one field across sources, flag deviations over a tolerance. The median of the supplied values is used as the reference, and each sour

Return schema metadata for a supported table.

Infer the best loader source for a normalized symbol.

Detect double-top and double-bottom patterns. Args: close: Closing price series. window: Peak/valley detection window. Retur

Evaluate an arithmetic expression with exact decimal arithmetic. Args: expr: Arithmetic expression string (numbers and ``+ - * /`` only).

Synthesize, persist, and return a ``mandate.proposal`` payload. Args: **kwargs: ``broker`` and ``ceilings`` required; optional ``

Append evidence to a goal. Args: **kwargs: Tool arguments from the model. Returns: JSON envelope with the ev

Execute an iWenCai semantic search and return a JSON envelope. Args: **kwargs: ``query`` (required, str) and optional ``limit`` (

Fetch dragon-tiger appearances (and seats when ``code`` is given). Args: **kwargs: ``date`` (required, YYYY-MM-DD) and optional `

Run the pre-trade gate, then ALLOW / DENY / PAUSE the order. Args: **kwargs: Order-tool arguments from the agent loop. R

Execute the tool and return a JSON string.

Extract recognizable financial data points from a markdown report. Covers multi-column tables and ``label: value unit`` lines. De-duplicates

Build :class:`FeedSpec` objects from backtest-config dicts. Each entry must carry ``name``, ``route_template`` and ``event_type``; an optiona

Convert a backtest code (e.g. ``"600519.SH"``) to a route's expected form. RSSHub routes disagree on instrument formatting: some take the exchang

Normalize supported date strings into ``YYYY-MM-DD``. Args: date_str: Raw date string from request or planner artifacts. Returns:

Format a tool execution result as a message.

Build a config from a JSON-like mapping, normalizing the profile.

Build a config from a JSON-like mapping.

Build a config from a JSON-like mapping, normalizing profile/URL.

Build a config from a JSON-like mapping, normalizing the profile.

Build a config from a JSON-like mapping, normalizing the profile.

Build a config from a JSON-like mapping, normalizing the profile.

Build a config from a JSON-like mapping, normalizing the profile. Args: data: Mapping with any subset of config fields.

Fetch the XBRL ``companyfacts`` JSON for a CIK. Args: cik: A CIK as int or string; padded to 10 digits internally. Returns:

Contract multiplier for the instrument. Args: symbol: Futures symbol (e.g. 'IF2406.CFFEX', 'ESZ4'). Returns:

Forex: multiplier is 1.0 (size is in currency units).

Look up exchange margin rate for a product. Args: symbol: Futures symbol. Returns: Margin rate (e.g. 0.10 fo

Execute a pairing subcommand and return the reply text. This is a pure function (no side effects other than store mutations) so it can be use

Detect head-and-shoulders top pattern. Args: close: Closing price series. window: Peak/valley detection window. Returns:

Return the directory holding per-runner heartbeat files. Returns: ``live_root()/runtime/heartbeats``. Not created here; written lazily by

Return a copy of ``run`` with live ``tasks/*.json`` merged in. ``run.json`` only gets the full snapshot at start and finalize; the pe

Check whether *sender_id* has been approved on *channel*.

Return a snapshot list of the current jobs. Returns: A new list of the live :class:`Job` objects (the list is a copy;

Link a run card or backtest artifact to a hypothesis. Args: hypothesis_id: Registry identifier. run_card_path: Option

Return claims for a goal.

List all runs sorted by created_at descending. Args: limit: Maximum number of runs to return. Returns: List

List all sessions in descending update-time order. Args: limit: Maximum number of sessions to return. Returns:

Load CSV rows as dictionaries. Args: path: CSV file path. Returns: Parsed CSV rows. Missing or unreadable files return an em

Load the selected trading profile id.

Load a supporting file on demand. Args: filename: File name (e.g. examples.md). Returns: File content or Non

Return whether ``end_date`` is settled enough to cache. The key is content-addressed on ``end_date`` but not on wall-clock fetch time, so cac

Write a minimal agent.json with one remote MCP server.

Translate a Vibe-Trading symbol into Yahoo's ticker convention. Args: symbol: Project-side symbol, e.g. ``AAPL.US``, ``00700.HK``, ``BTC-

Return the first due epoch-ms strictly after ``after_ms``. Supports the scheduled-research schedule format: a bare positive integer string fo

Render the cold-start banner once before the prompt appears.

Build a redacted provider diagnostic snapshot. Returns: Redacted provider/model/package/env/proxy/capability details.

Publish a message from a channel to the agent.

Return today's order count for ``broker`` (UTC rollover; 0 on any miss).

Purge heartbeat sentinels of runners that have gone stale. Mirrors the swarm reaper shape: scan every heartbeat, keep the live ones, delete t

Reset jobs left ``RUNNING`` by a previous executor process. This runs at most once per executor instance. Jobs that become ``RUNNING`

Register an advisory provider to be consulted on each review. Providers are consulted in registration order. Call :func:`clear_advisory_provi

Rebuild the entire index from file-based session store. Args: store_base_dir: Root directory of the SessionStore (contains sessio

Render assistant Markdown, upgrading pipe tables to Rich tables.

Return the configured verdict, or raise if configured to fail. Every invocation appends *context* to :attr:`call_history` before any

Run backtest: validate config.json + signal_engine.py, invoke built-in engine. Args: run_dir: Path to the run directory. Returns:

Atomically persist the full job set. Write sequence: temp file in same dir -> fsync -> os.replace -> fsync parent dir. A SIGKILL at a

Return prompt-injection findings for untrusted external text. Args: text: External text to scan. field: Optional JSON field path