Convert a TickerAll candles body into an ascending OHLCV frame, trimmed to the window. Args: payload: Decoded JSON body (a list, or ``{ca

Return (start_date, end_date) as YYYY-MM-DD strings.

Build a tz-naive trade_date-indexed OHLCV frame like a loader returns.

Raise ValueError if `p` starts with a UNC share prefix.

Send a JSON request with spacing and 429 Retry-After handling.

Return the shared CLI console, or a caller-supplied override.

Scan all .md files (except MEMORY.md) and parse frontmatter.

Write a durable last-known runtime_state.json for ``broker`` directly.

Write a dummy .md file with basic frontmatter.

Return the canonical artifacts directory for one agent within a run. The single source of truth for this path — shared with the retry loop in

Parse a trade journal and return a JSON analysis. Args: file_path: Path to CSV/Excel file. analysis_type: "full" | "profile" | "b

Control the false discovery rate across many simultaneous tests. Bonferroni controls the probability of *any* false positive and is far too s

Link single-period Brinson results into a residual-free multi-period attribution. Every period's effects are scaled by ``k_t / k`` and summed. Be

Bootstrap the OAuth handshake for a live broker channel (desktop only). Builds the broker's MCP tool wrappers, which forces a connection and — wh

Show auth state, active mandate, and halt state for live channels. Read-only: it loads the mandate via :func:`src.live.mandate.store.load_mandate

Compute importance via Ebbinghaus-inspired decay formula.

Regress one date's asset returns on their exposures. The coefficients are that date's factor returns. Weighting is by square-root market cap

Rough token count estimate (~4 chars/token). Args: messages: Message list. Returns: Estimated token count.

Apply a constant basis-point slippage to a fill price. The cheapest model, and adequate whenever the order is small enough that it does not m

Render *grounding* as a markdown block ready to splice into a prompt. Returns the empty string if no symbol has any data — callers can use th

Return a process-wide cached ``Registry`` for the bundled zoo. Thread-safe. First call builds and caches; subsequent calls return the same in

Read a session. Args: session_id: Session ID. Returns: The Session instance, or None when it does not exist.

Quantize *price* down onto the HOSE tick grid.

Check if a memory with similar content was recently written. Uses a 30-second sliding window to catch rapid-fire duplicates from retr

Return whether QVeris paid routing should be visible.

Report whether a runner's heartbeat is fresh enough to call it alive. Args: runner_id: The runner to check. now_ms: Reference tim

Test whether the breach *count* matches the model's claimed level. The Kupiec proportion-of-failures test compares the realised breach rate a

Load all hypotheses from storage.

Return the root directory for all live-channel state. Returns: ``<runtime_root>/live``. The directory is NOT created here; callers

CLI entrypoint returning a process exit code. Behaviour: * Interactive entry (no subcommand, or ``chat`` + TTY): show banner, run onbo

Build a market-session trigger for a known market key. Args: market: A key into :data:`MARKET_SPECS` (e.g. ``"us_equity"``).

Simulate price paths under geometric Brownian motion. Each step applies ``(mu - 0.5 * sigma**2) * dt + sigma * sqrt(dt) * Z`` in log space, s

Value at Risk under a fitted normal distribution. Cheap and smooth, but it sees only a mean and a variance, so it misses fat tails. The direc

Parse the ``## Verdict`` tail of a terminal briefing. Returns: ``(parse_state, items)``. ``no_verdict_section`` when no such heading

Preferred return owed to LPs, accrued per contribution from its own date. Accruing each draw separately matters: a fund that called half its capi

Record a bench result. Returns the result ID.

Redact one tool result for trace persistence and event previews. The single choke point for a tool-result string: callers redact once and han

Render the SignalEngine Python source for a profile. Args: profile: ShadowProfile carrying the rules to replay. Returns: Pyt

Replay buffered session events for reconnect recovery. Args: session_id: Session ID. last_event_id: Last event ID rec

Map a Vibe-Trading symbol to its Eastmoney secid. Supported suffixes: ``.SH`` / ``.SZ`` / ``.BJ`` (A-share), ``.HK`` (Hong Kong, code zero-pa

Run chart pattern detection on OHLCV data in run_dir. Args: run_dir: Path to the run directory. patterns: Comma-separated pattern

Per-row L1 normalize so sum of absolute values equals ``a``. Rows whose abs-sum is 0 (or all-NaN) become NaN — never silent zero.

Determine if a status transition should occur. Args: current_status: Current artifact status. consecutive_signals: Re

Map a markdown document to its heading structure. A section runs from its heading to the next heading of the same or shallower level, so aski

Sum the signed amounts. Valuation marks such as NAV are excluded by default: adding a mark to settled cash would overstate what was a

Convert flows in one or more currencies into ``rate_table``'s currency. Each flow is converted using the FX rate quoted on **that flow's own

Atomically update run state. Args: run: Updated SwarmRun instance. Raises: FileNotFoundError: If the run dir

Atomically record a runner's last-tick timestamp. Args: runner_id: The runner writing its heartbeat. now_ms: Timestamp to record,

Render a cover page that declares an amendment, exactly as EDGAR nests it. Copied from DZ BANK's live 2020-09-30 amendments: ``isAmendment`` and

Create a dated OHLCV frame ending on the scanner target date.

Build a minimal FMP historical-price-full body.

Realised PnL for a closed position.

Equal risk contribution weights.

Normalize channel-like objects and ids to a stable string key.

Relative Strength Index (Wilder smoothing) over *period* bars. Matches the Wilder-EWM convention already used for RSI elsewhere in this codeb

Yield one short-lived connection; commit on success, rollback on error.

Wrap one client contribution of ``size`` in a series. The amount is negated because ``CashFlow`` is holder-perspective: money the client pays

A suggest payload spanning A-share, HK, and US markets.

Return a minimal Anthropic environment with optional overrides.

Return token usage for a single LLM call, real if available. Prefers the provider-reported counts attached to the response by :func:`ChatLLM.

Build a ccxt ``binance`` client bound to the configured environment.

Execute one fake MCP tool with a parsed FastMCP result.

Return the ``data`` list from an OKX response, or ``[]`` defensively. python-okx returns a dict shaped ``{"code": "0", "data": [...]}`` on succes

Return the hand-built four-sector single-period attribution. Returns: The :class:`BrinsonResult` for the module-level fixture.

Convert a Longbridge SDK numeric value (Decimal/int) to float for JSON serialization.

Perform a read-only GET request against the Trading 212 REST API.

Get or create the SQLite connection (WAL mode).

Import ``agent/mcp_server.py`` without executing ``main()``. Returns: The imported mcp_server module.