IDDQueue¶

IDDQueue provides a synchronous PostgreSQL broker and Results backend for Dramatiq. It uses Psycopg 3, JSONB, LISTEN/NOTIFY and session advisory locks, without an ORM or a separate broker service. Delivery is at least once: actors and callbacks must be idempotent.

One queue table stores messages and results; coordination, deduplication, queue control, attempts and schedules use separate tables. Notifications wake workers, which claim authoritative rows; startup and idle recovery also scan storage. Fixed interval scheduling polls due rows. Transactional producers can use a synchronous or asynchronous caller-owned Psycopg connection.

Start here¶

Follow the step-by-step walkthrough to install the published RC, prepare PostgreSQL, start a worker and retrieve your first result. Each stage includes manual steps and commands.

Maintainers can edit and deploy this site or follow the PyPI publishing guide.

Contents¶

• Get Started
• Migration from dramatiq-pg
• FastAPI integration
• User Guide
• Detailed recipes
• API Reference
• Deployment Guide
• Compatibility and support
• Contributing
• 0.13.0 release notes
• Release checks
• IDDQueue changelog
• Historical upstream changelog
• Why PostgreSQL

Source and issues are public. The 0.13.0 release is available on PyPI. This fork preserves DALIBO's PostgreSQL LICENSE and upstream credits in README.