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

Apply optimizer to position weights. Args: ret: Return matrix (dates x codes). pos: Raw signal positions.

Clear the cached :class:`EnvConfig` singleton. Acquires the same lock used by :func:`get_env_config` so the reset is atomic with respect to c

Infer market type from symbol format. Args: code: Ticker / symbol string. Returns: Market type (a_share/us_equity/hk_equity/

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

Remove a job by id. Args: job_id: Identifier of the job to remove. Returns: ``True`` when the job was found

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

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.

Block until ``bucket`` is allowed to fire again, then record the slot. The *reserved fire time* — jitter included — is what gets stored, so t

Create a synthetic equity curve.

Run _sync_provider_env with a clean env and return relevant keys.

Full set of performance metrics. Args: equity_curve: Equity time series (index=timestamp, values=equity). trades: Completed round

Clear all issued tokens.

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

Return preloaded rows for requested codes.

Keyword search across all memory entries. Scoring: metadata_hits * 2.0 + body_hits * 1.0. Args: query: Search query.

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

Build a config from a JSON-like mapping, normalizing the profile.

Return the capability record for a provider/model pair. Args: provider: Configured provider name. model: Configured model name, u

Return alpha IDs matching the (optional) filters.

Resolve a profile id or the saved selected profile. Args: profile_id: Optional explicit profile id. Returns: Matching profil

Return the first *available* loader instance for *market*. Walks the fallback chain and returns the first loader whose ``is_available()`` ret

Resolve a per-provider minimum request interval from the environment. Args: env_name: Env var carrying an override in seconds (e.g.

Run a bench end-to-end and return the API-shaped summary. Args: zoo: Zoo id (e.g. ``gtja191``, ``alpha101``, ``qlib158``). univer

Fire an event via the callback.

Build a ``run_bench`` double returning canned rows for the ``only`` ids.

Decide whether this invocation should drive the interactive loop. Interactive entry requires: * Both stdin and stdout are TTYs (no piped / r

Create TradeRecord list from PnL values.

Run the propose tool and return the parsed proposal payload.

Seed three hypotheses spanning multiple statuses; return their ids.

Split text into searchable tokens. ASCII words >= 3 chars + individual characters from non-Latin scripts listed in ``_NON_LATIN_SCRIPT_RANGES

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

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

Replace internal root prefixes with '<redacted>', keep relative tail.

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

Build the Rich renderable shown while the run is active.

Validate a run directory used by generated-code tools. Args: p: User/LLM-supplied run directory. `~` expansion is supported. Returns

Validate a user-supplied broker/export file path. Args: p: User-supplied path. `~` expansion is supported. Returns: Absolute

Return a list of {symbol, market, rule_id, reason} matches. Args: profile: ShadowProfile holding the rules. target_date: ISO "YYY

Serialize the session to a dictionary. Returns: A JSON-serializable dictionary.

Build a persistent OAuth token store rooted at ``cache_dir``. The directory is created (with parents) and locked down to ``0700`` so only the

Render + load + execute a SignalEngine against a data_map.

Re-inject reasoning_content and normalize assistant content. LangChain strips ``reasoning_content`` when serializing AIMessages

Return the host ``api_server`` module for shared deps and monkeypatched symbols.

Send a raw frame to one connection, cleaning up on ConnectionClosed.

Build a per-worker registry that merges local + remote MCP tools. Swarm workers receive a strict whitelist (``agent_spec.tools``). This build

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

Pure core: is ``trigger`` due at ``now_ms``. Deterministic — reads no clock; all inputs are arguments. * INTERVAL: due when ``(now_ms - epoc

Return a goal by id.

Always available (public API, no auth).

Strip and validate a required text field. Args: value: User supplied text. field_name: Field name for the error message. Ret

Reconcile broker truth against the durable last-known state. Pulls the broker's positions, balance, and open orders through the injected READ

Call ``fn`` with a bounded retry budget on declared transient errors. Between attempts sleeps ``min(backoff[attempt], remaining_budget)`` so a

Run ONE fail-closed tick in fixed order; return the outcome dict. Ordering (each step short-circuits the tick on failure): 1. **Halt

Strip operator-only keys from API-caller-supplied session overrides. ``mcpServers`` / ``mcp_servers`` define subprocess ``command``/``args``/``en

``sign(df) * |df|**p`` — preserves sign; never produces complex output.

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

Update a goal status with stale-goal and completion validation.

Validate a URL is safe to fetch: scheme, hostname, and resolved IPs. ``allow_loopback`` is intentionally narrow: it only permits literal loop

Build an AgentConfig from a plain server-name → config-dict map.