Run ``flow_fn`` over ``inputs`` with bounded concurrency. Args: flow_fn: Any flow function with signature ``(input, *, cfg, *

Pull the canonical arXiv id from a raw user input. Returns: Canonical id in either modern (``YYMM.NNNNN``) or legacy (``archive[.

Parse a date string (filing dates, news timestamps) into UTC datetime. Accepts ISO-8601 with or without time component, ``YYYY-MM-DD``, ``YYY

Look up a DOI on Crossref and return canonical metadata. Args: doi: A DOI string. Accepts canonical form (``10.NNNN/...``), `

Count weekdays (Mon-Fri) strictly between ``a`` and ``b``. The count is **inclusive of both endpoints** when they fall on weekdays, and direc

Extract a ``Paper`` from a typed ``PaperInput``. See design doc §4.1 for the rationale on each kwarg. ``memory`` is a PR6 placeholder — non-N

Read a file from disk into a ``Fetched`` value. Args: path: Path to the file. Tilde and relative paths are accepted; both are

Route a ``Fetched`` payload through the right format helper.

Three-level tree: root ├── a │ ├── a1 │ └── a2 └── b

Render a JSON-schema-ish description for resolver instructions. Cases handled: 1. ``Annotated[X, ...]`` — peel via ``__metadata__`` and recu

Collapse runs of horizontal whitespace; keep paragraph breaks. Preserves single and double newlines (the markdown-paragraph signal) but colla

Apply NFKC + ligature/smart-quote normalisation + control-char drop. Order matters: NFKC first (so e.g. fullwidth digits collapse to ASCII),

Dispatch on the input variant; return (markdown, source metadata).

Fetch arXiv metadata and PDF bytes for a single paper. Args: id_or_url: ArXiv id, ``arXiv:`` prefixed string, or full ``arxiv

GET ``url`` and return the body as ``Fetched``. Streams the response so we can short-circuit on payloads larger than ``max_bytes`` without bu

Convert an HTML document into markdown. Args: html: Raw HTML source as a string. Pass already-decoded text — the fetch layer

Convert PDF bytes to a plain-text/markdown string. PyMuPDF returns plain text rather than rich markdown — there is no structural tree (headin

Return ``(input_annotation, cfg_type)`` for a flow function. ``input_annotation`` is returned as-is — it may be a discriminated- union alias

Peel ``T | None`` / ``Optional[T]`` to return the inner T.

Drop consecutive duplicate lines. Useful for killing repeated PDF page headers/footers ("Page 3 of 12", journal banners) without touching leg

Return hooks in run order: memory hooks first (PR6), then extras.

Merge multiple `RunHooks` into one (the SDK takes a single instance).

Parse ``natural_language`` into ``(input_obj, cfg_obj)`` for ``target_flow``. Args: natural_language: User-supplied free-form description

Build `RunConfig` + composed hooks, run the agent, return final output. Args: agent: The Agents SDK ``Agent`` to invoke. input: P

Render the system instructions, appending ``extra`` if provided.

Concatenate metadata + content into the prompt the agent sees.

Root-to-node path. Empty if `node_id` is not in the tree.

Set up a logger with consistent formatting and optional colors. Args: name: Logger name (defaults to 'quantmind') level: Logging

Return a UTC-aware datetime equivalent to ``dt``. Naive inputs are *interpreted* as UTC (we do not guess local time). Aware inputs are conver

No-op stub. PR6 writes a trajectory record under ``<memory_dir>/runs/``. Kept as a real call site (rather than commented-out) so PR6 changes

Default: title + summary. Override per domain if needed.

Format the log record with colors.

Time elapsed since ``as_of``. Defaults ``now`` to ``utcnow()``.

True iff the item came from an LLM flow (vs hand-curated).

Depth-first traversal starting at the root.

Return a copy with extra tags appended (frozen-friendly). Duplicates are skipped so the operation is idempotent.

Strip common decorations from a user-supplied DOI string.

Convert Crossref's ``date-parts: [[YYYY, MM, DD]]`` to a UTC datetime. Crossref returns date-parts arrays where missing components are simply

Get a logger instance with QuantMind formatting and optional colors. Args: name: Logger name (usually __name__) level: Optional l

Resolve and pretty-print the result without invoking the flow.

Initialize the colored formatter. Args: *args: Positional arguments passed to parent Formatter use_color: Whether to

Configure global logging settings for QuantMind. Args: level: Global logging level use_color: Whether to use colors (auto-detect

Create a demo logger to show color capabilities. Returns: Demo logger instance

Return the canonical string the store should embed for this item. Flatten subclasses: typically ``summary + key attrs``. Tree subclas

Default: root node's embedding text. Override per domain if needed.

Alias for ``errors`` to mirror ``successes`` for symmetry.