Webhook notification configuration.

Sends webhook notifications after pipeline completion or failure.

Unified content item model from any source.

Client for OpenAI-compatible APIs.

Structured exception with stable error code.

Generates daily Markdown summaries from pre-analyzed content items.

Fetch tweets via the Apify altimis/scweet actor.

Mock AI client for testing.

AI client configuration.

Scraper backed by the GDELT 2.0 DOC API.

Scraper backed by the Google News RSS search endpoint.

Store intermediate artifacts per pipeline run.

GDELT 2.0 DOC API source configuration. Queries the key-less GDELT DOC API (https://api.gdeltproject.org/api/v2/doc/doc) for recent news arti

Google News RSS search source configuration. Builds Google News RSS search URLs (https://news.google.com/rss/search) for a query and parses t

A quota group containing one or more source categories.

Chain multiple AI clients with automatic fallback. When a provider fails with a retryable error (rate limit, auth/quota, service unavailable,

Content filtering configuration.

Manages file-based storage for configuration and state.

Manages email subscriptions and sending summaries.

High-level staged pipeline service.

A named watchlist of tickers fetched from one OpenBB provider. Each watchlist produces one news.company() call per run, so group symbols by p

Scraper for Reddit posts and comments.

Client for Azure OpenAI deployments. Uses the native AsyncAzureOpenAI client, which requires the deployment name (passed as `model`), azure_e

Analyzes content items using AI to determine importance.

OpenBB Platform source configuration. Uses the installed `openbb` SDK to fetch news and filings for a set of tickers. The SDK is an optional

Configuration for monitoring a specific subreddit.

Reddit source configuration.

Supported AI providers.

Items and selection statistics from balanced digest filtering.

Main configuration model.

Raised when configuration is missing or invalid.

GitHub source configuration.

Orchestrates the complete workflow for content aggregation and analysis.

Scraper backed by the OpenBB Platform Python SDK.

Scraper for RSS/Atom feeds.

RSS feed source configuration.

All sources configuration.

Twitter source configuration. Two modes are supported: - "apify": Use Apify scweet actor (requires APIFY_TOKEN, more reliable) - "playwri

Client for Anthropic Claude models.

Enriches high-scoring content items with background knowledge.

Email configuration for updates/subscriptions.

Client for Google Gemini models.

Scraper for GitHub events and releases.

Hacker News configuration.

Scraper for Hacker News stories with top comments.

Loaded runtime references from a Horizon codebase.

Scraper for OSS Insight trending repositories endpoint.

Resolved execution context per call.

Raised when Reddit blocks an unauthenticated JSON listing request.

Configuration for monitoring a specific Reddit user.

Configuration for monitoring a specific Telegram channel.

Telegram source configuration.

Scraper for Telegram public channels via web preview.

Fetch tweets via Playwright + Cookie using GraphQL interception (free alternative to Apify).

Factory that returns pre-built dummy clients in order.

Abstract base class for AI clients.

Abstract base class for all scrapers.

OSS Insight trending repos source configuration. Pulls top star-gain repositories from the OSS Insight public API and emits them as ContentIt

Supported information source types.

Recursive ${VAR} expansion on config dicts/lists/strings.

Retry-without-temperature path for models that deprecated temperature. Triggered by Claude Opus 4.7 on Bedrock Converse and any OpenAI-compatible