Tasks Worker Documentation
Start with the broker matrix: the broker you pick decides which guarantees you get.
Brokers
- broker/broker-matrix.md: which broker gives which guarantees (persistence, multi-node, distributed locks, cluster-wide concurrency).
- broker/technical.md: LocalBroker design (
BaseManagerserver process, reuse of a live sibling's server, startup and reconnect). - broker/setup_before_uvicorn.md: initialising the broker before the web server starts.
- broker/topic-subscription.md: what
topics=['*']resolves to, and the bootstrap deadlock it used to cause (#26). - broker/orphan-recovery.md: reclaiming messages left in flight by a worker that died mid-task, and why an unreaped one silently wedges a topic's concurrency.
- ../src/broker/README_RABBITMQ.md: RabbitMQ broker usage and topology.
Running tasks
- orchestration.md: chaining, serialised fan-out (per-topic concurrency limits), and completion joins over parent/child task trees.
- jinja_template_globals.md:
task_submit_urland the JS globals used to trigger tasks from a page.
Operations
- observability.md: every Prometheus gauge, and why the names are a public interface.
- grafana/dashboard.json: Grafana dashboard for those gauges.
- WINDOWS_COMPATIBILITY.md: running the LocalBroker on Windows (
spawn).
Archived plan/roadmap documents (formerly docs/old/) and the pre-broker implementation (formerly
old/) were removed in 0.3.310; retrieve them from git history if needed. If you find a stale
reference, open an issue.