Create TradeRecord list from PnL values.

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

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

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

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

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

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

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

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 → `

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.

Add connector profile metadata to an operation payload.

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

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

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

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

Serialize the largest whole-record page of ``records[offset:]`` that fits. Args: records: All available records, newest first by the call

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

Load every available playbook, sorted by slug. A slug found in an earlier directory shadows the same slug later, so a user file overrides the

Load the persisted jobs. A missing store (never written) is the *only* clean empty result. A store that exists but fails to parse is

Load a YAML preset by name (user directory first, then bundled). Args: name: Preset name (without .yaml extension). Returns:

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

Move legacy code-relative state directories under the runtime root. Idempotent: once a legacy entry has been moved (or was never there), late

Single source of truth for "what does this run actually look like". Three layered transforms, applied in order to ``run``: 1. **Hydr

Register a new artifact, assigning an ID and timestamps. Returns: The assigned ``artifact_id``.

Strict-mode bench: like ``run_bench`` but with mandatory random control. Args: zoo: Zoo id (e.g. ``alpha101``, ``gtja191``, ``qlib158``,

Save or overwrite task state. Args: task: SwarmTask instance.

Drop, flag, or reject bars that violate OHLC invariants. Loaders only drop NaN rows, so structurally dirty bars — ``high < low``, a non-posit

Calculate options backtest metrics. Args: equity: Equity series. initial_cash: Initial capital. trades: List of trade rec

Create the appropriate market engine based on data source and market type. Routing priority: 1. Detect market type from symbol patterns (fu

Fetch and normalize one daily OHLCV frame, routing by symbol type.

Did a tool call return a top-level error envelope? Parses the result as JSON and checks for a top-level ``status == "error"``. Also treats ``

Normalize one gamma market through the tool and return the record.

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

Return a ledger that screened broadly, then locked one candidate.

Generate a mean-zero AR(1) series, the discrete analogue of an OU process. Args: phi: Persistence coefficient; |phi| < 1 gives a stationa

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

Bucket a strict bench row into one of four ``StrictCategory`` values. Required keys on ``row``: - ``alpha_t_full`` (float) - ``al

Clear all issued tokens.

Close the database connection.

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

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

Return preloaded rows for requested codes.

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

Format an assistant tool_calls message, preserving thinking text. Args: tool_calls: List of tool call objects. conten

Issue a throttled Eastmoney GET and decode the body as JSON. Args: url: Fully-qualified Eastmoney endpoint URL. params: Query par

Probe public candles with a short timeout (honours proxy env).

Return alpha IDs matching the (optional) filters.

Render a PASS/FAIL verdict from per-point verification results. Each result with a ``fetched_value`` is judged against the reported value at