Skip to content

Tasks Worker Documentation

Current technical documentation:

  • Orchestration: orchestration.md — chaining, serialized fan-out (per-topic concurrency limits), and completion joins over parent/child task trees.
  • Broker: tasks_worker/docs/broker/technical.md — LocalBroker design, startup, leader/follower behavior, usage, and testing.
  • Broker matrix: broker/broker-matrix.md — which broker for which guarantees (e.g. cluster-wide per-topic concurrency → postgres).

Archived (old, not up-to-date) documents have been moved under tasks_worker/docs/old/. Refer to that directory if you need historical plans/roadmaps or migration notes.

Quick start for broker initialization:

from fastpluggy_plugin.tasks_worker.broker.factory import setup_broker

# Ensure broker is ready before starting the web server
broker = setup_broker()

Notes: - Prefer the technical doc over older plan/roadmap-style files. - If you find a stale reference, check the old/ archive or open an issue to update the link.