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

celery.app.routes

Task Routing.

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

class celery.app.routes.MapRoute(map)[source]

Creates a router out of a dict.

class celery.app.routes.Router(routes=None, queues=None, create_missing=False, app=None)[source]

Route tasks based on the task_routes setting.

expand_destination(route)[source]
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]
celery.app.routes.expand_router_string(router)[source]
celery.app.routes.prepare(routes)[source]

Expand the task_routes setting.