Procesamiento confiable nativo en Postgres

outlabsTaskq

Una cola de tareas SQL-first para sistemas Python, con claims y settles tipados, workflows, schedules y una fachada FastAPI opcional para workers sin credenciales.

outlabsTaskq
Pre-release público · MIT

Cola de jobs en tu Postgres.

outlabsTaskq es una cola de tareas SQL-first para flotas Python: claim, fencing y retry viven en PL/pgSQL; el cliente tipado y la fachada FastAPI opcional son solo transporte.

Postgres FastAPI SKIP LOCKED Pydantic HTTP facade MIT
OutlabsTaskq mark Tu DB · Tu flota

SQL-first

Las funciones PL/pgSQL son el contrato. Python, HTTP y psql son clientes iguales.

Settles tipados

ok / already_settled / lost — un response HTTP perdido ya no tira trabajo terminado.

Fachada opcional

Workers sin credenciales de DB. Auth inyectada; outlabs-auth es opcional.

Configurable y simple

Perfiles ricos en la fila de cola; knobs minimos en el worker.

Superficie tecnica

Correctness en la base.

Claims con FOR UPDATE SKIP LOCKED

Fencing por attempt_id en cada settle

Enqueue tipado (created / existed)

Snooze y cancel sin quemar presupuesto

Limites de concurrencia por recurso

Redrive de jobs fallidos / poison

Enqueue + worker Python 3.12+
from taskq import Task, TaskQ, TaskRegistry

DOUBLE = Task(name="demo.double", queue="demo", …)
registry = TaskRegistry((DOUBLE,))

tq = TaskQ.from_dsn(DATABASE_URL, registry=registry)
result = await tq.enqueue(DOUBLE, {"value": 3})
# result.status in {"created", "existed"}

# taskq worker --dsn … --registry tasks:registry --queue demo

Estado actual

outlabsTaskq está disponible como pre-release público. Incluye el kernel SQL, cliente tipado, worker y CLI, fachada HTTP, follow-ups, workflows, schedules y autenticación opcional. La documentación vive en taskq.outlabs.io.

© 2026 OutLabs LLC. All rights reserved.