This document describes the current stable version of Celery (5.4). For development docs, go here.

Task Routing.

Contains utilities for working with task routers, (task_routes).


Creates a router out of a dict.

class, queues=None, create_missing=False, app=None)[source]

Route tasks based on the task_routes setting.

lookup_route(name, args=None, kwargs=None, options=None, task_type=None)[source]
query_router(router, task, args, kwargs, options, task_type)[source]
route(options, name, args=(), kwargs=None, task_type=None)[source][source]

Expand the task_routes setting.