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_pidlock() (in module celery.bin.celeryd) AlreadyRegistered ALWAYS_EAGER (in module celery.conf) 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_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) BaseAsyncResult (class in celery.result) BaseAsyncResult.TimeoutError

BaseBackend (class in celery.backends.base) BaseBackend.TimeoutError BaseBackend.UnpickleableExceptionWrapper 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.log (module) celery.managers (module) celery.messaging (module) celery.monitoring (module) celery.pool (module) celery.registry (module) celery.result (module) celery.supervisor (module) celery.task (module) celery.task.base (module) celery.task.builtins (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) 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) DEFAULT_ALWAYS_EAGER (in module celery.conf) 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)

E

EagerResult (class in celery.result) EagerResult.TimeoutError emergency_error() (in module celery.log) encoder() (celery.messaging.TaskPublisher method) 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.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) (celery.pool.TaskPool 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_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_waiting_tasks() (celery.managers.PeriodicTaskManager method) get_worker_pids() (celery.pool.TaskPool 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) InfinityThread (class in celery.worker.controllers) 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) 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)

join_timeout (celery.supervisor.OFASupervisor attribute)

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) 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) max_restart_freq (celery.supervisor.OFASupervisor attribute) max_restart_freq_time (celery.supervisor.OFASupervisor attribute)

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

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.InfinityThread 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.job.TaskWrapper 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) 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_task() (celery.worker.WorkController method) publish() (celery.monitoring.Statistics method)

R

raise_ping_timeout() (in module celery.supervisor) ready() (celery.result.BaseAsyncResult method) (celery.result.TaskSetResult method) reap() (celery.pool.TaskPool method) receive_message() (celery.worker.AMQPListener method) register() (celery.registry.TaskRegistry method) remote_execute() (celery.task.base.TaskSet class method) report() (celery.monitoring.StatsCollector method) reset_connection() (celery.worker.AMQPListener method) result (celery.result.BaseAsyncResult attribute) (TaskMeta attribute) (celery.result.EagerResult attribute) 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.InfinityThread 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) 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.InfinityThread 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

target (celery.supervisor.OFASupervisor attribute) Task (class in celery.task.base) task (PeriodicTaskMeta attribute) 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) 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

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

W

wait() (celery.result.BaseAsyncResult method) (celery.result.EagerResult 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)