Index

Symbols | A | B | C | D | E | F | G | H | 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 -S, --supervised celeryd command line option -u, --uid celeryd command line option

A

acquire() (celery.managers.TableLock class method) acquire_pidlock() (in module celery.bin.celeryd) add_worker() (celery.pool.DynamicPool method) AlreadyRegistered ALWAYS_EAGER (in module celery.conf), [1] AMQP_CONNECTION_MAX_RETRIES (in module celery.conf) AMQP_CONNECTION_RETRY (in module celery.conf) AMQP_CONNECTION_TIMEOUT (in module celery.conf), [1] AMQP_CONSUMER_QUEUE (in module celery.conf), [1] AMQP_CONSUMER_QUEUES (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_listener (celery.worker.WorkController attribute) AMQP_PUBLISHER_ROUTING_KEY (in module celery.conf), [1]

AMQPListener (class in celery.worker) apply() (celery.task.base.Task class method) (in module celery.execute) (in module celery.views) apply_async() (celery.pool.TaskPool method) (celery.task.base.Task class method) (in module celery.execute) args (celery.supervisor.OFASupervisor attribute) (celery.worker.job.TaskWrapper attribute) arguments (celery.task.base.TaskSet attribute) AsynchronousMapTask (class in celery.task.base) 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) BackgroundThread (class in celery.worker.controllers) BaseAsyncResult (class in celery.result) BaseAsyncResult.TimeoutError

BaseBackend (class in celery.backends.base) BaseBackend.TimeoutError BaseBackend.UnpickleableExceptionWrapper BaseLoader (class in celery.loaders.base) bucket_queue (celery.worker.AMQPListener attribute) (celery.worker.WorkController attribute) (celery.worker.controllers.Mediator attribute)

C

callback (celery.worker.controllers.Mediator attribute) 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.execute (module) celery.fields (module) celery.loaders (module) celery.loaders.base (module) celery.loaders.default (module) celery.loaders.djangoapp (module) celery.log (module) celery.managers (module) celery.messaging (module) celery.monitoring (module) celery.pool (module) celery.registry (module) celery.result (module) celery.signals (module) celery.supervisor (module) celery.task (module) celery.task.base (module) celery.task.builtins (module) celery.task.strategy (module) celery.utils (module) celery.views (module)

celery.worker (module) celery.worker.controllers (module) celery.worker.job (module) celeryd command line option --chroot --discard --umask --workdir -S, --supervised -c, --concurrency -d, --detach, --daemon -f, --logfile -g, --gid -l, --loglevel -p, --pidfile -s, --statistics -u, --uid check_interval (celery.supervisor.OFASupervisor attribute) chunks() (in module celery.utils) cleanup() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) close() (celery.backends.tyrant.Backend method) close_connection() (celery.worker.AMQPListener method) collect() (celery.monitoring.StatsCollector method) completed_count() (celery.result.TaskSetResult method) concurrency (celery.worker.WorkController attribute) conf (celery.loaders.base.BaseLoader attribute) consume_messages() (celery.worker.AMQPListener method) create_exception_cls() (celery.backends.base.BaseBackend method)

D

daemon (celery.supervisor.OFASupervisor.Process attribute) 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) decrement() (celery.datastructures.SharedCounter method) DEFAULT_AMQP_CONNECTION_MAX_RETRIES (in module celery.conf) default_retry_delay (celery.task.base.Task attribute) DefaultBackend (class in celery.backends) delay() (celery.task.base.Task class method) (PeriodicTaskMeta method)

delay_task() (celery.messaging.TaskPublisher method) (in module celery.execute) delay_task_in_set() (celery.messaging.TaskPublisher method) delete_expired() (celery.managers.TaskManager method) DeleteExpiredTaskMetaTask (class in celery.task.builtins) disable_error_emails (celery.task.base.Task attribute) discard_all() (in module celery.task) dmap() (in module celery.task) dmap_async() (in module celery.task) dump_to_cache() (celery.monitoring.StatsCollector method) DynamicPool (class in celery.pool)

E

EagerResult (class in celery.result) EagerResult.TimeoutError emergency_error() (in module celery.log) encoder() (celery.messaging.TaskPublisher method) even_time_distribution() (in module celery.task.strategy) 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) exchange (celery.task.base.Task attribute) execute() (celery.worker.job.TaskWrapper method) execute_remote() (in module celery.task) execute_using_pool() (celery.worker.job.TaskWrapper method) ExecuteRemoteTask (class in celery.task.base) exitcode (celery.supervisor.OFASupervisor.Process attribute) extend_with_default_kwargs() (celery.worker.job.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.job.TaskWrapper class method) full() (celery.datastructures.PositionQueue method)

G

gen_unique_id() (in module celery.utils) 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.base.Task method) get_db_prep_lookup() (celery.fields.PickledObjectField method) get_db_prep_save() (celery.fields.PickledObjectField 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_full_cls_name() (in module celery.utils)

get_internal_type() (celery.fields.PickledObjectField method) get_logger() (celery.task.base.Task method) get_publisher() (celery.task.base.Task method) get_result() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) get_status() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) get_task() (celery.managers.TaskManager method) (celery.registry.TaskRegistry method) get_traceback() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) get_waiting_tasks() (celery.managers.PeriodicTaskManager method) grow() (celery.pool.DynamicPool method)

H

hold_queue (celery.worker.AMQPListener attribute) (celery.worker.WorkController attribute)

I

ident (celery.supervisor.OFASupervisor.Process attribute) ignore_result (celery.task.base.Task attribute) increment() (celery.datastructures.SharedCounter method) init_entries() (celery.managers.PeriodicTaskManager method) init_periodic_tasks() (celery.backends.database.Backend method) install_restart_signal_handler() (in module celery.bin.celeryd) is_alive() (celery.supervisor.OFASupervisor.Process method) is_detached (celery.worker.WorkController attribute) is_done() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) (celery.managers.TaskManager method) (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (in module celery.task)

is_ready() (celery.result.EagerResult method) is_task_done() (in module celery.views) is_time() (celery.managers.PeriodicTaskManager method) iterate() (celery.result.TaskSetResult method) itersubtasks() (celery.result.TaskSetResult method)

J

jail() (in module celery.worker.job) join() (celery.result.TaskSetResult method) (celery.supervisor.OFASupervisor.Process method) (celery.task.base.TaskSet method)

K

kwargs (celery.supervisor.OFASupervisor attribute) (celery.worker.job.TaskWrapper attribute)

L

last_run_at (PeriodicTaskMeta attribute) length (celery.datastructures.PositionQueue attribute) limit (celery.pool.TaskPool attribute) Loader (class in celery.loaders.default) (class in celery.loaders.djangoapp) lock_table() (celery.managers.MySQLTableLock method) (celery.managers.TableLock method) 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.AMQPListener attribute) (celery.worker.WorkController attribute) loglevel (celery.worker.WorkController attribute)

M

mandatory (celery.task.base.Task attribute) map() (celery.task.base.TaskSet class method) map_async() (celery.task.base.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) max_restart_freq (celery.supervisor.OFASupervisor attribute) max_restart_freq_time (celery.supervisor.OFASupervisor attribute) max_retries (celery.task.base.Task attribute)

MaxRestartsExceededError MaxRetriesExceededError mediator (celery.worker.WorkController attribute) Mediator (class in celery.worker.controllers) message (celery.worker.job.TaskWrapper attribute) mitemgetter() (in module celery.utils) MySQLTableLock (class in celery.managers)

N

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

NotRegistered

O

OFASupervisor (class in celery.supervisor) OFASupervisor.Process (class in celery.supervisor) on_failure() (celery.worker.job.TaskWrapper method) on_finish() (celery.monitoring.TimerStats method) on_iteration() (celery.worker.controllers.BackgroundThread method) on_ready() (celery.pool.TaskPool method) on_return() (celery.pool.TaskPool method) on_start() (celery.monitoring.Statistics method) (celery.monitoring.TimerStats method) (celery.worker.controllers.BackgroundThread method) (celery.worker.controllers.PeriodicWorkController method)

on_stop() (celery.monitoring.Statistics method) (celery.worker.controllers.BackgroundThread method) on_success() (celery.worker.job.TaskWrapper method) on_task_init() (celery.loaders.base.BaseLoader method) (celery.loaders.djangoapp.Loader method) on_worker_init() (celery.loaders.base.BaseLoader method) (celery.loaders.default.Loader method) (celery.loaders.djangoapp.Loader method) open() (celery.backends.tyrant.Backend method)

P

parse_options() (in module celery.bin.celeryd) periodic_work_controller (celery.worker.WorkController attribute) PeriodicTask (class in celery.task.base) PeriodicTaskManager (class in celery.managers) PeriodicTaskMeta (built-in class) PeriodicWorkController (class in celery.worker.controllers) PickledObject (class in celery.fields) PickledObjectField (class in celery.fields) pid (celery.supervisor.OFASupervisor.Process attribute) pid_is_dead() (in module celery.pool) ping() (in module celery.task) PingTask (class in celery.task.builtins)

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_hold_queue() (celery.worker.controllers.PeriodicWorkController method) process_is_dead() (in module celery.pool) process_task() (celery.worker.WorkController method) publish() (celery.monitoring.Statistics method)

R

read_configuration() (celery.loaders.default.Loader method) (celery.loaders.djangoapp.Loader method) ready() (celery.result.BaseAsyncResult method) (celery.result.TaskSetResult method) reap_process() (in module celery.pool) receive_message() (celery.worker.AMQPListener method) register() (celery.registry.TaskRegistry method) release() (celery.managers.TableLock method) remote_execute() (celery.task.base.TaskSet class method) repeatlast() (in module celery.utils) replace_dead_workers() (celery.pool.DynamicPool method) report() (celery.monitoring.StatsCollector method) reset_connection() (celery.worker.AMQPListener method) result (celery.result.BaseAsyncResult attribute) (TaskMeta attribute) (celery.result.EagerResult attribute) retry() (celery.task.base.Task method)

retry_over_time() (in module celery.utils) RetryTaskError routing_key (celery.task.base.Task attribute) run() (celery.monitoring.Statistics method) (celery.supervisor.OFASupervisor.Process method) (celery.task.base.AsynchronousMapTask method) (celery.task.base.ExecuteRemoteTask method) (celery.task.base.Task method) (celery.task.base.TaskSet method) (celery.task.builtins.DeleteExpiredTaskMetaTask method) (celery.task.builtins.PingTask method) (celery.worker.controllers.BackgroundThread method) run_every (celery.task.base.PeriodicTask attribute) run_periodic_tasks() (celery.backends.database.Backend method) run_worker() (in module celery.bin.celeryd)

S

safe_process_task() (celery.worker.WorkController method) SEND_CELERY_TASK_ERROR_EMAILS (in module celery.conf), [1] setup_logger() (in module celery.log) SharedCounter (class in celery.datastructures) start() (celery.monitoring.Statistics class method) (celery.pool.TaskPool method) (celery.supervisor.OFASupervisor method) (celery.supervisor.OFASupervisor.Process method) (celery.worker.AMQPListener method) (celery.worker.WorkController method) Statistics (class in celery.monitoring) STATISTICS_COLLECT_INTERVAL (in module celery.conf), [1] StatsCollector (class in celery.monitoring) status (celery.result.BaseAsyncResult attribute) (TaskMeta attribute) (celery.result.EagerResult attribute)

stop() (celery.monitoring.Statistics method) (celery.pool.TaskPool method) (celery.worker.AMQPListener method) (celery.worker.WorkController method) (celery.worker.controllers.BackgroundThread method) store_result() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) (celery.managers.TaskManager method) subtasks (celery.result.TaskSetResult attribute) successful() (celery.result.BaseAsyncResult method) (celery.result.TaskSetResult method)

T

table_lock (in module celery.managers) TableLock (class in celery.managers) target (celery.supervisor.OFASupervisor attribute) Task (class in celery.task.base) task (PeriodicTaskMeta attribute) Task.MaxRetriesExceededError task_func (celery.worker.job.TaskWrapper attribute) task_id (celery.result.AsyncResult attribute) (TaskMeta attribute) (celery.result.BaseAsyncResult attribute) (celery.worker.job.TaskWrapper attribute) task_name (celery.task.base.TaskSet attribute) (celery.worker.job.TaskWrapper attribute) task_status() (in module celery.views) 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.base) taskset_id (celery.result.TaskSetResult attribute) TaskSetResult (class in celery.result) TaskTimerStats (class in celery.monitoring) TaskWrapper (class in celery.worker.job) terminate() (celery.supervisor.OFASupervisor.Process method) time_start (celery.monitoring.TimerStats attribute) TimeoutError, [1] TimerStats (class in celery.monitoring) to_python() (celery.fields.PickledObjectField method) total (celery.result.TaskSetResult attribute) (celery.task.base.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) (celery.result.BaseAsyncResult attribute) (celery.result.EagerResult attribute) type (celery.monitoring.Statistics attribute) (celery.task.base.Task attribute) tyrant_host (celery.backends.tyrant.Backend attribute) tyrant_port (celery.backends.tyrant.Backend attribute)

U

unlock_table() (celery.managers.MySQLTableLock method) (celery.managers.TableLock method) UnpickleableExceptionWrapper

unregister() (celery.registry.TaskRegistry method)

W

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

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