Retrieve a tool by name.

Safe division: ``a / (b + eps * sign(b))``. Where ``b == 0`` exactly (or NaN), result is NaN — never silently inf or 0.

Cross-sectional percentile rank per row (axis=1, ties=average, pct=True). NaN inputs stay NaN. An all-NaN row returns an all-NaN row.

Rolling mean per column, warmup → NaN.

Rolling Pearson correlation per column, min_periods=n. Constant series in the window → NaN (no silent zero). Pairs are inner-joined on column

Return ``(crumb, cookies)``, fetching them on first use or on refresh. Args: force_refresh: Discard any cached crumb/cookies and

Return a job by id, or ``None`` when it does not exist. Args: job_id: Job identifier. Returns: The matching

Update an existing hypothesis. Args: hypothesis_id: Registry identifier. title: Optional replacement title.

Save a new memory entry and update the index. Args: name: Memory name (used as filename slug). Empty or whitespace-

Return the cached :class:`EnvConfig` singleton, creating it on first access. Thread-safe: acquires a lock before checking / creating the instance

First difference at lag ``d``: ``df - df.shift(d)``. Lookahead ban: ``d >= 1`` strictly. Negative lag forbidden.

Run entry script and collect logs and artifacts. Args: entry_script: Entry script path. run_dir: Current run director

Rolling rank (last value's rank within the n-window), per column. Warmup (first ``n-1`` rows per column) returns NaN. Result is a percentile

Build the tool registry via auto-discovery, optionally enriched with MCP tools. Local tools are discovered and registered first. When ``agent_con

Linear decay-weighted moving average, weights ``n, n-1, ..., 1`` normalized. Warmup (first ``n-1`` rows) → NaN. Uses numpy ``sliding_window_

Rolling min per column, warmup → NaN.

Rolling sample std (ddof=1) per column, warmup → NaN.

Rolling max per column, warmup → NaN.

Supersede the current goal and create a new active goal. Args: session_id: Owning session id. objective: Research obj

Call ``POST /search``.

Clear the buffered events for a session. Args: session_id: Session ID.

Cancel the current loop. Sets a thread-safe flag polled at every iteration boundary, per LLM stream chunk, and between tool batches,

Fetch crypto OHLCV via OKX public API. Args: codes: Symbols like ``["BTC-USDT", "ETH-USDT"]``. start_date: Start date

Load structured agent config from disk with safe fallback. Args: config_path: Optional explicit config path. When omitted, the default

Insert or replace a job by id. Validates the schedule string before persisting. Args: job: The job to store. Ra

Create the directory structure for a new run and write initial state. Args: run: SwarmRun instance. Returns:

Extract a ShadowProfile from a broker journal file. Args: journal_path: CSV/Excel exported from a supported broker. min_support:

Load the state for a given run. Args: run_id: Run identifier. Returns: SwarmRun instance, or None if not fou

Validate that start_date <= end_date. Args: start_date: Start date string (YYYY-MM-DD). end_date: End date string (YYYY-MM-DD).

Handle an incoming message: check permissions, issue pairing codes in DMs, or forward to bus.

Resolve a memory by exact title, then by on-disk filename stem. Stem fallback accepts both the full ``{type}_{slug}`` form and the ba

Reload base.py with bottleneck enabled or disabled.

Close the file handle.

Convert a LangChain AIMessage (or AIMessageChunk) to ``LLMResponse``. Single source for reasoning: ``additional_kwargs["reasoning_content"]``

Return the shared console instance. Returns: The single :class:`Console` everyone in ``agent/cli`` writes to.

Load the committed mandate for ``broker`` from the protected store. Reads ``<runtime_root>/live/<broker>/mandate.json`` (written 0600 by the

Read trace.jsonl records. Args: dir_path: Directory containing ``trace.jsonl``. resolve_offloads: Whether to read sid

Fetch one DataFrame through the opt-in local cache. Convenience wrapper over :func:`loader_cache_get` / :func:`loader_cache_put` for the comm

Return a JSON-safe goal snapshot.

Parse *source*, run the visitor, return (violations, warnings).

Return the directory path for a given run. Args: run_id: Run identifier. Returns: Path to the run directory.

Market-aware VWAP-equivalent reference price. - ``equity_cn``: ``(amount * 1000) / (volume * 100 + 1)`` — Tushare's ``daily.amount`` is in

Return a TestClient that simulates a loopback caller.

Build local tool wrappers for a configured MCP server. Args: server_name: Logical server name from config. server_config: Validat

Return the runtime root directory for user-level agent state. Args: config_path: Optional explicit config file path. When provided, the

Check sender permission: star > allowlist > pairing store > deny.

Return criteria for a goal.

Per-bar market-rule hook (funding fees, liquidation, etc.). Default: no-op. Override in subclass as needed.

Rolling argmax (0-based index into the window), warmup → NaN. Uses ``bottleneck.move_argmax`` when available (~350x faster). Correction: ``bn

Build a runner wired entirely to the tracker stubs, with overrides.

Return the per-broker state directory under the live root. Args: broker: Broker key, e.g. ``"robinhood"``. Normalized to lower-case and

Run the ReAct loop synchronously. Args: user_message: User message. history: Prior conversation messages.

Raise ``ValueError`` when *schedule* is malformed. Args: schedule: Either a positive integer string (interval-ms) or a simpli

Populate a tmp memory dir with one entry per type.

Append traceable evidence after stale-goal validation. Args: session_id: Owning session id. goal_id: Goal being mutat

Create and persist a new hypothesis. Args: title: Short hypothesis title. thesis: Research thesis or rationale.

Return a media directory for *channel_name* under the VT uploads root. Inbound media must land inside ``~/.vibe-trading/uploads`` — one of the

Rolling argmin (0-based index into the window), warmup → NaN. Uses ``bottleneck.move_argmin`` when available (~350x faster). Correction: ``bn

Write a trace record. Args: entry: Trace entry; a ``ts`` field is added automatically.

Fan a redacted live-action record out to up to three sinks (SPEC §5). The record is redacted via :func:`src.tools.redaction.redact_payload` FIRST

Build a minimal bar Series for testing.

Classify one remote tool via the 3-tier precedence ladder. The curated map is authoritative: when it names the tool, its class is returned re

Write a mandate — the ONLY code path that activates live-trading authority. Re-validates that ``proposal_id`` is live and that the resolved profi

Build and publish an event in one step. Args: session_id: Session ID. event_type: Event type. data: Event

Return the current goal plus ledger rows for a session.

Build aligned date index, close matrix, target-position matrix, return matrix. Signal is shifted by 1 bar (next-bar-open semantics) then normalis

Build a Namespace pre-populated with sane defaults that ``_registry`` and handlers expect to read.

Dispatch ``alpha <sub>`` to the matching handler. Returns the exit code; ``cli.py`` propagates it via ``_coerce_exit_code``.

Return whether live trading is halted — a pure filesystem check. This is the authoritative kill-switch check the enforcement gate calls before