celery.app.registry

Registry of available tasks.

class celery.app.registry.TaskRegistry[源代码]

Map of registered tasks.

exception NotRegistered

The task is not registered.

filter_types(type)[源代码]
periodic()[源代码]
register(task)[源代码]

Register a task in the task registry.

The task will be automatically instantiated if not already an instance. Name must be configured prior to registration.

regular()[源代码]
unregister(name)[源代码]

Unregister task by name.

参数:

name (str) -- name of the task to unregister, or a celery.app.task.Task with a valid name attribute.

抛出:

celery.exceptions.NotRegistered -- if the task is not registered.