Exactly Once Python Packages

queen-mq

High-performance transactional message broker for applications that need an ordered stream per entity.

redis-message-queue

Lightweight Python message queuing with Redis and built-in publish-side deduplication.

fastapi-idempotency-key

Robust, Stripe-grade idempotency key middleware & decorator for FastAPI / Starlette with pluggable backends (Memory, SQLite, Redis)

pyclink

Stream processing for Kafka pipelines that must stay correct when processes die. SQL, event time, keyed state and exactly-once delivery in modern C++: one process on a laptop, embedded, or a cluster. No JVM.

aura-guard

Exactly-once + circuit breaker for agent tool calls (loops, retries, duplicate side effects)

airlock-sdk

Make AI agent actions exactly-once and human-approvable, with a tamper-evident audit. pip install airlock-sdk

chowki

chowki — durable execution for LLM agents: crash recovery, step memoization, human approval gates, secret redaction, and token budgets. Decorators, not infrastructure. No server, SQLite-backed.

karmasakshi-protocol

Verified Effect Commit Protocol for AI agents — seal the intended effect, witness the actual outcome.

holdpoint

A durable approval queue for agent actions: pause the call, let a human review or patch it, then run it exactly once. Zero dependencies, SQLite persistence, immutable audit.

gcp-pubsub-idempotency

Exactly-once processing for at-least-once Google Cloud Pub/Sub — a tiny Python idempotency gateway for Cloud Functions & Cloud Run push handlers. Leases, fencing tokens; Datastore/Redis/SQL backends.

justonce

Make side effects happen exactly once. Idempotency keys, atomic claims, and an effect ledger for code that charges money, sends messages, or mutates state.

kafka-streamka

Kafka Streams API implementation for Python - built upon synchronous producer and consumer

ballast-py

Durable backend correctness for single-machine Python on one SQLite file with transactional outbox, exactly-once jobs, forward-only migrations. No dependencies.

durabl

Durable execution for AI agent workflows in Python. Crash mid-run and resume exactly where you left off. SQLite, no services.