Retrieve a tool by name.

Look up one stored connection by id. Args: connection_id: Identifier to resolve; case and surrounding whitespace

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.

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

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

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

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

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

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

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

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

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

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

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

Build a series from ``(date, amount, kind)`` triples.

Call ``POST /search``.

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

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

Execute the tool and decode its JSON return value.

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

Real engine-schema run_dir: 9 same-day round trips, one position.

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

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

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

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

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

Expose the Pydantic method expected by LangChain's converter.

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.

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

Resolve a profile id or the saved selected profile. Args: profile_id: Optional explicit profile id. Returns: Matching profil

Rolling max per column, warmup → NaN.

Infer market type from symbol format. Args: code: Ticker / symbol string. Returns: Market type (a_share/us_equity/hk_equity/

Write a fixture file and return its path.

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

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

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

Forward time-window chunking (Wallex has no pagination).

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

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

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

Bar-by-bar execution with market rule enforcement.

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

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

Close the file handle.

Insert or replace a job by id. Validates the schedule string and the timezone's shape before persisting. The timezone key is delibera

Best-effort release of HTTP clients owned by this adapter. LangChain may lend multiple adapters the same cached HTTPX clients. Those

Override or reset the connector client factory (used by unit tests).

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

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

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

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

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

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

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

Core orchestration loop (runs in background thread). Steps: 1. Update run status to running 2. Initialize TaskStore,

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