Build a minimal ShadowProfile for scanner tests.

Build the three injected READ callables from fabricated snapshots.

Return a TestClient that simulates a non-loopback caller.

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

Convert project symbols into yfinance symbols. Args: code: Project symbol, for example ``AAPL.US`` or ``700.HK``. Returns: y

Append an event to events.jsonl. Args: run_id: Run identifier. event: Event to append. Raises: F

Construct a ChatOpenAI instance. Args: model_name: Model name; defaults to LANGCHAIN_MODEL_NAME. callbacks: Optional LangChain ca

Number of bars per year for annualisation. Args: interval: Bar size (1m / 5m / 15m / 30m / 1H / 4H / 1D). source: Data source (tu

Publish a structured progress event from a tool. Silently no-ops when called outside an active tool context (e.g. during unit tests that invo

Detect peaks and valleys in a price series. Args: close: Closing price series. window: Half-window size; effective window is 2*wi

Return a loader *class* for *source*, falling back if unavailable. Args: source: Requested data source name. Returns: A Data

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

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

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

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

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

Load QVeris config with environment overrides applied.

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

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

Send a message to a session and trigger execution. Args: session_id: Session ID. content: Message content.

Return a JSON-serializable profile snapshot.

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

Rolling sample covariance per column, min_periods=n.

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

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线的实体长度。

Build an AgentLoop with a real (but empty) registry and a stub LLM.

Build the CLI parser with subcommands and compatibility flags.

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

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

Close position, record trade, return capital.

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

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

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

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

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

Build a minimal Futu kline DataFrame mirroring request_history_kline output.

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.

Compute correlation matrix for multiple price series. Args: price_series: Mapping of asset code -> DataFrame with a ``close`` column.

Sanitize skill name to a safe directory slug.

Import the SDK connector module for a ``broker_sdk`` connector key.

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

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

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

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

Load all hypotheses from storage.

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

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"``).

Pair buys and sells per symbol using FIFO to compute per-roundtrip PnL. Args: df: Standardized DataFrame (datetime-sorted). Returns:

Remove a memory entry by name. Args: name: Memory name to remove. Returns: True if found and removed.

Execute a single worker task using a lightweight ReAct loop. Steps: 1. Build filtered ToolRegistry from agent_spec.tools 2. Create Ch

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.

Start the QQ bot with auto-reconnect loop.

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

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

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

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

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

Build a minimal FMP historical-price-full body.

Equal risk contribution weights.

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