pgqueuer
Pgqueuer is a Python library leveraging PostgreSQL for efficient job queuing.
Decision gist · record as of 2026-08-14
Yes. PgQueuer is actively maintained, permissively licensed (MIT), has no known vulnerabilities, and solves a real problem: if you already run PostgreSQL, you can eliminate a separate message broker and gain transactional consistency. The low install friction and support for modern Python versions (3.10+) make it straightforward to adopt. Start with the in-memory mode for testing, then move to PostgreSQL for production.AI-flagged interpretation of the facts on this page — verify before relying
Before you install
- Requires PostgreSQL 12+ and an existing database connection; jobs are durable only when backed by a real PostgreSQL database (in-memory mode is for testing only).
- Low friction: pure Python wheel with seven runtime dependencies.
- Active maintenance—last commit 2026-08-01, released 2026-07-27, 1517 GitHub stars.
License · maintenance · safety
MIT License (permissive) — MIT licensed (permissive). No restrictions on commercial or proprietary use; you may modify and distribute freely under the same license.
last release 2026-07-27 (18 days) · last repo commit 2026-08-01 · 1,517 stars
0 known vulnerabilities (OSV.dev, 2026-08-14) · 261,920 downloads/mo, #8,380 on PyPI
Alternatives
Verify before relying
pip install pgqueuer
from pgqueuer import PgQueuer
from pgqueuer.db import AsyncpgDriver
from pgqueuer.models import Job
async def main():
pgq = PgQueuer(AsyncpgDriver(connection))
@pgq.entrypoint("my_job")
async def process(job: Job):
print(f"Processing: {job}")
await pgq.qm.queries.enqueue("my_job", b"payload")- Whether the dashboard (pgq dashboard command) requires additional dependencies or setup beyond the base install.
- Performance characteristics and throughput limits under high concurrency or large job volumes.
- Exact retry and backoff behavior when jobs fail, and whether custom executors are required for production retry strategies.
- Which database drivers (asyncpg, psycopg async/sync) are included or require separate installation.
What it is and what it does
PgQueuer is a Python job queue library that uses your PostgreSQL database as the backing store instead of requiring a separate message broker. You define job handlers as async functions decorated with @pgq.entrypoint, enqueue jobs from your application code, and run workers via the CLI. Jobs live in the same database as your application data, so you can enqueue a job and insert related records in a single transaction—if the transaction rolls back, the job never lands, eliminating dual-write drift.
The library uses PostgreSQL's LISTEN/NOTIFY for instant job dispatch and FOR UPDATE SKIP LOCKED to ensure jobs are never double-processed. It supports cron-style scheduling, deferred execution, per-entrypoint concurrency limits, Prometheus metrics, and a live dashboard. For testing and prototyping, PgQueuer.in_memory() provides a drop-in replacement that runs without a database. Runtime dependencies are anyio, croniter, pydantic, pydantic-settings, tabulate, typer, and uvloop.
Use it for
- Enqueue background tasks transactionally alongside your business data in a single database transaction.
- Schedule recurring jobs using cron expressions without deploying a separate scheduler service.
- Run integration tests and prototypes using the in-memory queue adapter without a database.
- Monitor queue health and job throughput in real time using the built-in dashboard.
- Process jobs with guaranteed ACID semantics because the queue and your application data share the same database.
Worth the install?
AI-flagged interpretation of the facts on this page. Verify before relying on it.
Yes.
PgQueuer is actively maintained, permissively licensed (MIT), has no known vulnerabilities, and solves a real problem: if you already run PostgreSQL, you can eliminate a separate message broker and gain transactional consistency. The low install friction and support for modern Python versions (3.10+) make it straightforward to adopt. Start with the in-memory mode for testing, then move to PostgreSQL for production.
Install
pgqueuer on PyPI
Before you install
Low friction: pure Python wheel with seven runtime dependencies. Active maintenance—last commit 2026-08-01, released 2026-07-27, 1517 GitHub stars. Targets Python 3.10+.
Requires PostgreSQL 12+ and an existing database connection; jobs are durable only when backed by a real PostgreSQL database (in-memory mode is for testing only).
License in practice
MIT licensed (permissive). No restrictions on commercial or proprietary use; you may modify and distribute freely under the same license.
Quickstart
pip install pgqueuer
from pgqueuer import PgQueuer
from pgqueuer.db import AsyncpgDriver
from pgqueuer.models import Job
async def main():
pgq = PgQueuer(AsyncpgDriver(connection))
@pgq.entrypoint("my_job")
async def process(job: Job):
print(f"Processing: {job}")
await pgq.qm.queries.enqueue("my_job", b"payload")Verify before relying
- Whether the dashboard (pgq dashboard command) requires additional dependencies or setup beyond the base install.
- Performance characteristics and throughput limits under high concurrency or large job volumes.
- Exact retry and backoff behavior when jobs fail, and whether custom executors are required for production retry strategies.
- Which database drivers (asyncpg, psycopg async/sync) are included or require separate installation.
Package facts
| License | MIT License permissive |
| Python support | Supports the current Python release >=3.10 |
| Install friction | Low. Pure-Python wheel |
| Runtime dependencies | 7 packagesanyiocroniterpydantic-settingspydantictabulatetyperuvloop |
| Maintenance | Actively maintained 18 days since the last release |
| Last repo commit | |
| First released | |
| Downloads | 261,920 / month, #8,380 on PyPI 30-day window, as of 2026-08-14 |
| Known vulnerabilities | None known OSV.dev, checked 2026-08-14 |
| Classifiers | Development Status :: 5 - Production/StableEnvironment :: Web EnvironmentFramework :: AsyncIOIntended Audience :: DevelopersLicense :: OSI Approved :: MIT LicenseNatural Language :: EnglishOperating System :: OS IndependentProgramming Language :: PythonProgramming Language :: Python :: 3.10Programming Language :: Python :: 3.11Programming Language :: Python :: 3.12Programming Language :: Python :: 3.13Programming Language :: Python :: 3.14Topic :: DatabaseTopic :: Software Development :: Libraries :: Python ModulesTopic :: System :: Distributed ComputingTopic :: Utilities |
Evidence: pgqueuer-1.3.2-py3-none-any.whl
Tags
Let your AI agent find packages like this
Example. Real query, live index.
You found this page by searching. An agent finds it by wishing: SkillFed indexes 14,416 PyPI packages by what they can do, searchable in plain language.
wish › “postgresql job queue”
- pgqueuerPgQueuer turns PostgreSQL into a background job queue, letting you…
- saqSAQ is an async job queue framework that runs background tasks using…
- absurd-sdkPython SDK for Absurd, a PostgreSQL-based durable task execution…
Give your agent the search over MCP, or paste the wish link into any chat.
More Python Modules packages
Converts domain names between Unicode and ASCII-compatible encoding (Punycode) according to IDNA 2008 and Unicode Technical Standard 46, with security validation and broader script coverage than the standard library.
Install it if you work with internationalized domain names, need to validate domains, or use HTTP clients that depend on it transitively.
Setuptools is a Python build backend and package management tool that handles building, distributing, and installing Python packages, including support for C/C++ extension modules.
PyYAML parses and emits YAML 1.1 data format, enabling serialization and deserialization of configuration files and Python objects to and from human-readable YAML text.
Pydantic validates Python data structures against type hints, coercing and checking input at runtime to ensure it matches a declared schema.
Provides reusable metadata objects for use with PEP-593 `typing.Annotated` to express common constraints like bounds, collection sizes, and predicates on types.
Install it if you use or build libraries that need to express type constraints in a standardized, inspectable way—or if you want to annotate your own types with…
Provides runtime tools to inspect and introspect Python type annotations, enabling programmatic examination of type hints at execution time.
See also saq · faktory · rq-scheduler · arq · django-background-tasks · asyncpg · bullmq · rq · absurd-sdk · django-tasks