Index

A | B | C | D | E | F | G | I | J | L | M | N | P | Q | R | S | T | U | W

---

A

AlreadyRegistered AMQP_CONSUMER_QUEUE (in module celery.conf) AMQP_EXCHANGE (in module celery.conf) AMQP_ROUTING_KEY (in module celery.conf) AsynchronousMapTask (class in celery.task)

AsyncResult (class in celery.result) autodiscover() (celery.registry.TaskRegistry method) (in module celery.discovery)

B

backend (celery.result.AsyncResult attribute) (celery.result.BaseAsyncResult attribute) Backend (class in celery.backends.cache) (class in celery.backends.database) (class in celery.backends.tyrant)

BaseAsyncResult (class in celery.result) BaseBackend (class in celery.backends.base)

C

celery.backends (module) celery.backends.base (module) celery.backends.cache (module) celery.backends.database (module) celery.backends.tyrant (module) celery.conf (module) celery.discovery (module) celery.log (module) celery.managers (module) celery.messaging (module)

celery.platform (module) celery.registry (module) celery.result (module) celery.task (module) celery.timer (module) celery.worker (module) check() (celery.platform.PIDFile method) cleanup() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method)

D

DAEMON_CONCURRENCY (in module celery.conf) DAEMON_LOG_FILE (in module celery.conf) DAEMON_LOG_LEVEL (in module celery.conf) DAEMON_PID_FILE (in module celery.conf) daemonize() (in module celery.platform) date_done (TaskMeta attribute) default_backend (in module celery.backends) DefaultBackend (class in celery.backends) delay() (celery.task.Task class method) (PeriodicTaskMeta method)

delay_task() (celery.messaging.TaskPublisher method) (in module celery.task) delay_task_in_set() (celery.messaging.TaskPublisher method) delete_expired() (celery.managers.TaskManager method) DeleteExpiredTaskMetaTask (class in celery.task) discard_all() (in module celery.task) dmap() (in module celery.task) dmap_async() (in module celery.task)

E

emergency_error() (in module celery.log) EMPTY_MSG_EMIT_EVERY (in module celery.conf) EmptyQueue EventTimer (class in celery.timer) execute() (celery.worker.TaskWrapper method)

execute_remote() (in module celery.task) execute_using_pool() (celery.worker.TaskWrapper method) ExecuteRemoteTask (class in celery.task) extend_kwargs_with_logging() (celery.worker.TaskWrapper method)

F

filter_types() (celery.registry.TaskRegistry method) find_related_module() (in module celery.discovery)

from_message() (celery.worker.TaskWrapper class method)

G

get() (celery.result.BaseAsyncResult method) get_all() (celery.registry.TaskRegistry method) get_all_expired() (celery.managers.TaskManager method) get_all_periodic() (celery.registry.TaskRegistry method) get_all_regular() (celery.registry.TaskRegistry method) get_backend_cls() (in module celery.backends) get_consumer() (celery.task.Task method) get_default_backend_cls() (in module celery.backends) get_logger() (celery.task.Task method) get_pid() (celery.platform.PIDFile method) get_publisher() (celery.task.Task method) get_result() (celery.backends.base.BaseBackend method) (celery.backends.cache.Backend method) (celery.backends.database.Backend method) (celery.backends.tyrant.Backend method)

get_status() (celery.backends.base.BaseBackend method) (celery.backends.cache.Backend method) (celery.backends.database.Backend method) (celery.backends.tyrant.Backend method) get_task() (celery.managers.TaskManager method) (celery.registry.TaskRegistry method) get_waiting_tasks() (celery.managers.PeriodicTaskManager method)

I

is_done() (celery.backends.base.BaseBackend method) (celery.backends.cache.Backend method) (celery.backends.database.Backend method) (celery.backends.tyrant.Backend method) (celery.managers.TaskManager method) (celery.result.BaseAsyncResult method) (in module celery.task)

iterate() (celery.task.TaskSet method)

J

jail() (in module celery.worker) join() (celery.task.TaskSet method)

L

last_run_at (PeriodicTaskMeta attribute) LOG_FORMAT (in module celery.conf)

LOG_LEVELS (in module celery.conf)

M

map() (celery.task.TaskSet class method) map_async() (celery.task.TaskSet class method) mark_as_done() (celery.backends.base.BaseBackend method) (in module celery.task)

mark_as_failure() (celery.backends.base.BaseBackend method) (in module celery.task) mark_as_retry() (celery.backends.base.BaseBackend method)

N

name (PeriodicTaskMeta attribute) NoProcessConsumer (class in celery.messaging)

NotRegistered

P

PeriodicTask (class in celery.task) PeriodicTaskManager (class in celery.managers) PeriodicTaskMeta (built-in class)

PIDFile (class in celery.platform) prepare_result() (celery.backends.base.BaseBackend method)

Q

QUEUE_WAKEUP_AFTER (in module celery.conf)

R

ready() (celery.result.BaseAsyncResult method) register() (celery.registry.TaskRegistry method) remote_execute() (celery.task.TaskSet class method) remove() (celery.platform.PIDFile method) remove_pidfile() (in module celery.platform) requeue_task() (celery.messaging.TaskPublisher method) result (celery.result.BaseAsyncResult attribute) (TaskMeta attribute)

run() (celery.task.ExecuteRemoteTask method) (celery.task.Task method) (celery.task.TaskSet method) (celery.worker.TaskDaemon method) run_periodic_tasks() (celery.worker.TaskDaemon method)

S

schedule_retry_tasks() (celery.worker.TaskDaemon method) setup_logger() (in module celery.log) status (celery.result.BaseAsyncResult attribute) (TaskMeta attribute) store_result() (celery.backends.base.BaseBackend method) (celery.backends.cache.Backend method) (celery.backends.database.Backend method) (celery.backends.tyrant.Backend method) (celery.managers.TaskManager method)

successful() (celery.result.BaseAsyncResult method)

T

Task (class in celery.task) task (PeriodicTaskMeta attribute) task_id (celery.result.AsyncResult attribute) (TaskMeta attribute) (celery.result.BaseAsyncResult attribute) TASK_STATUS_DONE (built-in variable) TASK_STATUS_FAILURE (built-in variable) TASK_STATUS_PENDING (built-in variable) TASK_STATUS_RETRY (built-in variable) TASK_STATUSES (built-in variable) TASK_STATUSES_CHOICES (built-in variable) TaskConsumer (class in celery.messaging) TaskDaemon (class in celery.worker) TaskManager (class in celery.managers) TaskMeta (built-in class)

TaskPublisher (class in celery.messaging) TaskRegistry (class in celery.registry) TaskRegistry.AlreadyRegistered TaskRegistry.NotRegistered tasks (in module celery.registry) TaskSet (class in celery.task) TaskWrapper (class in celery.worker) tick() (celery.timer.EventTimer method) (celery.timer.TimeoutTimer method) TimeoutError TimeoutTimer (class in celery.timer) total_run_count (PeriodicTaskMeta attribute) TT_HOST (in module celery.backends.tyrant) TT_PORT (in module celery.backends.tyrant)

U

UnknownTask unregister() (celery.registry.TaskRegistry method)

W

wait() (celery.result.BaseAsyncResult method) wait_for() (celery.backends.base.BaseBackend method)

write() (celery.platform.PIDFile method)