Recompile the graph with a per-ticker checkpointer and return the ``thread_id`` to inject into the stream/invoke ``config`` (or ``None``

The value to stream/invoke: ``None`` to resume an existing checkpoint, else the initial state for a fresh run. LangGraph resumes an i

Remove all checkpoint databases. Returns the number of databases deleted. SQLite keeps committed state in ``-wal`` and ``-shm`` files beside the

Remove checkpoint for a specific ticker+date by deleting the thread's rows.

Drop a completed run's checkpoint so a later run starts fresh (#1249).

Build a run's initial state; propagate() and the CLI both start here. Settles this ticker's pending decisions first, then injects the lessons

Restore the plain uncheckpointed graph after a checkpointed run.

Convert various date formats to the YYYYMMDDTHHMM Alpha Vantage expects. A plain date means midnight, which is the start of that day. For the end

Build known model names from the shared CLI catalog plus legacy IDs.

Return a configured ChatOpenAI instance, driven by the provider registry.

``requests.get`` plus ``raise_for_status``, with ``secret`` kept out of errors. Vendors that authenticate with a query parameter put the key in t

Whether ``provider`` is served by the OpenAI-compatible registry.

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

Whether a ticker entry is acceptable (charset + length). Allows the characters Yahoo symbols use, including ``=`` for futures/forex like ``GC

True when ``symbol`` only contains characters Yahoo symbols use.

Process a signal to extract the core decision.

Log a finished run's decision for reflection on the next same-ticker run.

Render a ResearchPlan to markdown for storage and the trader's prompt context.

Write the markdown report tree for a completed run, like the CLI does. Programmatic callers get the same on-disk reports the CLI produces. Pa

Determine if debate should continue.

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

Whether the vendor answers at all, for telling silence from an outage. A client that returns an empty result instead of raising leaves those two

Notice to serve instead of a live-only company profile, or None to serve it. Vendor "company overview" endpoints (yfinance ``Ticker.info``, Alpha

Whether ``thinking_level="minimal"`` is accepted: numbered Flash models before 3.8. Pro, 3.8+ and version-less aliases (which move between gen

Alpha return of a settled entry, or None when it has not settled. The log stores it as a percentage rounded to one decimal, so aggregates here

Drive the real selection flow, answering each prompt with a fixed value.

Apply TRADINGAGENTS_* env vars to the config dict in-place.

({period end: value}, unit) for the first tag the filer reports, as known then. A period reported more than once takes its latest filing on or be

Lazily import langchain-aws (the optional ``[bedrock]`` extra) and return a ChatBedrockConverse subclass with normalized content output. Impo

Assemble the run config from interactive selections, honoring env precedence. Round counts and checkpoint follow "explicit env/flag wins": an env

Assemble the sentiment-analyst system message with structured data blocks.

Whether the symbol's cached download can serve this request. The file holds the download made on the day it was written, so it serves only th

Parse a grid bound, rejecting anything the run date would also reject.

Normalize a stock DataFrame for stockstats: parse/normalize dates and coerce prices to numeric (NaN where invalid). Dropping incomplete rows and

Return a trimmed string, or None for empty / placeholder-ish values.

Coerce env-var string to the type of the existing default value. Invalid values raise ``ValueError`` rather than silently falling back to a d

Return parsed dates from an OHLCV frame, whether Date is a column or the index.

Dates that bound the feed's coverage. The search is limited to the last week (``t=week``), so the lookback start bounds it even when nothing came

Read a public EDGAR document, respecting SEC's identification rule.

Fetch available models from the OpenRouter API.

Default path: parse the public Atom search feed for a subreddit. ``sub`` may be one subreddit or several joined with ``+``. On a 429 (Reddit's

Drop rows with no close and forward/back-fill remaining price gaps so indicators compute on a continuous series.

Filter CSV data to include only rows within the specified date range. Args: csv_data: CSV string from Alpha Vantage API star

FRED's current calendar date (US Central) as ``yyyy-mm-dd``. The vintage pin is clamped to this: FRED rejects a ``realtime_start`` after its

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.

Return ``seconds`` with +/-``frac`` random jitter, to desynchronize concurrent runs pacing against the same per-IP limit.

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.

Walk the selection steps. ``prefs`` prefills, the environment skips.

Read a response body bounded to ``_MAX_FEED_BYTES``, raising on overflow.

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 60s. The cap matches ``_RETRY_FALLBACK_SECONDS``: honouring less than we would

Where this run writes, with the ticker validated as a path component. Every other path that interpolates a ticker checks it first; a value of

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.

Who SEC sees. No account or key exists; callers identify themselves. www.sec.gov, which serves the ticker map, refuses a User-Agent carrying no

The run date as a canonical ``YYYY-MM-DD`` string no later than today.

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

The installed package version, so a release identifies itself correctly.

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