Normalize an optional connector profile id.

Return the ``openapi`` submodule from whichever SDK package is installed.

Invoke serve_main with uvicorn stubbed; return the host it bound to. The frontend mount / static-file branches are short-circuited because uv

Call ``obj.name(*args, **kwargs)`` if it exists, retrying without kwargs. python-okx signatures vary across versions (some read methods accept ex

Return (ret, pos, dates) for a small long-only universe.

Strip C0/C1 control bytes from `content` while keeping ``\n`` and ``\t``.

Return the first non-empty str value found for *keys*, stripped.

Convert project symbol to Futu OpenAPI format. Examples: 700.HK -> HK.00700 5.HK -> HK.00005 000001.SZ -> SZ.0000

Build shared optional trading connector arguments.

Return the data payload from a Futu ``(ret_code, data[, page_key])`` tuple. Futu read calls return ``(ret_code, data)``; ``request_history_kline`

Open an immediate write transaction for cross-connection safety.

Bound a per-symbol row list to keep tool payloads within budget.

Raise :class:`TimeoutError` if the monotonic clock has crossed ``deadline``. Use this between pages of a paginated fetch to fail fast instead of

Close the database connection.

Compute daily Spearman rank correlation (IC) between factor values and returns. Vectorised via ``rank().corrwith()`` (Spearman = Pearson on ranks

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

Return non-blocking diagnostics for assertion messages.

Fetch news headlines for one stock or the broad market. Args: **kwargs: ``scope`` ('stock' | 'global', default 'stock'), ``code``

Return and create the runtime data directory derived from config path. Args: config_path: Optional explicit config file path. Return

Return skills grouped by category for the system prompt. Returns: Grouped skill list with category headers.

Return a process-wide singleton SessionSearchIndex. Thread-safe via double-checked locking. Used by both SessionService (indexing) and Sessio

Infer market key from a ticker symbol.

Return True when ``finish_reason`` indicates content moderation blocked the response. Recognises both OpenAI's ``"content_filter"`` and Gemini's

Return whether an MCP server denotes a live-trading broker. Detection is by config key OR by URL host, so a live-broker URL parked under an a

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

Return summary info for all available presets. Returns: List of dicts with keys: name, title, description, agent_count, variables.

AST-extract the ``__alpha_meta__`` dict literal from a zoo module. No import is performed — purely static parsing. Raises ``RegistryError`` on

Load a YAML preset by name. Args: name: Preset name (without .yaml extension). Returns: Parsed YAML dict. Raises:

Load a ShadowProfile back from disk. Raises: FileNotFoundError: No profile with that id.

Load disk config and apply runtime overrides. Args: config_path: Optional explicit config file path. overrides: Runtime override

Return the parquet cache path for one loader payload.

Perform channel-specific interactive login (e.g. QR code scan). Args: force: If True, ignore existing credentials and force re-au

End-to-end: load file, detect format, parse. Args: path: File path. Returns: (format_name, records). Falls back to generic i

Record a generated transcript event for the current process.

Return the API-key and base-URL env names for a provider/model pair.

Fetch web page content via the Jina Reader API. The full URL (including query string) is sent to the third-party Jina Reader service (r.jina.

Convert records to a standardized DataFrame (datetime column parsed).

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

Resolve the effective transport from explicit type or implied fields.

Context manager that runs a FastMCP HTTP server on a retryable free port.

Split content into chunks within max_len, preferring line breaks. Args: content: The text content to split. max_len: Maximum leng

Begin rendering. ``verb`` rerolls per turn if not supplied.

Start a swarm run. Returns immediately, execution happens in background. Args: preset_name: YAML preset name to execute.

Single source of truth for where swarm runs are persisted. The swarm store (mcp_server) and the run-dir sandbox allow-list (src.tools.path_ut

Serialize the hypothesis to plain JSON-compatible data.

Create the default FastMCP client from MCP transport config. Returns: Configured async FastMCP client.

Calculate price change percentage from bar data.

Call an async Telegram API function with retry on pool/network timeout and RetryAfter.

Collapse whitespace and clip text for single-line terminal cells.

Summarize a cluster as one ShadowRule. Entry condition uses p10–p90 numeric bounds + dominant market. This is lighter than a decision tree an

Normalise the ``alpha_ids`` argument to a clean list of ids. Accepts a list (the contract) or a comma/space-separated string (LLMs occasional

Coerce frontmatter values to a display string. ``parse_frontmatter`` returns lists for ``[a, b]`` syntax and bools for ``true``/``false``. ``

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

Route parsed ``connector`` subcommands.

Persist an event and forward to live callback if registered. Args: run_id: Run identifier. event: Event to persist.

Import every known loader module so ``@register`` decorators fire. Safe to call multiple times — only runs the imports once. Loaders whose de

Render a failure envelope as a JSON string. Args: message: Human-readable error text. Returns: ``{"ok": fals

Create exchange instance.

Return (service, session) or raise 404.

Return the shared goal store, lazily initialized.

Print one-line error; emit traceback only when ``--verbose`` is set.

Intercept a reply while a mandate proposal is outstanding. Must be called only when ``ctx.pending_proposal`` is set. A bare numeric pick is a

Import agent/mcp_server.py without executing main(). Returns: The imported mcp_server module. Raises: ImportError: If the mo

Detect crypto symbols (e.g. BTC-USDT, ETH/USDT).

Detect Hong Kong equity symbols (e.g. 00700.HK).