Index

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

---

Symbols

--chroot celeryd command line option --discard celeryd command line option --umask celeryd command line option --workdir celeryd command line option -c, --concurrency celeryd command line option -d, --detach, --daemon celeryd command line option -f, --logfile celeryd command line option

-g, --gid celeryd command line option -l, --loglevel celeryd command line option -p, --pidfile celeryd command line option -s, --statistics celeryd command line option -u, --uid celeryd command line option

A

acquire_pidlock() (in module celery.bin.celeryd) add() (celery.pool.TaskPool method) AlreadyRegistered AMQP_CONNECTION_TIMEOUT (in module celery.conf), [1] AMQP_CONSUMER_QUEUE (in module celery.conf), [1] AMQP_CONSUMER_ROUTING_KEY (in module celery.conf), [1] AMQP_EXCHANGE (in module celery.conf), [1] AMQP_EXCHANGE_TYPE (in module celery.conf), [1] AMQP_PUBLISHER_ROUTING_KEY (in module celery.conf), [1] apply_async() (celery.pool.TaskPool method) (celery.task.Task class method) (in module celery.task)

args (celery.worker.TaskWrapper attribute) arguments (celery.task.TaskSet attribute) 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) BaseBackend.UnpickleableExceptionWrapper

C

celery.backends (module) celery.backends.base (module) celery.backends.cache (module) celery.backends.database (module) celery.backends.tyrant (module) celery.bin.celeryd (module) celery.conf (module) celery.datastructures (module) celery.discovery (module) celery.log (module) celery.managers (module) celery.messaging (module) celery.monitoring (module) celery.pool (module) celery.registry (module) celery.result (module) celery.task (module) celery.timer (module) celery.worker (module) celeryd command line option --chroot --discard --umask --workdir -c, --concurrency -d, --detach, --daemon -f, --logfile -g, --gid -l, --loglevel -p, --pidfile -s, --statistics -u, --uid

cleanup() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) close_connection() (celery.worker.WorkController method) collect() (celery.monitoring.StatsCollector method) completed_count() (celery.result.TaskSetResult method) concurrency (celery.worker.WorkController attribute) connection_diagnostics() (celery.worker.WorkController method) create_exception_cls() (celery.backends.base.BaseBackend method)

D

DAEMON_CONCURRENCY (in module celery.conf), [1] DAEMON_LOG_FILE (in module celery.conf), [1] DAEMON_LOG_LEVEL (in module celery.conf), [1] DAEMON_PID_FILE (in module celery.conf), [1] date_done (TaskMeta attribute) decoder() (celery.messaging.TaskConsumer method) DEFAULT_STATISTICS_COLLECT_INTERVAL (in module celery.conf) 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) dump_to_cache() (celery.monitoring.StatsCollector method)

E

emergency_error() (in module celery.log) encoder() (celery.messaging.TaskPublisher method) event (celery.timer.EventTimer attribute) EventTimer (class in celery.timer) exc_args (celery.backends.base.BaseBackend.UnpickleableExceptionWrapper attribute) (celery.backends.base.UnpickleableExceptionWrapper attribute) exc_cls_name (celery.backends.base.BaseBackend.UnpickleableExceptionWrapper attribute) (celery.backends.base.UnpickleableExceptionWrapper attribute) exc_module (celery.backends.base.BaseBackend.UnpickleableExceptionWrapper attribute) (celery.backends.base.UnpickleableExceptionWrapper attribute)

exception (celery.datastructures.ExceptionInfo attribute) exception_to_python() (celery.backends.base.BaseBackend method) ExceptionInfo (class in celery.datastructures) execute() (celery.worker.TaskWrapper method) execute_remote() (in module celery.task) execute_using_pool() (celery.worker.TaskWrapper method) ExecuteRemoteTask (class in celery.task) extend_with_default_kwargs() (celery.worker.TaskWrapper method)

F

failed() (celery.result.TaskSetResult method) filled (celery.datastructures.PositionQueue attribute) filter_types() (celery.registry.TaskRegistry method) find_nearest_pickleable_exception() (in module celery.backends.base) find_related_module() (in module celery.discovery)

from_message() (celery.worker.TaskWrapper class method) full() (celery.datastructures.PositionQueue method) (celery.pool.TaskPool 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_default_periodicstatus_backend_cls (in module celery.backends) get_default_periodicstatus_backend_cls() (in module celery.backends) get_logger() (celery.task.Task 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) get_worker_pids() (celery.pool.TaskPool method)

I

interval (celery.timer.EventTimer attribute) 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.result.TaskSetResult method) (celery.task.TaskSet method) itersubtasks() (celery.result.TaskSetResult method)

J

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

K

kwargs (celery.worker.TaskWrapper attribute)

L

last_run_at (PeriodicTaskMeta attribute) last_triggered (celery.timer.EventTimer attribute) length (celery.datastructures.PositionQueue attribute) limit (celery.pool.TaskPool attribute) LOG_FORMAT (in module celery.conf), [1] LOG_LEVELS (in module celery.conf), [1]

logfile (celery.worker.WorkController attribute) logger (celery.pool.TaskPool attribute) (celery.worker.WorkController attribute) loglevel (celery.worker.WorkController attribute)

M

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

mark_as_retry() (celery.backends.base.BaseBackend method) message (celery.worker.TaskWrapper attribute)

N

name (celery.task.Task attribute) (PeriodicTaskMeta attribute)

NotRegistered

O

on_failure() (celery.worker.TaskWrapper method) on_finish() (celery.monitoring.TimerStats method) on_ready() (celery.pool.TaskPool method) on_return() (celery.pool.TaskPool method) on_start() (celery.monitoring.Statistics method) (celery.monitoring.TimerStats method)

on_stop() (celery.monitoring.Statistics method) on_success() (celery.worker.TaskWrapper method) open() (celery.backends.tyrant.Backend method)

P

parse_options() (in module celery.bin.celeryd) PeriodicTask (class in celery.task) PeriodicTaskManager (class in celery.managers) PeriodicTaskMeta (built-in class) PeriodicWorkController (class in celery.worker) ping() (in module celery.task) PingTask (class in celery.task) pool (celery.worker.WorkController attribute)

PositionQueue (class in celery.datastructures) PositionQueue.UnfilledPosition (class in celery.datastructures) prepare_exception() (celery.backends.base.BaseBackend method) prepare_result() (celery.backends.base.BaseBackend method) process_cleanup() (celery.backends.base.BaseBackend method) process_task() (celery.worker.WorkController method) publish() (celery.monitoring.Statistics method)

R

ready() (celery.result.BaseAsyncResult method) (celery.result.TaskSetResult method) reap() (celery.pool.TaskPool method) register() (celery.registry.TaskRegistry method) remote_execute() (celery.task.TaskSet class method) report() (celery.monitoring.StatsCollector method) requeue_task() (celery.messaging.TaskPublisher method) reset_connection() (celery.worker.WorkController method) result (celery.result.BaseAsyncResult attribute) (TaskMeta attribute) run() (celery.monitoring.Statistics method) (celery.pool.TaskPool method) (celery.task.AsynchronousMapTask method) (celery.task.DeleteExpiredTaskMetaTask method) (celery.task.ExecuteRemoteTask method) (celery.task.PingTask method) (celery.task.Task method) (celery.task.TaskSet method) (celery.worker.PeriodicWorkController method) (celery.worker.WorkController method)

run_every (celery.task.PeriodicTask attribute) run_periodic_tasks() (celery.backends.database.Backend method) run_worker() (in module celery.bin.celeryd)

S

SEND_CELERY_TASK_ERROR_EMAILS (in module celery.conf), [1] setup_logger() (in module celery.log) shutdown() (celery.worker.WorkController method) start() (celery.monitoring.Statistics class method) Statistics (class in celery.monitoring) StatsCollector (class in celery.monitoring) status (celery.result.BaseAsyncResult attribute) (TaskMeta attribute) stop() (celery.monitoring.Statistics method) (celery.worker.PeriodicWorkController method)

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) subtask_ids (celery.result.TaskSetResult attribute) subtasks (celery.result.TaskSetResult attribute) successful() (celery.result.BaseAsyncResult method) (celery.result.TaskSetResult method)

T

Task (class in celery.task) task (PeriodicTaskMeta attribute) task_consumer (celery.worker.WorkController attribute) task_func (celery.worker.TaskWrapper attribute) task_id (celery.result.AsyncResult attribute) (TaskMeta attribute) (celery.result.BaseAsyncResult attribute) (celery.worker.TaskWrapper attribute) task_name (celery.task.TaskSet attribute) (celery.worker.TaskWrapper 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) task_time_running() (celery.monitoring.StatsCollector method) TaskConsumer (class in celery.messaging) TaskManager (class in celery.managers) TaskMeta (built-in class) TaskPool (class in celery.pool) TaskPublisher (class in celery.messaging) TaskRegistry (class in celery.registry) TaskRegistry.AlreadyRegistered TaskRegistry.NotRegistered TaskSet (class in celery.task)

taskset_id (celery.result.TaskSetResult attribute) TaskSetResult (class in celery.result) TaskTimerStats (class in celery.monitoring) TaskWrapper (class in celery.worker) terminate() (celery.pool.TaskPool method) tick() (celery.timer.EventTimer method) (celery.timer.TimeoutTimer method) time_start (celery.monitoring.TimerStats attribute) (celery.timer.TimeoutTimer attribute) timeout (celery.timer.TimeoutTimer attribute) TimeoutError TimeoutTimer (class in celery.timer) TimerStats (class in celery.monitoring) total (celery.result.TaskSetResult attribute) (celery.task.TaskSet attribute) total_run_count (PeriodicTaskMeta attribute) total_task_time_running (celery.monitoring.StatsCollector attribute) total_task_time_running_by_type (celery.monitoring.StatsCollector attribute) total_tasks_processed (celery.monitoring.StatsCollector attribute) total_tasks_processed_by_type (celery.monitoring.StatsCollector attribute) traceback (celery.datastructures.ExceptionInfo attribute) type (celery.monitoring.Statistics attribute) (celery.task.Task attribute) tyrant_host (celery.backends.tyrant.Backend attribute) tyrant_port (celery.backends.tyrant.Backend attribute)

U

UnknownTask UnpickleableExceptionWrapper

unregister() (celery.registry.TaskRegistry method)

W

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

waiting() (celery.result.TaskSetResult method) WorkController (class in celery.worker)