🚀 Highlights 🚀

PostgREST RPC: Enqueue Jobs over HTTP

• New fn_pgqueuer_enqueue RPC unlocks any HTTP client for job submission via PostgREST.
• docs/postgrest.md walks you end-to-end: define the function, grant least-privilege access, plug it into PostgREST, and exercise it with curl.
• Safety callouts (auth, payload limits, entrypoint whitelisting) are front and center so you can deploy responsibly.

One-Liner Constructors for Existing Connections

• PgQueuer.from_asyncpg_connection, .from_asyncpg_pool, and .from_psycopg_connection let you reuse the pools and connections you already manage—no wrapper boilerplate needed.
• Matching helpers on Queries simplify schema installs and admin scripts:

  pgq = PgQueuer.from_asyncpg_pool(pool, resources={"http": http_client})
  await pgq.run()
  

• Psycopg users only need to ensure autocommit is on when they build the connection.

Entrypoints That Receive Runtime Context

• Opt in with accepts_context=True to have PGQueuer call your entrypoints with both the job and context objects.
• Ideal for carrying tracing headers, shared HTTP clients, or any per-worker state you register in resources.

pgq = PgQueuer.from_asyncpg_pool(
    pool,
    resources={
        "http": httpx.AsyncClient(),
        "metrics": PrometheusClient(namespace="pgq"),
    },
)

@pgq.entrypoint("thumbnail", accepts_context=True)
async def build_thumbnail(job: Job, context: Context) -> None:
    http = context.resources["http"]
    metrics = context.resources["metrics"]

    metrics.counter("thumbnail_jobs_started").inc()

    payload = job.payload or {}
    image_url = payload["image_url"]

    response = await http.get(image_url)
    store_thumbnail(image_url, response.content)

    metrics.counter("thumbnail_jobs_succeeded").inc()

Operational Touch-Ups

• Fresh Postgres driver troubleshooting guide (connection hygiene, pool resets, LISTEN/NOTIFY drift) gives on-call teams a quick diagnostic checklist.
• Docker compose docs now remind you to docker compose down, keeping local Postgres containers from sticking around between test runs.

Pull requests

• Document docker compose teardown step by @janbjorge in https://github.com/janbjorge/pgqueuer/pull/476
• Improve TimedOverflowBuffer retries via dedicated RetryManager by @janbjorge in https://github.com/janbjorge/pgqueuer/pull/478
• Postgres driver troubleshooting by @janbjorge in https://github.com/janbjorge/pgqueuer/pull/485
• Add PgQueuer classmethods for connection initialization by @janbjorge in https://github.com/janbjorge/pgqueuer/pull/487
• Classmethods connection initialization queries by @janbjorge in https://github.com/janbjorge/pgqueuer/pull/488
• Adds accepts_context flag by @janbjorge in https://github.com/janbjorge/pgqueuer/pull/489
• Add PostgREST RPC integration for enqueuing jobs by @janbjorge in https://github.com/janbjorge/pgqueuer/pull/493

Full Changelog: https://github.com/janbjorge/pgqueuer/compare/v0.25.1...v0.25.2