routing

Task-to-queue routing.

class RouterCopy Anchor Link

Resolves the queue for a task name.

Precedence (highest first):

1. queue= passed to task.options(...) at enqueue time
2. queue= given to the @app.task decorator
3. routing rules configured on the application (this class)
4. the application's default queue

Rules are either a mapping of glob patterns to queue names, evaluated in insertion order (\{"app.images.*": "images"\}), or a callable returning a queue name or None.

__init__(routes: Routes, default: str) -> NoneCopy Anchor Link

resolve(task_name: str, decorator_queue: str | None, call_queue: str | None) -> strCopy Anchor Link

route(task_name: str) -> str | NoneCopy Anchor Link

Queue selected by routing rules, or None if no rule matches.