This document describes Celery 2.4. For development docs, go here.

celery.registry

celery.registry

Registry of available tasks.

copyright:
  1. 2009 - 2011 by Ask Solem.
license:

BSD, see LICENSE for more details.

class celery.registry.TaskRegistry
exception NotRegistered

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.
celery.registry.tasks = {'celery.chord_unlock': <@task: celery.chord_unlock>, 'celery.backend_cleanup': <@task: celery.backend_cleanup>, 'celery.contrib.abortable.AbortableTask': <@task: celery.contrib.abortable.AbortableTask>, 'celery.chord': <@task: celery.chord>, 'celery.ping': <@task: celery.ping>}

Global task registry.