janbjorge/pgqueuer

Health v2 · maintenance only

Adoption not part of the score

1519 stars · 35 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

PgQueuer is a Python library that turns an existing PostgreSQL database into a background job and task queue using FOR UPDATE SKIP LOCKED and LISTEN/NOTIFY. It supports transactional enqueueing, cron-style recurring tasks, observability via Prometheus metrics and tracing, and an in-memory mode for testing.

Use cases

• run background jobs from a Python app without a separate message broker
• enqueue tasks in the same transaction as database writes
• schedule recurring cron-style jobs in PostgreSQL
• process emails or notifications asynchronously with asyncio workers
• add a job queue to an existing PostgreSQL stack with minimal infrastructure
• test job processing logic without a real database

When to choose

• you already run PostgreSQL and want a queue with no extra infrastructure
• you need transactional consistency between your data and enqueued jobs
• your workload fits a single PostgreSQL database and asyncio workers
• you want instant job dispatch via LISTEN/NOTIFY with a polling fallback

When to avoid

• you need very high throughput beyond what a single PostgreSQL instance can handle
• you require multi-broker features like complex routing or cross-region replication
• your stack does not use PostgreSQL or Python 3.10+

Facets

library · maturity active

message-queue scheduling workflow-automation monitoring databases backend developer-tools python windows postgresql asyncio job-queue task-queue background-jobs listen-notify skip-locked cron-scheduling prometheus-metrics automation linux macos docker

Member repositories

For agents

markdown · JSON · MCP: product_card(name="janbjorge/pgqueuer")