Task Registry - celery.registry¶

celery.registry

class celery.registry.TaskRegistry¶

Site registry for tasks.

exception AlreadyRegistered¶

The task is already registered.

exception TaskRegistry.NotRegistered¶

The task is not registered.

TaskRegistry.autodiscover()¶

Autodiscovers tasks using celery.discovery.autodiscover().

TaskRegistry.filter_types(type)¶

Return all tasks of a specific type.

TaskRegistry.get_all()¶

Get all task types.

TaskRegistry.get_all_periodic()¶

Get all periodic task types.

TaskRegistry.get_all_regular()¶

Get all regular task types.

TaskRegistry.get_task(name)¶

Get task by name.

TaskRegistry.register(task, name=None)¶

Register a task in the task registry.

Task can either be a regular function, or a class inheriting from celery.task.Task.

Parameter:	name – By default the Task.name attribute on the task is used as the name of the task, but you can override it using this option.
Raises AlreadyRegistered:
	if the task is already registered.

TaskRegistry.unregister(name)¶

Unregister task by name.

Parameter:	name – name of the task to unregister, or a celery.task.Task class with a valid name attribute.
Raises celery.exceptions.NotRegistered:
	if the task has not been registered.