multi-source data connector orchestration with incremental sync
Airweave implements a source connector architecture that abstracts heterogeneous data sources (Google Docs, Linear, Intercom, Trello, etc.) through a unified interface. Each connector implements OAuth integration via an Auth Provider System, handles incremental sync using cursor-based tracking to avoid re-processing, and manages token refresh lifecycle. The Temporal Workflow System orchestrates sync jobs with configurable schedules (one-time, recurring, continuous), while the Entity Processing Pipeline streams entities through a queue with backpressure handling and concurrency controls to prevent source API throttling.
Unique: Uses a Factory Pattern with Source Connector Architecture to abstract 8+ heterogeneous APIs behind a unified interface, combined with Temporal Workflow System for reliable job orchestration and cursor-based incremental sync to avoid redundant API calls. The Entity Processing Pipeline implements stream-based queue management with backpressure to handle high-volume syncs without overwhelming source APIs.
vs alternatives: Handles incremental sync and token lifecycle management natively (vs. Langchain's basic document loaders), and provides workflow-level scheduling with Temporal (vs. simple cron-based approaches in Llama Index)
semantic search with vespa-backed vector retrieval and agentic ranking
Airweave implements a Search System built on Vespa for distributed vector similarity search across indexed entities. The search pipeline accepts natural language queries, converts them to embeddings, and retrieves candidates using Vespa's ranking framework. The Agentic Search capability allows AI agents to refine queries iteratively — agents can inspect initial results, reformulate queries, and re-rank results based on relevance signals. The search operations pipeline supports hybrid search (combining vector similarity with BM25 keyword matching) and filters by collection, source, and metadata breadcrumbs to scope results to relevant document hierarchies.
Unique: Implements Agentic Search as a first-class capability where agents can iteratively refine queries and re-rank results, combined with Vespa's distributed ranking framework for hybrid vector+keyword search. Breadcrumb metadata enables hierarchical filtering (e.g., search only within specific document trees), which is rare in commodity RAG systems.
vs alternatives: Vespa-backed search provides sub-100ms latency at scale vs. Pinecone's higher latency for complex filtering, and agentic search refinement is native (vs. requiring custom agent loops in LangChain)
frontend dashboard for collection management, sync monitoring, and usage analytics
Airweave provides a web-based Dashboard with React frontend (state management via Zustand) for managing collections, viewing sync status, and monitoring usage. The Collection Management UI enables creating/editing collections and managing source connections. The dashboard displays sync progress (entities processed, errors, duration) and allows triggering manual syncs. Real-Time Updates and SSE enable live progress updates without polling. The Usage Limits and Billing UI shows API usage, sync counts, and billing status. The Application Structure and Routing uses React Router for navigation between dashboard sections. OAuth Callback Flow is handled transparently in the UI for source connection setup.
Unique: Provides a comprehensive dashboard with real-time sync monitoring via SSE and Zustand-based state management, enabling operators to monitor and manage syncs without CLI or API knowledge. OAuth flow is integrated directly into the UI for seamless source connection setup.
vs alternatives: Real-time updates via SSE are more responsive than polling-based dashboards, and integrated OAuth flow is simpler than requiring separate OAuth setup
self-hosted deployment with docker and postgresql/qdrant configuration management
Airweave supports self-hosted deployment via Docker containers. The Docker and Deployment documentation provides Dockerfiles for backend, frontend, and worker services. Configuration Management via environment variables and YAML files (dev.integrations.yaml, prd.integrations.yaml, self-hosted.integrations.yaml) enables customization of OAuth providers, storage backends, and feature flags. The backend service uses PostgreSQL for relational data and Qdrant for vector storage; both can be self-hosted or cloud-managed. The start.sh script automates local setup with Docker Compose. Self-hosted deployments have full control over data residency and can customize integrations (e.g., add custom OAuth providers).
Unique: Provides comprehensive self-hosted deployment with Docker Compose and environment-based configuration, enabling full customization of OAuth providers and storage backends. Configuration is environment-specific (dev, production, self-hosted) with separate YAML files for each.
vs alternatives: Self-hosted option provides data residency control vs. cloud-only platforms, and environment-based configuration enables easy customization vs. hardcoded integrations
incremental sync with cursor-based pagination and change detection
Airweave implements Incremental Sync and Cursors to avoid re-processing all entities on every sync. Source connectors track a cursor (e.g., last_modified_timestamp, page_token) that marks the point of the last successful sync. On subsequent syncs, the connector fetches only entities modified after the cursor, reducing API calls and processing time. The Sync System stores cursors in PostgreSQL and updates them after each successful sync. Change detection is source-specific: some sources provide modification timestamps, others use pagination tokens. The Entity Processing Pipeline processes only new/changed entities, making incremental syncs much faster than full syncs.
Unique: Implements cursor-based incremental sync with source-specific change detection, stored in PostgreSQL for durability. Cursor tracking enables efficient syncs by fetching only new/changed entities, reducing API calls and processing time.
vs alternatives: Cursor-based incremental sync is more efficient than full re-indexing on every sync, and source-specific cursor handling is more flexible than generic timestamp-based approaches
multi-tenant vector storage with qdrant and postgresql dual-write
Airweave uses a Qdrant Multi-Tenant Architecture where each organization's vectors are isolated in separate Qdrant collections, with metadata stored in PostgreSQL. The QdrantDestination API implements a write path that batches entity embeddings and writes them to Qdrant with error handling and retry logic. PostgreSQL stores the relational schema (collections, source connections, sync metadata) and serves as the source of truth for entity relationships and breadcrumbs. The dual-write pattern ensures consistency: vectors in Qdrant are indexed for search, while PostgreSQL maintains referential integrity and enables complex queries (e.g., 'find all entities from source X synced after timestamp Y').
Unique: Implements explicit multi-tenant isolation via Qdrant collection-per-organization pattern combined with PostgreSQL relational schema for metadata, enabling both vector search and complex SQL queries on entity relationships. The QdrantDestination API abstracts write complexity with batching and error handling.
vs alternatives: Dual-write to Qdrant + PostgreSQL enables richer queries than vector-only systems (e.g., 'find entities from source X synced after date Y'), and collection-per-tenant isolation is more explicit than namespace-based approaches in Pinecone
mcp server integration for agent-native search tool exposure
Airweave exposes search capabilities as a Model Context Protocol (MCP) server, allowing Claude and other MCP-compatible agents to invoke search as a native tool. The MCP Server Architecture defines a search tool schema that agents can call with natural language queries and filters. The MCP Search Tool handles query parsing, invokes the underlying Search System (Vespa-backed), and returns results in a format agents can reason about. This enables agents to autonomously search the knowledge base without explicit function-calling code — the agent sees search as a first-class capability in its tool registry.
Unique: Implements MCP Server as a first-class integration point, allowing agents to invoke search as a native tool without custom function-calling code. The MCP Search Tool schema is pre-defined and discoverable by agents, enabling autonomous search without explicit agent prompting.
vs alternatives: Native MCP integration is simpler than custom OpenAI function calling (no schema definition in agent code), and enables broader LLM compatibility (Claude, open-source models) vs. vendor-specific approaches
embeddable connect widget for oauth-based source connection ui
Airweave provides a Connect Widget — an embeddable React component that handles the full OAuth flow for connecting sources. The Connect Widget Architecture manages OAuth Callback Flow internally: it initiates OAuth with the source platform, handles the redirect callback, exchanges the authorization code for tokens, and stores credentials securely. The Connect Client SDKs (JavaScript/TypeScript) expose a simple API for embedding the widget in external applications. Connect Session Management tracks widget state (pending, authenticated, error) and enables parent applications to listen for connection events. This eliminates the need for applications to implement OAuth flows themselves.
Unique: Provides a fully encapsulated OAuth flow as a React component, handling token exchange and secure storage without exposing credentials to the parent application. The Connect Session Management pattern enables event-driven integration with parent applications.
vs alternatives: Simpler than implementing OAuth manually (vs. building custom flows), and more secure than passing credentials through the browser (credentials stored server-side in PostgreSQL)
+5 more capabilities