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 Managers, when to use a TaskManager, a TaskConsumer or a TaskScheduler, and what each one does in a FastAPI app.
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 Dependencies — share a database manager, an HTTP client or any other resource across task runs.
Extending the FastAPI App, add your own routes to the task manager app and inject the same dependencies into them.
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.