celery.app.routes¶

Task Routing.

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

class celery.app.routes.MapRoute(map)[исходный код]¶

Creates a router out of a dict.

class celery.app.routes.Router(routes=None, queues=None, create_missing=False, app=None)[исходный код]¶

Route tasks based on the task_routes setting.

expand_destination(route)[исходный код]¶

lookup_route(name, args=None, kwargs=None, options=None, task_type=None)[исходный код]¶

query_router(router, task, args, kwargs, options, task_type)[исходный код]¶

route(options, name, args=(), kwargs=None, task_type=None)[исходный код]¶

celery.app.routes.prepare(routes)[исходный код]¶

Expand the task_routes setting.