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

Resolve unique local server-name segments for MCP tool names. The first release keeps MCP tool names ASCII-safe by sanitizing server names. D

Resolve a file path under run_dir with fallback to allowed roots. Args: file_path: Relative or absolute path (supports tilde expansion).

Start a background task and return its task_id. Args: command: Shell command to execute. Returns: JSON strin

Full backtest pipeline. Signature matches ``daily_portfolio.run_backtest`` for drop-in replacement. Args: config: Backte

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

Drive a multi-market backtest from a ShadowProfile. Args: profile: ShadowProfile to replay. window_start / window_end: ISO dates.

Validate a document-reader file path. Args: p: User-supplied document path. `~` expansion is supported. Returns: Absolute re

Return runtime and channel status.

Terminate an HTTP MCP subprocess and wait for clean exit.

Return a plain JSON-serializable view of this tick result.

Re-wrap a live broker's discovered tools by read/write class. READ tools are returned as-is with ``is_readonly = True``; WRITE and UNKNOWN to

Return the agent package root.

Filter DataFrame by a simple expression. Supports: - "YYYY-MM to YYYY-MM" or "YYYY-MM-DD to YYYY-MM-DD" (date range) - "symbol=XX

Extract date from bar, handling various column names.

Parse a JSON tool response.

Build subprocess env and enforce no-proxy execution. Args: run_dir: Current run directory. pythonpath_extra: Addition

SLSQP weights for the penalized objective; updates turnover state.

Call a known read operation on a remote MCP connector profile.

Strip empty list values from MCP payloads.

Emit a swarm event via callback if provided. Args: callback: Optional event callback function. event_type: Event type string.

Load `.env` from the first found candidate path.

UTC-midnight epoch seconds for a date, used to build fake chart rows.

Equal weights for n assets.

Pull ``--max-iter <N>`` (or ``--max-iter=N``) out of ``argv``. The legacy argparse setup accepts ``--max-iter`` both at the top level and as

Extract product code from futures symbol. Handles CME conventions: - Product + month-code + year: ESZ4, CLF25, GCM2025 - Product + Y

Build the smallest object that quacks like a LangChain AIMessage.

Fetch daily OHLCV for one symbol via the backtest loader registry. Uses the same access path as the backtest runner (``resolve_loader`` + the

Translate a project symbol into FMP's bare-ticker convention. FMP carries US tickers bare, so a trailing ``.US`` suffix (the project's US-equ

Build an OHLCV frame from (open, high, low, close, volume) rows.

Remove expired pending entries in-place.

Return the shared finance goal store.

Return a hypothesis by id, or None when absent.

Return the singleton ScheduledResearchJobStore, creating it on first call.

Group symbols by detected market type. Args: codes: List of symbol strings. Returns: Mapping market_type -> list of codes.

Return True if ``text`` contains unbalanced ``()``/``[]``/``{}`` pairs. Used to decide whether a plain Enter should submit or insert a newlin

A daily bar carrying Yahoo's real session-open epoch (14:30 UTC).

Execute a tool with heartbeat + structured progress emission. Installs a thread-local progress emitter so the tool may call ``emit_pr

Return True if ``text`` is a bare kill-switch turn. Matches a turn whose entire content (trimmed, trailing punctuation removed, lower-cased)

Return a standard MCP JSON error envelope.

Return a standard JSON error envelope.

Return a standard MCP JSON success envelope.

Load a Python module from a file path via importlib. Args: file_path: Path to the ``.py`` file. module_name: Logical module name.

Dynamically load an optimizer function from config. Args: config: Backtest configuration. Returns: Optimizer callable, or No

下影线长度。 Args: o: 开盘价序列。 c: 收盘价序列。 l: 最低价序列。 Returns: 每根K线的下影线长度。

Create a close price DataFrame.

Create a SwarmEvent with current timestamp. Args: event_type: Event type string. agent_id: Optional agent identifier.

Build lightweight ``MCPRemoteTool`` stubs without a live adapter. Mirrors the helper in ``tests/test_registry_mcp_integration.py`` so M2 test

Convert FastMCP response payloads into JSON-serializable objects. Args: value: Arbitrary response value. Returns: JSON-seria

Build a minimal OHLCV DataFrame matching tushare's column layout.

Return whether ``mandate`` is at/past its expiry as of ``now`` (fail-closed). An unparseable ``expires_at`` is treated as expired: a live mandate

Epoch milliseconds for a wall-clock instant in a named timezone.

Normalize AKShare DataFrame to standard OHLCV schema. AKShare Chinese column names: 日期, 开盘, 最高, 最低, 收盘, 成交量 AKShare English column na

Two ascending daily candles in Finnhub's parallel-array layout.

Coerce environment string values to ``bool``. Accepts ``"1"``, ``"true"``, ``"yes"``, ``"on"`` (case-insensitive) as ``True`` and ``"0"``, ``

Parse an ISO-8601 UTC ``expires_at`` string into an aware ``datetime``. The mandate commit path writes the expiry with a trailing ``Z`` (e.g.

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

Print execution result panel.

Unwrap a Yahoo ``{"raw":..,"fmt":..}`` cell to its numeric ``raw`` value. Args: value: A Yahoo scalar, which may be a plain value or a fo

Read bytes from http(s) or local file path; return (data, filename).

Read settings without creating agent/.env. Prefer the user's active agent/.env. If it does not exist yet, fall back to agent/.env.example fo

Build a swarm registry that exposes the given remote tools verbatim. Reuses the real :func:`build_swarm_registry` for the local-tool side (so

Reply to an existing Feishu message using the Reply API (synchronous). Args: reply_in_thread: If True, reply as a thread/topic me

Return the shared CLI console.