Safely run async code in Streamlit (handles uvloop).

FastMCP Client.call_tool returns an object with `.data`; tolerate both.

Poll until terminal status or deadline. Returns the final response.

Convert a pandas DataFrame (yfinance financials) to a clean dict.

Generate error talk data structure

Extract the first JSON object from agent output.

Finalize crawling statistics

file.py -> /Users/you/project/file.py

Parse structured or natural chat context into the mutable Streamlit context dict.

Base model id for OpenAI-compatible chat on Token Factory (override via CHAT_BASE_MODEL or BASE_MODEL_NAME).

Create default stock data structure with the given symbol.

Create a new transaction in Couchbase.

Create a tweet using Composio's Twitter toolkit

Define and create research and memory agents

Delete specific files from the vector store.

Ensure Couchbase connection is established.

Generate embedding using Nebius AI

Read the generated post text.

Fetch sell-side analyst price targets and recommendation consensus. Returns: Dict with current price, mean/low/high targets, upside

Get decision by transaction ID.

Fetch recent insider buy/sell transactions for a ticker. Insider buying is a bullish signal; heavy insider selling is bearish. Args:

Get synchronous Couchbase scope (for Streamlit).

Get a transaction by ID.

Read the guideline text.

Load dataset entries filtered by a specific scope value.

Load conferences from Couchbase

Load the full dataset index.

Load few-shot examples from the dataset based on the scope field. - scope contains 'train_generator' -> used as post text examples - scope co

Load JSON from a file, returning default if the file doesn't exist.

Load .env from the app directory without overriding active session keys.

Run LLM judge evaluation with Okahu/Monocle tracing.

Make a request to the Exa API

Canonical key for entity resolution — lowercased, legal suffixes stripped.