Tutorials¶

Step-by-step guides for using Aio Fluid in your backend applications. See the home page for installation instructions.

Workers¶

Workers are the foundational building block — async components with start/stop lifecycle management. Start here if you are new to the library.

Tasks — define tasks with the @task decorator, set priorities, scheduling, concurrency limits, and CPU-bound execution.
Task Queue App — wire tasks into a full producer/consumer application with FastAPI and Redis.
Task Broker — implement a custom broker to replace the default Redis backend.
Task Retries — automatically retry tasks on failure or when rate-limited by concurrency.
K8s Jobs — dispatch CPU-bound tasks as Kubernetes Jobs instead of local subprocesses.

Async Database — CRUD operations and migrations for Postgres using SQLAlchemy and asyncpg.

Event Dispatchers — decouple event sources from handlers for flexible async pipelines.