Extract the ``data.diff`` row list from a push2 payload, defensively. Args: payload: Decoded JSON from a push2 board endpoint. Retur

Dispatch user-facing data-routing commands.

Most frequent value in a series, or the first if tied.

min(local config, server advertised) — 0 blocks all uploads.

An Eastmoney search payload carrying two CMS articles.

Forward swarm status to the hosting session SSE channel if present.

Stage a Telegram update behind a short per-session reorder window.

Load bot identity once and reuse it for mention/reply checks.

Load dotenv values before rendering CLI-only settings.

Thin wrapper so the console script and ``python -m cli.main`` agree.

Escape text for Telegram HTML parse mode.

Map the project suffix to the broker exchange code (NSE / BSE).

Run a key-gated read-only tool, preserving its env-var-named error. Prefers the auto-discovered registry (present when the API key is set). When

Execute all tasks in a single layer in parallel, with retry on failure. Each task is retried up to agent_spec.max_retries times if the worker

Trip a stop, clear authority, audit, and return on proactive expiry. This is the §7.5 component-7 proactive path: expiry is acted on in the

Return every markdown link target containing ``references/``. Args: skill: Skill directory name (e.g. ``tushare``). Returns:

Pull the answer rows out of the iWenCai robot-data response. The service nests the structured result several levels deep under ``data.answer[

Join text content blocks from a FastMCP response. Args: content: Content block list. Returns: Joined text block content.

Fetch China-market news headlines for a query from Eastmoney. Args: query: Free-text search term (bare code or keyword). limit: M

Drop local-only arguments before forwarding to the remote tool. Args: arguments: Raw arguments from the local agent loop.

Project a full registry down to a whitelist with consistent drop logging.

Record a tool result: update memory, append message, write trace, emit event. Args: tc: Tool call object. result: Raw

Return the first configured `.env` candidate that exists, if any.

Flatten any leftover multi-index columns after symbol selection. Args: frame: Price dataframe. symbol: yfinance symbol used for c

Send any buffered tool hints for *chat_id* as a single message. Tool hints are coalesced to reduce message count and avoid hitting the

Render a large number with K / M / B / T suffixes for readability.

Fold a key to its alphanumeric core (lower-case, separators stripped). Collapses snake_case, camelCase, kebab-case and spaced variants to one for

Render a runner's last-tick timestamp as an absolute + relative string. Args: tick: A ``datetime`` or ISO-8601 string from the liveness h

Format a SwarmRun into a JSON result string. Args: run: SwarmRun instance. preset: Matched preset name. variables: Extrac

Format elapsed seconds for compact terminal display.

Return a short, readable error summary for logs.

Smart-format tool argument summary.

Get or refresh Access Token.

Assign a consistent color to each agent.

Late-access _get_channel_runtime for test monkeypatch compat.

Return a DataLoader class for a source name, with fallback. Args: source: Source name (tushare/okx/yfinance/akshare/ccxt). Returns:

Return the JSON-Schema for ``run_swarm`` via FastMCP introspection. Uses the public ``FastMCP.get_tool`` API so the test exercises the schema

Get typing ticket with per-user refresh + failure backoff cache.

Read a global boolean from the top-level channels config.

Handle incoming Discord messages from discord.py. Self-loop guard: only drop messages from this bot's own account. Messages from othe

Route swarm sub-commands.

Print a next-step hint to stderr when stdout is a TTY. Goes to stderr so it does not pollute JSON / pipe-friendly stdout output.

Normalize a Host header to a lowercase hostname without a port.

Replay goal/run strip state after subscribe (same-process refresh).

Synthetic NSE-shape OHLCV panel; vwap injected as India typical price.

Best-effort market inference from a symbol string.

Extract a positive integer from a scalar or tuple condition.

Accept either explicit `.SH/.SZ/.BJ` suffix or bare 6-digit ticker.

Decide whether an import statement target is on the whitelist.

Detect 北交所 symbols. Mootdx std factory does not serve BJ data (get_k_data raises KeyError, bars() returns empty), so the loader logs a warning

An agent with at least one data/analysis tool beyond the generic kit.

Return True when chat_id appears to be a Signal group ID (base64).

Return whether an AST node is made only from literal values.

Return True when *node* is ``os.environ``.

Skip events that landed in the timeline before this process started. Matrix sync replays the room timeline on each startup/restart; without

Return whether a top-level assignment is literal-only.

Return whether an annotation/base expression cannot call code.

True for the Windows access/sharing race on os.replace. ``winerror`` is only set on Windows; ``getattr`` keeps this a hard False on POSIX, so

Return whether ``code`` is a US-equity symbol this loader handles.

Shared SSE loop for bench + compare jobs. Emits ``progress`` whenever ``n_done`` advances, then a single ``result`` (projected onto the wire

Return the recognized live-broker keys (SPEC §7.2).