Build the three injected READ callables from fabricated snapshots.

Refuse a code set whose members do not settle in one currency. The shared capital pool holds a single scalar of cash and sums position values

Clear the process-wide crumb cache so each test handshakes fresh.

Build the OHLCV frame from chart rows, clipped to the inclusive window. For daily-and-coarser intervals the DatetimeIndex is normalized to midnig

Build a series alternating between a calm and a turbulent regime.

Wrap a completed :func:`~.dcf.run_dcf` call into a versioned artifact. ``capital_structure_basis``, ``discounting_convention``, ``terminal_va

Align one company's flow metric onto a comparable twelve-month footing. See the module docstring, section 2, for why this step exists and why

Test whether breaches cluster in time. Fits a first-order Markov chain to the breach sequence and tests the restriction that the two transiti

Hash an arbitrary payload the same way ``build_*_artifact`` hashes inputs. Public mainly so the normalization scheme (:func:`_flatten` / :fun

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

Bridge a known equity market value to enterprise value. EV = market_cap + total_debt - cash_and_equivalents + minority_interest

Sharpe the best of ``n_trials`` reaches by luck alone. From the expected maximum of ``N`` independent Gaussians:: E[max] ~ std * [ (1 -

Fetch market data and return strict JSON.

Fit the loss tail with a generalised Pareto distribution (POT method). Extreme value theory says the exceedances over a high enough threshold

Yield ``openbb_ai`` SSE objects for an OpenBB ``QueryRequest``. Args: request: The parsed ``openbb_ai.models.QueryRequest``.

Conditional VaR (expected shortfall) from the empirical distribution. The average loss *given* that the VaR threshold was breached. Unlike VaR it

Upsert a memory entry into the index. Args: entry_id: 6-char hex identifier. title: Memory title. descrip

Infer market key from a ticker symbol. Resolution order: 1. Crypto pair spellings (``BTC-USDT``, ``ETH/USD`` …). 2. Explicit exchange su

Return whether a tool-argument / payload key name should be redacted. A key is sensitive when its normalized (stripped, lower-cased) form either

Return a runner's last recorded heartbeat timestamp. Args: runner_id: The runner to read. Returns: The last-tick timestamp i

Apply market impact proportional to the participation rate. Impact is ``impact_coeff * volume_traded / adv``. Marginal impact is constant, wh

Return summary info for all available presets, sorted by name. User presets (``~/.vibe-trading/swarm/presets/``) are listed alongside the bun

Load all persisted jobs. Returns: A dict mapping job id to job. Empty when the store has never been written.

Load Binance settings from ``~/.vibe-trading/binance.json``.

Load Alpaca settings from ``~/.vibe-trading/alpaca.json``.

Load OKX settings from ``~/.vibe-trading/okx.json``.

Locate the worst peak-to-trough decline of an equity curve and its recovery. Args: equity: Net-value / equity series, strictly positive.

Acquire exclusive file lock; yields True if acquired, False on timeout.

Estimate default probability and credit spread from equity market data. Args: equity_value: Market capitalisation. equity_vol: An

Defang chat-template control tokens in untrusted external content. A zero-width space (U+200B) is inserted right after the opening delimiter

Total capital drawn into the fund, as a positive magnitude. Args: series: The cash flows. contribution_kinds: Kind labels counted

Confidence that a strategy's true Sharpe exceeds a benchmark. ``PSR = Z[ (SR - SR*) * sqrt(T - 1) / sqrt(1 - g3*SR + (g4 - 1)/4 * SR^2) ]``

Combinatorially-symmetric cross-validation (CSCV) overfitting diagnostic. Splits the sample into ``n_splits`` contiguous subsets, then for every

Price one rebalance: capacity, then impact, then borrow. Args: target_weights: Desired weights, shorts negative. current_weights:

Update quality score based on usage feedback. Args: name: Memory entry name (exact match). event: One of "task_succes

Start a background task and return its task_id. Args: command: Shell command to execute. Returns: JSON strin

Run garbage collection on memory store. Args: dry_run: If True (default), log actions without modifying files. Returns:

Replace unsafe path characters with underscores.

Resolve `p` under `workdir` and ensure it stays inside. Args: p: User-supplied path (relative or absolute). ``~`` expansion is

Send attachments first, then text.

Trip the kill switch by writing a sentinel file. Writing is atomic (same-directory temp file + ``os.replace``) so a partial write can never l

Cut an oversized tool result to ``limit`` characters and say so. A silent cut is indistinguishable from a complete answer, so the model repor

Static-check a generated signal_engine source. Checks: 1. ``ast.parse`` succeeds. 2. Module defines ``class SignalEngine``.

Win rate and P&L statistics from completed trades. Args: trades: Completed round-trip trades. Returns: Dict with win_rate, p

Write JSON and Markdown run cards for a backtest run. Args: run_dir: Directory where run_card.json and run_card.md are written. c

Filter DataFrame by a simple expression. Supports: - "YYYY-MM to YYYY-MM" or "YYYY-MM-DD to YYYY-MM-DD" (date range) - "symbol=XX

Fail closed when the resolved host does not match the declared environment. The host is the authoritative discriminator: testnet keys cannot reac

Fail closed when the account does not match the declared environment.

实体长度（绝对值）。 Args: o: 开盘价序列。 c: 收盘价序列。 Returns: 每根K线的实体长度。

Parse a JSON tool response.

Build the Vibe-owned Codex token store. The path deliberately does not use oauth-cli-kit's default storage, because that backend imports and

Build the CLI parser with subcommands and compatibility flags.

Build data_map, signal_map, codes for testing.

Total equity = free cash + sum(margin + unrealised) per position. Uses vectorized numpy path when _calc_pnl/_calc_margin are not over

Close position, record trade, return capital.

Return the current API auth key, if configured. Resolves the ``VIBE_TRADING_API_KEY`` alias server-side via :func:`get_env_config` so both ``

Build override dict for eToro tools, including optional credential overrides.

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

Intraday bars via stk_mins. Args: codes: Stock codes. start_date: Start date (YYYY-MM-DD). end_date: End

Detect exchange-listed ETF / LOF symbols (e.g. 510050.SH, 159915.SZ).

Return True if the tool result does not look like an error response.

Return the raw text of one lens file. Args: slug: Lens file stem, e.g. ``munger-inversion``. Returns: Raw markdown text.

Epoch-ms of a wall-clock time in an IANA zone (``fold=0`` = first occurrence).

Build a minimal OHLCV DataFrame matching tushare's column layout.

Normalize ``run_dir`` in tool args to an absolute path when possible. If the model supplies a relative ``run_dir`` (for example ``"."`` or ``

Label i resolves `horizon` bars later, so labels overlap heavily.