Optimized bulk calculation of stock stats indicators. Fetches data once and calculates indicator for all available dates. Returns dict ma

Keep only open markets that resolve in the future. ``closed`` is the reliable resolved flag (``active`` stays True even for settled markets),

Parse an Atom ``published`` timestamp to a UTC epoch, or None.

Log the final state to a JSON file.

Whether a cached frame must be refetched to reflect the requested day. The cache file is keyed per day, so without this a run started before the

Return ``<BASE>-USD`` for a known USD/USDT/USDC-quoted crypto, else None.

Parse to naive, midnight-normalized dates so tz-aware or intraday timestamps compare correctly against the naive ``curr_date`` cutoff (#1201).

Prompt user to type a custom model ID.

GET a FRED endpoint, surfacing FRED's JSON error body on a bad request.

Map a friendly alias to a FRED series ID, or pass a raw ID through. Raises ``ValueError`` when the input is neither a known alias nor a plausible

Seconds to wait from a 429's ``Retry-After`` header, capped at 30s.

Execute the graph and write the resulting state to disk and memory log.

Map a crypto pair to StockTwits' ``<BASE>.X`` convention. StockTwits lists crypto as ``BTC.X`` (Yahoo's ``BTC-USD`` form 404s), so any crypto

Reduce the HTML body Reddit embeds in an Atom entry to plain text.

Whether Anthropic accepts the ``effort`` parameter for this model.

OHLCV on or before curr_date, date-sorted. Raises if nothing usable. ``load_ohlcv`` already normalizes the Date column and filters out look-a

Keep only messages published in [start_date, end_date] (look-ahead safe). No window (both None) leaves the list untouched for live callers. A mes

Keep only posts published in [start_date, end_date] (look-ahead safe). No window (both None) leaves the list untouched for live callers. A post w

Ask which GLM platform (Z.AI international vs BigModel China) to use. Zhipu serves the same GLM models under two brands with separate account

Ask which MiniMax region (global vs China) to use. MiniMax exposes two endpoints with separate accounts — a key from one region does NOT auth

Ask for report output language.

Ask which Qwen region (international vs China) to use. Alibaba DashScope exposes two endpoints with separate accounts — a key from one region

Render a ground-truth snapshot: latest OHLCV row, indicators, recent closes.

Context-manager form of begin/end_checkpoint for the propagate path.

Classify LangChain message into display type and extract content. Returns: (type, content) - type is one of: User, Agent, Data, Control

Remove all checkpoint DBs. Returns number of files deleted.

Show the resolved Ollama endpoint after provider selection. Surfaces three things the user benefits from seeing before model selection: which

Display announcements panel. Prompts for Enter if require_attention is True.

Display the complete analysis report sequentially (avoids truncation).

Make sure the API key for `provider` is available in the environment. If the env var is already set, returns its value untouched. Otherwise i

Extract string content from various message formats. Returns None if no meaningful text content is found.

Fetch announcements from endpoint. Returns dict with announcements and settings.

Fetch recent Reddit posts mentioning ``ticker`` across finance subreddits and return them as a formatted plaintext block. ``inter_request_del

Fetch recent StockTwits messages for ``ticker`` and return them as a formatted plaintext block ready for prompt injection. When ``start_date`

Format token count for display.

Format tool arguments for terminal display.

Get the analysis date from user input.

Retrieve the FRED API key from the environment.

Retrieve the API key for Alpha Vantage from environment variables.

Get the category that contains the specified method.

Count reports that are finalized (their finalizing agent is completed). A report is considered complete when: 1. The report section h

Return configured ChatGoogleGenerativeAI instance.

Return the configured LLM instance.

Return the provider name used in warning messages.

Return current statistics.

Prompt the user to enter a ticker symbol, preserving exchange suffixes. Uses questionary.text (not typer.prompt, which strips trailing dot-suffix

Get all user selections before starting the analysis display.

Get the configured vendor for a data category or specific tool method. Tool-level configuration takes precedence over category-level.

Initialize agent status and report sections based on selected analysts. Args: selected_analysts: List of analyst type strings (e.

Check if value is empty using Python's truthiness.

Whether a signal is the non-tradeable REVIEW sentinel (#1170).

Prompt for a custom OpenAI-compatible endpoint base URL.

Save the complete analysis report to disk (shared CLI/API writer).

Select analysts using an interactive checkbox.

Select deep thinking llm engine using an interactive selection.

Select the LLM provider and its API endpoint.

Select an OpenRouter model from the newest available, or enter a custom ID. ``mode`` ("quick"/"deep") labels the prompt so the two consecutive

Select research depth using an interactive selection.

Select shallow thinking llm engine using an interactive selection.

Set up and compile the agent workflow graph. Args: selected_analysts (list): List of analyst types to include. Options are:

Return the env-configured reasoning/thinking value, or prompt for it. When ``env_var`` is set the interactive choice is skipped and the value

Normalize a datetime to UTC-aware; a naive value is assumed to be UTC.

Update analyst statuses based on accumulated report state. Logic: - Store new report content from the current chunk if present - Check ac

Update status for research team members (not Trader).

Validate that the model is supported by this client.