Cue

Cue

Per-person attention budgets for AI agents and background automations, self-hosted.

Documentation · Getting started · Agents

A code-review agent, a log-triage agent and a billing agent can all page the same engineer at 2 a.m. A LangGraph interrupt() or a Slack approve button pauses one agent; none of them knows what the others already sent. Cue sits in front of all of them as the outbound gatekeeper:

• Budgets per agent, per person. Each agent sends with its own key. Its frequency_caps limit how many messages it may send one person per period, and messages over budget are stored as suppressed with reason agent_budget. Category caps count what a person gets from every sender together.
• Quiet hours in the person's time zone. A message due inside someone's quiet hours waits until they end. Only critical messages in categories people cannot unsubscribe from break through, and each agent's max_importance caps what it may claim, so only agents you trust can use critical.
• Digests for the rest. A digest rule turns a stream of agent events into one message per window, or one per day at a local time.
• Approval for risky messages. Messages that match an agent's approval condition wait as pending_approval; a reviewer decides from a one-time link in their own notification. Agent keys can never approve.
• A reason for every outcome. Each message has a status and a status_reason, and each event records which rules matched and why. Agents connect over HTTP, the SDKs or the MCP server.

Use it as a library

No server needed: pip install cue-notify, then decide in-process, with state in a SQLite file. You send the message yourself.

from cue_notify.embedded import Gate

gate = Gate("sqlite:///cue.db", quiet_hours=("22:00", "08:00"), caps={"marketing": [("P1D", 1)]}) decision = gate.check("user-42", category="marketing", timezone="Europe/Berlin", key="sale-42") if decision.action == "send": print("sending now") gate.sent(decision) else: print(decision.action, decision.at, decision.reason) for due in gate.due(): print("sending", due.key) gate.sent(due)

check() answers send, defer (until decision.at), suppress or digest, with a reason; due() returns deferred messages and digest batches whose time has come. Quiet hours in each person's time zone, caps, cooldowns, per-sender budgets, digests and idempotency keys work as in the server; templates, channels and preference pages do not come with it. See Use Cue as a library.

The recording at the top is examples/agents-demo: from a checkout, uv run python examples/agents-demo/demo.py runs it with SQLite and the console connector.

Quick start

With Docker Compose (PostgreSQL, an API and a worker; messages go to the worker's log):

git clone https://github.com/murtazox04/Cue && cd Cue

docker compose up --build -d docker compose exec api cuectl keys create admin docker compose logs -f worker

Or with Python 3.12+ and SQLite, in a virtual environment:

python -m venv .venv && . .venv/bin/activate

pip install cue-notify export CUE_WORKER__EMBEDDED=true export CUE_CHANNELSPUSHPROVIDER=console CUE_CHANNELSSMSPROVIDER=console cuectl db upgrade && cuectl keys create admin && cuectl serve

keys create prints an API key once; keep it as CUE_API_KEY. Then follow the getting-started guide to create a template and a rule and send an event that shows up in the log, and agents to give an agent its own key and limits.

To try it without installing anything, with uv:

CUE_WORKER__EMBEDDED=true CUE_CHANNELS__PUSH__PROVIDER=console \

CUE_CHANNELSSMSPROVIDER=console uvx cue-notify serve --migrate

and, in a second terminal in the same directory (both use ./cue.db), uvx cue-notify keys create admin.

More for agents

• Agents as senders. Each agent gets its own key with a per-person attention budget, an importance ceiling and, where you want it, human approval before anything goes out. Agent keys cannot read or change people's profiles, and cannot approve anything. See agents.
• Ask a person first. Before a risky action (a refund, a deletion, a mass e-mail), an agent calls POST /v1/approvals or the request_approval MCP tool. Cue tells the reviewers on their own channels with a one-time link and reports the decision back, with bridges for LangGraph, Pydantic AI, CrewAI Flows and Dapr Agents. See approval requests.
• MCP server. uvx cue-notify mcp gives Claude, Cursor or your own agent tools to notify people and inspect delivery, under the same policy and audit trail. See AI agents (MCP).
• Screening (optional, off by default, experimental). With [screening] enabled = true and a TypeSafe API key, a decision model (Jev) reads each agent message before it is sent: pressure, deception or leaked secrets hold it for a person, and overstated importance is lowered. Built against TypeSafe's published API; not yet proven in production. Your own backend's messages are never screened.
• Coding agents. cue-hook lets OpenHands and Claude Code tell you when they finish or wait for input. See coding agents.
• Claude Code plugin. /plugin marketplace add murtazox04/Cue, then /plugin install cue@cue, adds a skill for integrating Cue into an application.

Notifications from your own backend

The same policy serves your product's own notifications. Your backend reports what happened (order.shipped, payment.failed). Cue decides whether that is worth a notification, renders it in the person's language, picks the time and the route, and hands a finished message to the delivery you connect: your own sending service through a signed webhook, or a bundled connector.

• Rules and policy in one place. JSON Logic rules map events to templates; every message, whether triggered by a rule, sent directly or broadcast, passes the same checks: unsubscribes, muted channels, frequency caps, cooldowns and quiet hours in the recipient's own time zone, checked again right before sending.
• Fewer messages. Digests turn a burst of events into one message per window or one per day at a local time, and fatigue backs off from people who stopped engaging.
• People in control. A hosted preference page (or a JSON API for your own), RFC 8058 one-click unsubscribe, and a consent ledger of every change.
• Answers. Every event records which rules matched and why; every message records its status and the reason it was suppressed or failed.

curl -X POST https://cue.example.com/v1/events \

-H "Authorization: Bearer $CUE_API_KEY" -H "Content-Type: application/json" \ -d '{"name": "order.shipped", "recipient": "customer-42", "data": {"order_id": "1001"}, "idempotency_key": "order-1001-shipped"}'

Your delivery endpoint then receives a signed, fully rendered message:

{

"id": "01a1…", "channel": "push", "address": " ", "locale": "en", "importance": "normal", "expires_at": null, "content": {"title": "Your order is on its way", "body": "Order 1001 ships today.", "url": "https://shop.example/orders/1001"}, "metadata": {"cue_message_id": "01a1…", "cue_tracking_token": "…"}, "links": {"preferences": "https://cue.example.com/preferences/…"} }

Who it's for

For teams whose agents, background jobs or product code send push, e-mail, SMS or chat messages to people, and who want the decisions (whether, when, how often, over which route, in which language) made in one place, stored, and explainable, on their own infrastructure.

Not for you (yet) if you need:

• an in-app inbox or notification feed: planned, not built;
• an admin UI: today you configure Cue through the HTTP API, the CLI and cue.toml;
• a connector Cue does not have yet. Today's are FCM, APNs, Twilio, SMTP, Amazon SES, Resend, Slack, Telegram, a signed webhook and console, plus any you write;
• a hosted service: Cue is self-hosted only;
• a visual journey builder for marketing campaigns: not planned.

See the roadmap.

Bring your own delivery

Each route (push, sms, email, ops-alerts…) is backed by a connector:

Connectors are configuration, not code changes: swap SMS vendors without touching a rule.

Also

• SDKs. pip install cue-notify-client and npm install cue-client, both with webhook signature verification. See SDKs.
• Engagement tracking. Delivered, opened, clicked, converted; client apps report with a per-message token, no API key needed.
• Broadcasts. Audience filters, resumable batches, pause/resume/cancel without double sends.
• Compliance. US texting hours and state caps for marketing texts, STOP/START replies, and opt-in records with the disclosure shown. See compliance.
• Runs on your database. An API process and a worker process (or the worker embedded in the API for small installs), with PostgreSQL or SQLite. No Redis or message broker: the durable job queue lives in the database. Schedule cuectl prune yourself for retention.
• Observable. Per-rule event outcomes, status reasons, Prometheus metrics, JSON logs.
• Docs for tools. llms.txt and AGENTS.md.

How Cue compares

| Knock, Courier, OneSignal | Hosted notification services. | You