Index

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

---

Symbols

--chroot celerybeat command line option celeryd command line option --discard celeryd command line option --umask celerybeat command line option celeryd command line option --workdir celerybeat command line option celeryd command line option -B, --beat celeryd command line option -c, --concurrency celeryd command line option -d, --detach, --daemon celerybeat command line option celeryd command line option

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

A

abstract (celery.task.base.Task attribute) acquire_pidlock() (in module celery.platform) add_bucket_for_type() (celery.worker.buckets.TaskBucket method) AlreadyExecutedError AlreadyRegistered ALWAYS_EAGER (in module celery.conf), [1] AMQP_CONNECTION_MAX_RETRIES (in module celery.conf), [1] 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_PUBLISHER_ROUTING_KEY (in module celery.conf), [1] apply() (celery.task.base.Task class method) (in module celery.execute) (in module celery.views) apply_async() (celery.task.base.Task class method) (celery.worker.pool.TaskPool method) (in module celery.execute) args (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) (celery.task.base.Task attribute) Backend (class in celery.backends.amqp) (class in celery.backends.cache) (class in celery.backends.database) (class in celery.backends.redis) (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 BaseLoader (class in celery.loaders.base) broker_listener (celery.worker.WorkController attribute)

C

callback (celery.worker.controllers.Mediator attribute) can_consume() (celery.worker.buckets.TokenBucketQueue method) capacity (celery.worker.buckets.TokenBucketQueue attribute) CarrotListener (class in celery.worker) celery.backends (module) celery.backends.amqp (module) celery.backends.base (module) celery.backends.cache (module) celery.backends.database (module) celery.backends.mongodb (module) celery.backends.redis (module) celery.backends.tyrant (module) celery.beat (module) celery.bin.celerybeat (module) celery.bin.celeryd (module) celery.bin.celeryinit (module) celery.conf (module) celery.contrib.test_runner (module) celery.datastructures (module) celery.decorators (module) celery.discovery (module) celery.exceptions (module) celery.execute (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.platform (module) celery.registry (module) celery.result (module) celery.signals (module) celery.task (module) celery.task.base (module), [1] celery.task.builtins (module) celery.task.rest (module), [1] celery.task.strategy (module) celery.utils (module) celery.utils.functional (module) celery.views (module) celery.worker (module) celery.worker.buckets (module) celery.worker.controllers (module)

celery.worker.job (module) celery.worker.pool (module) celery.worker.scheduler (module) CELERY_BACKEND (in module celery.conf), [1] CELERY_CACHE_BACKEND (in module celery.conf), [1] celerybeat command line option --chroot --umask --workdir -d, --detach, --daemon -f, --logfile -g, --gid -l, --loglevel -p, --pidfile -u, --uid CELERYBEAT_LOG_FILE (in module celery.conf), [1] CELERYBEAT_LOG_LEVEL (in module celery.conf), [1] CELERYBEAT_PID_FILE (in module celery.conf), [1] CELERYBEAT_SCHEDULE_FILENAME (in module celery.conf) celeryd command line option --chroot --discard --umask --workdir -B, --beat -c, --concurrency -d, --detach, --daemon -f, --logfile -g, --gid -l, --loglevel -p, --pidfile -s, --statistics -u, --uid chunks() (in module celery.utils) cleanup() (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) close() (celery.backends.redis.Backend method) (celery.backends.tyrant.Backend method) (celery.log.LoggingProxy method) close_connection() (celery.worker.CarrotListener 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.CarrotListener 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) decrement() (celery.datastructures.SharedCounter method) DEFAULT_CELERYBEAT_SCHEDULE_FILENAME (in module celery.conf) DEFAULT_RATE_LIMIT (in module celery.conf), [1] 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) DISABLE_RATE_LIMITS (in module celery.conf), [1] discard_all() (in module celery.task) DjangoMemcacheWrapper (class in celery.backends.cache) 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) eta_scheduler (celery.worker.CarrotListener attribute) even_time_distribution() (in module celery.task.strategy) 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) expected_time() (celery.worker.buckets.TokenBucketQueue method) extend_with_default_kwargs() (celery.worker.job.TaskWrapper method)

F

failed() (celery.result.TaskSetResult method) fill_rate (celery.worker.buckets.TokenBucketQueue attribute) filled (celery.datastructures.PositionQueue attribute) filter_types() (celery.registry.TaskRegistry method) find_related_module() (in module celery.discovery)

flush() (celery.log.LoggingProxy method) from_message() (celery.worker.job.TaskWrapper class method) full() (celery.datastructures.PositionQueue method) fun_takes_kwargs() (in module celery.utils)

G

gen_unique_id() (in module celery.utils) get() (celery.result.BaseAsyncResult method) (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue 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_bucket_for_type() (celery.worker.buckets.TaskBucket method) get_consumer() (celery.task.base.Task method) get_default_backend_cls (in module celery.backends) get_due_tasks() (celery.beat.Scheduler method) get_full_cls_name() (in module celery.utils) get_logger() (celery.task.base.Task method)

get_nowait() (celery.worker.buckets.TokenBucketQueue method) get_publisher() (celery.task.base.Task method) get_result() (celery.backends.amqp.Backend method) (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) get_status() (celery.backends.amqp.Backend method) (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) get_task() (celery.managers.TaskManager method) (celery.registry.TaskRegistry method) get_traceback() (celery.backends.amqp.Backend method) (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method)

H

handle_failure() (celery.worker.job.WorkerTaskTrace method) handle_retry() (celery.worker.job.WorkerTaskTrace method) handle_success() (celery.worker.job.WorkerTaskTrace method)

hold_queue (celery.worker.WorkController attribute)

I

ignore_result (celery.task.base.Task attribute) increment() (celery.datastructures.SharedCounter method) init_with_registry() (celery.worker.buckets.TaskBucket method) install_signal_handler() (in module celery.platform) InvalidResponseError is_detached (celery.worker.WorkController attribute) is_successful() (celery.backends.amqp.Backend method) (celery.backends.base.BaseBackend method) (celery.backends.database.Backend method) (celery.managers.TaskManager method) (in module celery.task)

is_task_done() (in module celery.views) is_task_successful() (in module celery.views) isatty() (celery.log.LoggingProxy method) iterate() (celery.result.TaskSetResult method) itersubtasks() (celery.result.TaskSetResult method)

J

join() (celery.result.TaskSetResult method)

K

kwargs (celery.worker.job.TaskWrapper attribute)

L

last_run_at (PeriodicTaskMeta attribute) length (celery.datastructures.PositionQueue attribute) limit (celery.worker.pool.TaskPool attribute) Loader (class in celery.loaders.default) (class in celery.loaders.djangoapp) LOG_FORMAT (in module celery.conf), [1] LOG_LEVELS (in module celery.conf), [1]

logfile (celery.worker.WorkController attribute) logger (celery.worker.CarrotListener attribute) (celery.worker.WorkController attribute) (celery.worker.pool.TaskPool attribute) LoggingProxy (class in celery.log) 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_retries (celery.task.base.Task attribute)

MaxRetriesExceededError 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

on_failure() (celery.task.base.Task method) (celery.worker.job.TaskWrapper method) on_finish() (celery.monitoring.TimerStats method) on_iteration() (celery.worker.controllers.BackgroundThread method) (celery.worker.controllers.Mediator method) (celery.worker.controllers.ScheduleController method) on_ready() (celery.worker.pool.TaskPool method) on_retry() (celery.task.base.Task method) on_start() (celery.monitoring.Statistics method) (celery.monitoring.TimerStats method) (celery.worker.controllers.BackgroundThread method) on_stop() (celery.monitoring.Statistics method) (celery.worker.controllers.BackgroundThread method)

on_success() (celery.task.base.Task method) (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.redis.Backend method) (celery.backends.tyrant.Backend method)

P

parse_options() (in module celery.bin.celerybeat) (in module celery.bin.celeryd) parse_ratelimit_string() (in module celery.worker.buckets) PeriodicTask (class in celery.task.base) PeriodicTaskMeta (built-in class) 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_value() (celery.backends.base.BaseBackend method) process_cleanup() (celery.backends.base.BaseBackend method) process_task() (celery.worker.WorkController method) publish() (celery.monitoring.Statistics method) put() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) put_nowait() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method)

Q

qsize() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method)

R

rate_limit (celery.task.base.Task attribute) RateLimitExceeded read_configuration() (celery.loaders.default.Loader method) (celery.loaders.djangoapp.Loader method) ready() (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.result.TaskSetResult method) ready_queue (celery.worker.CarrotListener attribute) (celery.worker.WorkController attribute) (celery.worker.controllers.Mediator attribute) receive_message() (celery.worker.CarrotListener method) redirect_stdouts_to_logger() (in module celery.log) redis_host (celery.backends.redis.Backend attribute) redis_port (celery.backends.redis.Backend attribute) register() (celery.registry.TaskRegistry method) remote_execute() (celery.task.base.TaskSet class method) RemoteExecuteError repeatlast() (in module celery.utils) report() (celery.monitoring.StatsCollector method) reset_connection() (celery.worker.CarrotListener 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.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_clockservice() (in module celery.bin.celerybeat) run_every (celery.task.base.PeriodicTask attribute) run_tests() (in module celery.contrib.test_runner) run_worker() (in module celery.bin.celeryd)

S

safe_process_task() (celery.worker.WorkController method) schedule_controller (celery.worker.WorkController attribute) schedule_registry() (celery.beat.Scheduler method) ScheduleController (class in celery.worker.controllers) ScheduleEntry (class in celery.beat) Scheduler (class in celery.beat) SchedulingError SEND_CELERY_TASK_ERROR_EMAILS (in module celery.conf), [1] serializer (celery.task.base.Task attribute) setup_logger() (in module celery.log) SharedCounter (class in celery.datastructures) start() (celery.monitoring.Statistics class method) (celery.worker.CarrotListener method) (celery.worker.WorkController method) (celery.worker.pool.TaskPool method) Statistics (class in celery.monitoring) StatsCollector (class in celery.monitoring)

status (celery.result.BaseAsyncResult attribute) (TaskMeta attribute) (celery.result.EagerResult attribute) stop() (celery.monitoring.Statistics method) (celery.worker.CarrotListener method) (celery.worker.WorkController method) (celery.worker.controllers.BackgroundThread method) (celery.worker.pool.TaskPool method) store_result() (celery.backends.amqp.Backend method) (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.EagerResult method) (celery.result.TaskSetResult method)

T

Task (class in celery.task.base) task (PeriodicTaskMeta attribute) task() (in module celery.decorators) Task.MaxRetriesExceededError 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_SERIALIZER (in module celery.conf), [1] 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) TaskBucket (class in celery.worker.buckets) TaskConsumer (class in celery.messaging) TaskManager (class in celery.managers) TaskMeta (built-in class) TaskPool (class in celery.worker.pool) TaskPublisher (class in celery.messaging) TaskRegistry (class in celery.registry) TaskRegistry.NotRegistered TaskSet (class in celery.task.base)

taskset_id (celery.result.TaskSetResult attribute) TaskSetResult (class in celery.result) TaskTimerStats (class in celery.monitoring) TaskType (class in celery.task.base) TaskWrapper (class in celery.worker.job) tick() (celery.beat.Scheduler method) time_start (celery.monitoring.TimerStats attribute) TimeoutError TimerStats (class in celery.monitoring) timestamp (celery.worker.buckets.TokenBucketQueue attribute) TokenBucketQueue (class in celery.worker.buckets) TokenBucketQueue.RateLimitExceeded 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

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

URL (class in celery.task.rest)

W

wait() (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.worker.buckets.TokenBucketQueue method) wait_for() (celery.backends.base.BaseBackend method) waiting() (celery.result.TaskSetResult method)

WorkController (class in celery.worker) WorkerTaskTrace (class in celery.worker.job) write() (celery.log.LoggingProxy method) writelines() (celery.log.LoggingProxy method)