Task Registry - celery.registry¶

celery.registry

exception celery.registry.AlreadyRegistered¶

The task is already registered.

exception celery.registry.NotRegistered¶

The task is not registered.

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(task_name)¶

Get task by name.

TaskRegistry.register(task, 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:	task_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(task_name)¶

Unregister task by name.

Parameter:	task_name – name of the task to unregister.
Raises NotRegistered:
	if the task has not been registered.