Task Registry - celery.registry

celery.registry

class celery.registry.TaskRegistry

Site registry for tasks.

exception NotRegistered(message, *args, **kwargs)

The task is not registered.

TaskRegistry.filter_types(type)

Return all tasks of a specific type.

TaskRegistry.periodic()

Get all periodic task types.

TaskRegistry.pop(key, *args)

TaskRegistry.register(task)

Register a task in the task registry.

The task will be automatically instantiated if not already an instance.

TaskRegistry.regular()

Get all regular task types.

TaskRegistry.unregister(name)

Unregister task by name.

Parameters:

• name – name of the task to unregister, or a celery.task.base.Task with a valid name attribute.

Raises celery.exceptions.NotRegistered:  

if the task has not been registered.