Point ``module.os`` at a stand-in carrying ``overrides``. Args: monkeypatch: The test's ``monkeypatch`` fixture. module: The modu

K contiguous test blocks, each with training purged and embargoed. Folds are contiguous in time rather than shuffled: shuffling destroys the

Total number of stored evidence rows.

Run a full comparable-companies valuation: EV bridge, multiples, implied range. Args: target: The company being valued. peers: Th

Run build_llm in a replaced environment and return the adapter kwargs. Args: env: Full environment for the call; every other variable is

Return a ``_sec_get`` stub serving a whole quarter's chain of filings. Each entry is ``{adsh, form, file_date, cover, rows}``: ``cover`` is the

Build one EDGAR full-text search hit in the live ``_source`` shape.

Normalize a symbol onto one canonical identity for exact comparison. Args: value: Any provider- or model-supplied symbol spelling. R

Build the local-connector override dict, rejecting malformed numerics. Args: kwargs: Raw tool arguments. Returns: Override m

A range-mode /candles body: {candles, truncated, coverage, stopReason, ...}.

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

No-op: the stub owns no HTTP client.

Fetch normalized OHLCV data through the repository loader layer. When ``source="auto"`` (or any resolved source), if the chosen loader raises

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

Load Futu settings from ``~/.vibe-trading/futu.json``.

Load an entity x date x metric panel file into an ``EntityPanel``. The ingest module's generic counterpart to ``load_cashflows``, for data th

Parse one playbook markdown file. Args: path: Path to a ``.md`` playbook file. Returns: The parsed :class:`ResearchPlaybook`

Build the REST client for a config (tests may override via ``set_client_factory``).

Apply optimizer to position weights. Args: ret: Return matrix (dates x codes). For a decision at ``dt``, only row

Chain-link the true time-weighted return across a valuation series. Each interval's return removes that interval's external flow before divid

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

A self-consistent, LTM-ready peer for tests that are not about the big hand-computed fixture (EV bridge signs, exclusion, warnings, ...).

A gamma event wrapping the supplied markets.

Check whether a futures code belongs to a Chinese exchange. Recognises two forms: 1. ``<product><delivery>.<exchange>`` where exchange is o

Construct EvidenceStore tolerantly across positional/keyword db path.

Create TradeRecord list from PnL values.

Extract the numbers in a claim that could plausibly be prices. Digits that belong to a canonical symbol, a calendar date, an aggregate

Drive the real argparse dispatcher, returning its exit code.

Run _sync_provider_env with a clean env and return relevant keys.

Append one hash-chained record to a JSONL ledger, durably. Reads and verifies the ledger's ENTIRE existing chain under an exclusive advisory

Present value of a bullet bond settling on a coupon date. The result is a *clean* price: settlement is assumed to sit on a coupon date so no

Build the EBIT -> FCFF bridge for every projection year. Args: ebit: EBIT forecast, one entry per projection year, oldest first.

Build a table from ``{(base_currency, date): rate}`` pairs. Args: mapping: Each value is units of ``quote_currency`` per 1 unit o

Return the full documentation for a skill (used by the load_skill tool). Falls back to disk lookup for user skills created mid-session.

Return the current goal plus ledger rows for a session.

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

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

Close an OpenD context, swallowing teardown errors.

Small constructor to keep the isolated unit tests below readable.

Render + load + execute a SignalEngine against a data_map.

Return a ``_sec_get`` stub that answers by URL, as the live endpoints do. Full-text search is filtered by the ``ciks`` parameter the way the live

Decompose one period's active return into allocation, selection and interaction. Sector returns may be omitted only where the corresponding weigh

Create and persist a session. Args: session: Session instance to create. Returns: The persisted Session.

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

Value at Risk from the empirical distribution of past returns. Makes no distributional assumption: it simply reads the loss off the sorted sa

Return alpha IDs matching the (optional) filters.

Load Trading 212 settings from ``~/.vibe-trading/trading212.json``.

Coerce a supported date input to a plain ``datetime.date``. ``datetime`` instances are truncated to their date, because a cash flow settles o

Project linked income, cash flow and balance-sheet statements forward. Args: opening: The opening balance sheet plus trailing revenue. Mu

Replace internal root prefixes with '<redacted>', keep relative tail. Every occurrence of an internal root is replaced when it ends at a real

Recursively redact sensitive keys in a structured payload. Walks dicts and lists; any dict value whose key :func:`is_sensitive_arg` is replac

Resolve credentials atomically from environment or the legacy runtime file.

Atomically persist the job set. Write sequence (durable even under SIGKILL): temp file in the same dir → ``os.fsync`` the temp fd → `

Throttled GET that decodes the response body as JSON. Same contract as :func:`throttled_get`, plus ``response.raise_for_status()`` and ``resp

Run one poll/dispatch pass. Args: now_ms: Optional explicit reference time. Defaults to ``now_fn``.

Hybrid output contract. Return a short reason string when the worker did NOT produce a substantive deliverable, else ``None``. Content-sanity

Fire an event via the callback.

Wrap unit rows in the companyfacts envelope shape.

Build a minimal bar Series for testing.

Run the propose tool and return the parsed proposal payload.

Return a TestClient that simulates a non-loopback caller.

Get the sub-engine that provides rules for this symbol.

Return a standard unsupported-capability payload.

Authorize against identity state frozen before the whole LLM batch. Args: tool_name: Requested tool. arguments: Model

Resample daily returns to estimate Sharpe confidence interval. Args: equity_curve: Equity time series. n_bootstrap: Number of boo

Build a :class:`RunManifest` from raw run composition data. Args: run_id: Run/session identifier (provenance only, not hashed). t

Check if this tool's dependencies are met. Override in subclasses to check for API keys, packages, etc. Tools that return False are e

Lazy-import the alpha module and run its ``compute(panel)``. Raises: KeyError: alpha_id unknown. SkipAlpha: required