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.

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

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

Save a new memory entry and update the index.

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.

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

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

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

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

Translate one Vibe-Trading event into ``openbb_ai`` SSE objects. Args: event_type: The session-bus event type. data:

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

Return a cached entry if fresh, else ``None``.

Clear the cached :class:`EnvConfig` singleton. Acquires the same lock used by :func:`get_env_config` so the reset is atomic with respect to c

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

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 a series from ``(date, amount, kind)`` triples.

Validate identity assertions and numeric price claims. Args: content: Candidate assistant answer. Returns: A

Execute the tool and decode its JSON return value.

Patch the tool's HTTP entry point with a routing stub.

Select flows by kind. Args: kind: A single kind label or an iterable of labels. Labels are normalized, so ``"Capi

Call ``POST /search``.

Close the file handle.

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

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

Rolling min per column, warmup → NaN.

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

Keep raw-response ``parse()`` streams behind the same proxy.

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

Rolling max per column, warmup → NaN.

Write a fixture file and return its path.

Price a European option with the Black-Scholes-Merton formula. Args: S: Underlying spot price. K: Strike price. T: Time t

Resolve a memory by exact title, then by on-disk filename stem.

Expose the Pydantic method expected by LangChain's converter.

Write a trace record, flushed and fsynced for crash safety. ``flush`` alone only moves bytes into the OS page cache; a host crash or

Load a single playbook by slug. Args: slug: Playbook slug (its filename stem). directory: Search only this directory instead of t

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

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

Full set of performance metrics. Args: equity_curve: Equity time series (index=timestamp, values=equity). trades: Completed round

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

Clear the buffered events and notify subscribers for a session. Subscriber queues receive a ``session_cleared`` sentinel event so the

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

Number of bars per year for annualisation. Args: interval: Bar size (1m / 5m / 15m / 30m / 1H / 4H / 1D), case-insensitive li

Store a sanitized copy (no ``config`` key, no secrets).

Block until ``bucket`` is allowed to fire again, then record the slot. The *reserved fire time* — jitter included — is what gets stored, so t

Serialize the session to a dictionary. Returns: A JSON-serializable dictionary.

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

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

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

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

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

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

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

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

Build a TestClient with runtime root redirected under tmp_path.

Render an information-table XML document from row dicts. Issuer names are XML-escaped because real filings carry ampersands (``National Fire

Build a minimal stand-in for a ``requests.Response``. Args: text: Body used by the XML path. payload: Object returned by ``.json(

Load an irregular dated cash-flow file into a ``CashFlowSeries``. The file needs a date column and an amount column. Currency and kind may co

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

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

An unsettled binary market as gamma serializes it.

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

Consume the full untruncated tool result and persist its evidence. Args: tool_name: Executed tool name. arguments: Ex

Monkeypatch ``_fetch_raw_book`` to return ``book`` and record call args.