Index

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

Symbols

--compat
celery-upgrade command line option
--config
celery command line option
--countdown
celery-call command line option
--detach
celery-beat command line option
celery-events command line option
celery-worker command line option
--django
celery-upgrade command line option
--eta
celery-call command line option
--eventlet
celery-shell command line option
--exchange
celery-call command line option
--executable
celery command line option
celery-beat command line option
celery-events command line option
celery-worker command line option
--expires
celery-call command line option
--gevent
celery-shell command line option
--gid
celery command line option
celery-beat command line option
celery-events command line option
celery-worker command line option
--heartbeat-interval
celery-worker command line option
--help
celery command line option
--loader
celery command line option
--max-interval
celery-beat command line option
--max-memory-per-child
celery-worker command line option
--max-tasks-per-child
celery-worker command line option
--no-backup
celery-upgrade command line option
--pidfile
celery command line option
celery-beat command line option
celery-events command line option
celery-worker command line option
--prefetch-multiplier
celery-worker command line option
--purge
celery-worker command line option
--queue
celery-call command line option
--routing-key
celery-call command line option
--scheduler
celery-worker command line option
--serializer
celery-call command line option
--soft-time-limit
celery-worker command line option
--time-limit
celery-worker command line option
--traceback
celery-result command line option
--uid
celery command line option
celery-beat command line option
celery-events command line option
celery-worker command line option
--umask
celery command line option
celery-beat command line option
celery-events command line option
celery-worker command line option
--without-gossip
celery-worker command line option
--without-heartbeat
celery-worker command line option
--without-mingle
celery-worker command line option
--workdir
celery command line option
celery-beat command line option
celery-events command line option
celery-worker command line option
-a, --ack-messages
celery-migrate command line option
-A, --app
celery command line option
-a, --args
celery-call command line option
-B, --beat
celery-worker command line option
-B, --bpython
celery-shell command line option
-b, --broker
celery command line option
-c, --camera
celery-events command line option
-c, --concurrency
celery-worker command line option
-C, --no-color
celery command line option
-d, --destination
celery-control command line option
celery-inspect command line option
-d, --dump
celery-events command line option
-E, --task-events
celery-worker command line option
-f, --force
celery-purge command line option
-F, --forever
celery-migrate command line option
-F, --freq, --frequency
celery-events command line option
-f, --logfile
celery command line option
celery-beat command line option
celery-events command line option
celery-worker command line option
-I, --include
celery-worker command line option
-I, --ipython
celery-shell command line option
-j, --json
celery-control command line option
celery-inspect command line option
-k, --kwargs
celery-call command line option
-l, --loglevel
celery-beat command line option
celery-events command line option
celery-worker command line option
-n, --hostname
celery-worker command line option
-n, --limit
celery-migrate command line option
-O
celery-worker command line option
-P, --pool
celery-worker command line option
-P, --python
celery-shell command line option
-Q, --queues
celery-migrate command line option
celery-worker command line option
-q, --quiet
celery command line option
-r, --maxrate
celery-events command line option
-s, --schedule
celery-beat command line option
celery-worker command line option
-S, --scheduler
celery-beat command line option
-S, --statedb
celery-worker command line option
-t, --task
celery-result command line option
-T, --tasks
celery-migrate command line option
-t, --timeout
celery-control command line option
celery-inspect command line option
-T, --without-tasks
celery-shell command line option
-t, -timeout
celery-migrate command line option
-X, --exclude-queues
celery-worker command line option

A

abbr() (in module celery.utils.text)
abbrtask() (in module celery.utils.text)
abcast() (celery.app.control.Control.Mailbox method)
abort() (celery.contrib.abortable.AbortableAsyncResult method)
AbortableAsyncResult (class in celery.contrib.abortable)
AbortableTask (class in celery.contrib.abortable)
abstract (celery.app.task.Task attribute)
(celery.contrib.abortable.AbortableTask attribute)
accept (celery.app.control.Control.Mailbox attribute)
(celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
accept_content
setting
ack
acknowledge() (celery.worker.request.Request method)
acknowledged
(celery.worker.request.Request attribute)
acks_late (celery.app.task.Task attribute)
(Task attribute)
acquire() (celery.platforms.Pidfile method)
ACTIONS (celery.bin.base.Option attribute)
active (celery.concurrency.base.BasePool attribute)
(celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
active() (celery.app.control.Inspect method)
active_queues
control
active_queues() (celery.app.control.Inspect method)
active_requests (in module celery.worker.state)
add() (celery.app.amqp.Queues method)
(celery.beat.Scheduler method)
(celery.bin.base.Extensions method)
(celery.result.ResultSet method)
(celery.utils.collections.LimitedSet method)
(hub method)
add_append_opt() (celery.bin.base.Command method)
add_arc() (celery.utils.graph.DependencyGraph method)
add_cert() (celery.security.certificate.CertStore method)
add_compat() (celery.app.amqp.Queues method)
add_consumer
control
add_consumer() (celery.app.control.Control method)
add_defaults() (celery.Celery method)
(celery.utils.collections.ChainMap method)
add_edge() (celery.utils.graph.DependencyGraph method)
add_pending_result() (celery.backends.async.AsyncBackendMixin method)
add_pending_results() (celery.backends.async.AsyncBackendMixin method)
add_periodic_task() (celery.Celery method)
add_queue() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
add_reader() (hub method)
add_task_queue() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
add_to_chord() (celery.app.task.Task method)
(celery.backends.redis.RedisBackend method)
add_writer() (hub method)
adjust() (celery.beat.Scheduler method)
adjust_timestamp() (in module celery.utils.time)
after_return()
(celery.app.task.Task method)
after_setup_logger
signal
after_setup_task_logger
signal
after_task_publish
signal
Agent (class in celery.worker.consumer)
(class in celery.worker.consumer.agent)
alert() (celery.events.cursesmon.CursesMonitor method)
alert_remote_control_reply() (celery.events.cursesmon.CursesMonitor method)
alias (celery.bootsteps.Blueprint attribute)
(celery.bootsteps.Step attribute)
alive (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
alive() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
alive_workers() (celery.events.state.State method)
ALL_STATES
state
already_setup (celery.app.log.Logging attribute)
AlreadyRegistered
alt (celery.app.defaults.Option attribute)
ALWAYS_TYPED_ACTIONS (celery.bin.base.Option attribute)
AlwaysEagerIgnored
amqp (celery.bin.amqp.AMQShell attribute)
(celery.Celery attribute)
AMQP (class in celery.app.amqp)
amqp (class in celery.bin.amqp)
AMQPAdmin (class in celery.bin.amqp)
AMQPBackend (class in celery.backends.amqp)
AMQPBackend.BacklogLimitExceeded
AMQPBackend.Consumer (class in celery.backends.amqp)
AMQPBackend.Consumer.ContentDisallowed
AMQPBackend.Exchange (class in celery.backends.amqp)
AMQPBackend.Producer (class in celery.backends.amqp)
AMQShell (class in celery.bin.amqp)
annotate() (celery.app.annotations.MapAnnotation method)
annotate_any() (celery.app.annotations.MapAnnotation method)
anon_nodename() (in module celery.utils.nodenames)
app, [1]
(celery.app.control.Inspect attribute)
(celery.apps.beat.Beat attribute)
(celery.events.EventDispatcher attribute)
(celery.events.EventReceiver attribute)
(celery.result.AsyncResult attribute)
(celery.result.ResultSet attribute)
(celery.schedules.crontab attribute)
(celery.schedules.schedule attribute)
(celery.utils.abstract.CallableSignature attribute)
(celery.worker.WorkController attribute)
(celery.worker.request.Request attribute)
app_or_default() (in module celery.app)
AppLoader (class in celery.loaders.app)
apply
apply() (celery.app.task.Task method)
(celery.bootsteps.Blueprint method)
(celery.utils.abstract.CallableTask method)
apply_async() (celery.app.task.Task method)
(celery.beat.Scheduler method)
(celery.concurrency.base.BasePool method)
(celery.utils.abstract.CallableTask method)
apply_chord() (celery.backends.redis.RedisBackend method)
apply_entry() (celery.beat.Scheduler method)
apply_eta_task()
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
apply_target() (in module celery.concurrency.base)
appstr() (in module celery.app.utils)
args (celery.beat.ScheduleEntry attribute)
(celery.bin.amqp.Spec attribute)
(celery.bin.base.Command attribute)
(celery.bin.graph.graph attribute)
(celery.bin.logtool.logtool attribute)
(celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.utils.abstract.CallableSignature attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
argsrepr (celery.worker.request.Request attribute)
arguments (celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.rpc.BaseRPCBackend.Exchange attribute)
argv_with_executable (celery.apps.multi.Node attribute)
(celery.bin.multi.MultiTool.MultiParser.Node attribute)
as_dict() (celery.events.state.State.Task method)
(celery.events.state.Task method)
(celery.utils.collections.LimitedSet method)
as_tuple() (celery.result.AsyncResult method)
(celery.result.GroupResult method)
as_uri() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.DisabledBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.cassandra.CassandraBackend method)
(celery.backends.mongodb.MongoBackend method)
(celery.backends.rpc.RPCBackend method)
ask() (celery.bin.base.Command method)
AsyncBackendMixin (class in celery.backends.async)
AsyncResult (celery.Celery attribute)
(class in celery.result)
AsyncResult() (celery.app.task.Task method)
(celery.contrib.abortable.AbortableTask method)
AsyncResult.TimeoutError
asynloop() (in module celery.worker.loops)
ATTR (celery.utils.graph.DOT attribute)
attr() (celery.utils.graph.GraphFormatter method)
AttributeDict (class in celery.utils.collections)
AttributeDictMixin (class in celery.utils.collections)
attrs (celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.rpc.BaseRPCBackend.Exchange attribute)
ATTRS (celery.bin.base.Option attribute)
attrs() (celery.utils.graph.GraphFormatter method)
ATTRSEP (celery.utils.graph.DOT attribute)
auto_declare (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
(celery.backends.rpc.RPCBackend.Consumer attribute)
auto_delete (celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.rpc.BaseRPCBackend.Exchange attribute), [1]
autodiscover_tasks() (celery.Celery method)
(celery.loaders.base.BaseLoader method)
autoregister (celery.app.task.Task attribute)
available (celery.utils.sysinfo.df attribute)
AWS_ACCESS_KEY_ID
AWS_SECRET_ACCESS_KEY

B

backend (celery.app.task.Task attribute)
(Task attribute)
(celery.Celery attribute)
(celery.result.AsyncResult attribute)
(celery.result.ResultSet attribute)
background (celery.events.cursesmon.CursesMonitor attribute)
BacklogLimitExceeded, [1]
banner() (celery.apps.beat.Beat method)
BaseBackend (class in celery.backends.base)
BaseLoader (class in celery.loaders.base)
BasePool (class in celery.concurrency.base)
BasePool.Timer (class in celery.concurrency.base)
BasePool.Timer.Entry (class in celery.concurrency.base)
BaseResultConsumer (class in celery.backends.async)
BaseRPCBackend (class in celery.backends.rpc)
BaseRPCBackend.BacklogLimitExceeded
BaseRPCBackend.Consumer (class in celery.backends.rpc)
BaseRPCBackend.Consumer.ContentDisallowed
BaseRPCBackend.Exchange (class in celery.backends.rpc)
BaseRPCBackend.Producer (class in celery.backends.rpc)
BaseRPCBackend.ResultConsumer (class in celery.backends.rpc)
BaseRPCBackend.ResultConsumer.Consumer (class in celery.backends.rpc)
BaseRPCBackend.ResultConsumer.Consumer.ContentDisallowed
Beat (celery.Celery attribute)
(class in celery.apps.beat)
beat (class in celery.bin.beat)
Beat (class in celery.worker.components)
Beat.Service (class in celery.apps.beat)
beat_embedded_init
signal
beat_init
signal
beat_max_loop_interval
setting
beat_schedule
setting
beat_schedule_filename
setting
beat_scheduler
setting
beat_sync_every
setting
before_task_publish
signal
bgThread (class in celery.utils.threads)
billiard
bind() (queue method)
bind_to() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.rpc.BaseRPCBackend.Exchange method)
binding (celery.backends.rpc.RPCBackend attribute)
binding() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.rpc.BaseRPCBackend.Exchange method)
black() (celery.utils.term.colored method)
blink() (celery.utils.term.colored method)
BlockingPool (celery.concurrency.prefork.TaskPool attribute)
blue() (celery.utils.term.colored method)
blueprint, [1]
(celery.worker.WorkController attribute)
Blueprint (class in celery.bootsteps)
body (celery.worker.request.Request attribute)
body() (celery.utils.threads.bgThread method)
body_can_be_buffer (celery.concurrency.base.BasePool attribute)
(celery.concurrency.solo.TaskPool attribute)
bold() (celery.utils.term.colored method)
bootsteps() (celery.bin.graph.graph method)
bright() (celery.utils.term.colored method)
broadcast() (celery.app.control.Control method)
broker_connection_max_retries
setting
broker_connection_retry
setting
broker_connection_timeout
setting
broker_failover_strategy
setting
broker_heartbeat
setting
broker_heartbeat_checkrate
setting
broker_login_method
setting
broker_pool_limit
setting
broker_read_url
setting
broker_read_url (celery.app.utils.Settings attribute)
broker_transport_options
setting
broker_url
setting
broker_url (celery.app.utils.Settings attribute)
broker_use_ssl
setting
broker_write_url
setting
broker_write_url (celery.app.utils.Settings attribute)
bucket (celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.riak.RiakBackend attribute)
bucket_for_task() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(consumer method)
bucket_name (celery.backends.riak.RiakBackend attribute)
Buffer (celery.utils.collections.BufferMap attribute)
BufferMap (class in celery.utils.collections)
BufferMap.Empty
bufmaxsize (celery.utils.collections.BufferMap attribute)
bugreport() (celery.Celery method)
(in module celery.app.utils)
build_graph() (celery.result.AsyncResult method)
build_tracer() (in module celery.app.trace)
builtin_fixups (celery.Celery attribute)
builtin_modules (celery.loaders.base.BaseLoader attribute)
builtins (celery.bin.amqp.AMQShell attribute)
Bunch (class in celery.utils.objects)
by_alias (celery.worker.control.Panel attribute)

C

C_FAKEFORK, [1], [2], [3], [4]
C_FORCE_ROOT, [1]
C_IMPDEBUG
cache_backend
setting
cache_backend_options
setting
CacheBackend (class in celery.backends.cache)
cached_property (class in celery.utils)
call() (celery.app.control.Control.Mailbox method)
call_after() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
call_at() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
call_command() (celery.bin.multi.MultiTool method)
call_repeatedly() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
call_soon() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
call_task() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
Callable() (in module celery.utils.deprecated)
CallableSignature (class in celery.utils.abstract)
CallableTask (class in celery.utils.abstract)
callbacks (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
calling
can_cache_declaration (celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.rpc.BaseRPCBackend.Exchange attribute)
cancel() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
(celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.base.BasePool.Timer.Entry method)
(celery.concurrency.eventlet.TaskPool.Timer method)
(celery.events.snapshot.Polaroid method)
(celery.utils.timer2.Entry method)
(celery.utils.timer2.Timer method)
(celery.utils.timer2.Timer.Entry method)
cancel_by_queue() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
cancel_consumer
control
cancel_consumer()
(celery.app.control.Control method)
cancel_for() (celery.backends.async.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer method)
cancel_task_queue() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(consumer method)
canceled (celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
cancelled (celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
capacity (celery.utils.sysinfo.df attribute)
capture() (celery.events.EventReceiver method)
(celery.events.snapshot.Polaroid method)
cassandra_auth_kwargs
setting
cassandra_auth_provider
setting
cassandra_entry_ttl
setting
cassandra_keyspace
setting
cassandra_port
setting
cassandra_read_consistency
setting
cassandra_servers
setting
cassandra_table
setting
cassandra_write_consistency
setting
CassandraBackend (class in celery.backends.cassandra)
cast() (celery.app.control.Control.Mailbox method)
CDeprecationWarning
Celery (class in celery)
celery (module)
celery command line option
--config
--executable
--gid
--help
--loader
--pidfile
--uid
--umask
--workdir
-A, --app
-C, --no-color
-b, --broker
-f, --logfile
-q, --quiet
celery-beat command line option
--detach
--executable
--gid
--max-interval
--pidfile
--uid
--umask
--workdir
-S, --scheduler
-f, --logfile
-l, --loglevel
-s, --schedule
celery-call command line option
--countdown
--eta
--exchange
--expires
--queue
--routing-key
--serializer
-a, --args
-k, --kwargs
celery-control command line option
-d, --destination
-j, --json
-t, --timeout
celery-events command line option
--detach
--executable
--gid
--pidfile
--uid
--umask
--workdir
-F, --freq, --frequency
-c, --camera
-d, --dump
-f, --logfile
-l, --loglevel
-r, --maxrate
celery-inspect command line option
-d, --destination
-j, --json
-t, --timeout
celery-migrate command line option
-F, --forever
-Q, --queues
-T, --tasks
-a, --ack-messages
-n, --limit
-t, -timeout
celery-purge command line option
-f, --force
celery-result command line option
--traceback
-t, --task
celery-shell command line option
--eventlet
--gevent
-B, --bpython
-I, --ipython
-P, --python
-T, --without-tasks
celery-upgrade command line option
--compat
--django
--no-backup
celery-worker command line option
--detach
--executable
--gid
--heartbeat-interval
--max-memory-per-child
--max-tasks-per-child
--pidfile
--prefetch-multiplier
--purge
--scheduler
--soft-time-limit
--time-limit
--uid
--umask
--without-gossip
--without-heartbeat
--without-mingle
--workdir
-B, --beat
-E, --task-events
-I, --include
-O
-P, --pool
-Q, --queues
-S, --statedb
-X, --exclude-queues
-c, --concurrency
-f, --logfile
-l, --loglevel
-n, --hostname
-s, --schedule
celery._state (module)
celery.app (module)
celery.app.amqp (module)
celery.app.annotations (module)
celery.app.builtins (module)
celery.app.control (module)
celery.app.defaults (module)
celery.app.log (module)
celery.app.registry (module)
celery.app.routes (module)
celery.app.task (module), [1]
celery.app.trace (module)
celery.app.utils (module)
celery.apps.beat (module)
celery.apps.multi (module)
celery.apps.worker (module)
celery.backends (module)
celery.backends.amqp (module)
celery.backends.async (module)
celery.backends.base (module)
celery.backends.cache (module)
celery.backends.cassandra (module)
celery.backends.consul (module)
celery.backends.couchbase (module)
celery.backends.couchdb (module)
celery.backends.database (module)
celery.backends.database.models (module)
celery.backends.database.session (module)
celery.backends.elasticsearch (module)
celery.backends.filesystem (module)
celery.backends.mongodb (module)
celery.backends.redis (module)
celery.backends.riak (module)
celery.backends.rpc (module)
celery.beat (module)
celery.bin.amqp (module)
celery.bin.base (module)
celery.bin.beat (module)
celery.bin.celery (module)
celery.bin.events (module)
celery.bin.graph (module)
celery.bin.logtool (module)
celery.bin.multi (module)
celery.bin.worker (module)
celery.bootsteps (module)
celery.concurrency (module)
celery.concurrency.base (module)
celery.concurrency.eventlet (module)
celery.concurrency.gevent (module)
celery.concurrency.prefork (module)
celery.concurrency.solo (module)
celery.contrib.abortable (module)
celery.contrib.migrate (module)
celery.contrib.rdb (module)
celery.contrib.sphinx (module)
celery.events (module)
celery.events.cursesmon (module)
celery.events.dumper (module)
celery.events.snapshot (module)
celery.events.state (module)
celery.exceptions (module)
celery.loaders (module)
celery.loaders.app (module)
celery.loaders.base (module)
celery.loaders.default (module)
Celery.on_after_configure (in module celery)
Celery.on_after_finalize (in module celery)
Celery.on_after_fork (in module celery)
Celery.on_configure (in module celery)
celery.platforms (module)
celery.result (module)
celery.schedules (module)
celery.security (module)
celery.security.certificate (module)
celery.security.key (module)
celery.security.serialization (module)
celery.security.utils (module)
celery.signals (module)
celery.states (module)
celery.utils (module)
celery.utils.abstract (module)
celery.utils.collections (module)
celery.utils.debug (module)
celery.utils.deprecated (module)
celery.utils.dispatch (module)
celery.utils.dispatch.saferef (module)
celery.utils.dispatch.signal (module)
celery.utils.functional (module)
celery.utils.graph (module)
celery.utils.imports (module)
celery.utils.iso8601 (module)
celery.utils.log (module)
celery.utils.nodenames (module)
celery.utils.objects (module)
celery.utils.saferepr (module)
celery.utils.serialization (module)
celery.utils.sysinfo (module)
celery.utils.term (module)
celery.utils.text (module)
celery.utils.threads (module)
celery.utils.time (module)
celery.utils.timer2 (module)
celery.worker (module)
celery.worker.components (module)
celery.worker.consumer (module)
celery.worker.consumer.agent (module)
celery.worker.consumer.connection (module)
celery.worker.consumer.consumer (module)
celery.worker.consumer.control (module)
celery.worker.consumer.events (module)
celery.worker.consumer.gossip (module)
celery.worker.consumer.heart (module)
celery.worker.consumer.mingle (module)
celery.worker.consumer.tasks (module)
celery.worker.control (module)
celery.worker.heartbeat (module)
celery.worker.loops (module)
celery.worker.pidbox (module)
celery.worker.request (module)
celery.worker.state (module)
celery.worker.strategy (module)
CELERY_BENCH
CELERY_BROKER_URL
CELERY_CHDIR
CELERY_CONFIG_MODULE, [1], [2]
CELERY_CREATE_DIRS
CELERY_LOADER, [1], [2], [3], [4], [5]
CELERY_RDB_HOST
CELERY_RDB_PORT
CELERY_RDBSIG
CELERY_SU
CELERY_TRACE_APP, [1], [2]
CeleryCommand (class in celery.bin.celery)
CELERYCTL
celeryd_after_setup
signal
celeryd_init
signal
CELERYD_SU_ARGS
CeleryError
CeleryWarning
Certificate (class in celery.security.certificate)
CertStore (class in celery.security.certificate)
chain (class in celery)
ChainMap (class in celery.utils.collections)
chan (celery.bin.amqp.AMQShell attribute)
changes (celery.utils.collections.ChainMap attribute)
channel (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Exchange attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
check_args() (celery.bin.base.Command method)
CHECK_METHODS (celery.bin.base.Option attribute)
check_value() (celery.bin.base.Option method)
children (celery.result.AsyncResult attribute)
(celery.result.GroupResult attribute)
chord (celery.worker.request.Request attribute)
(class in celery)
chord_size (celery.utils.abstract.CallableSignature attribute)
ChordError
chunks() (celery.app.task.Task method)
(in module celery.utils.functional)
cipater
claim_steps() (celery.bootsteps.Blueprint method)
cleanup() (celery.backends.database.DatabaseBackend method)
(celery.backends.mongodb.MongoBackend method)
(celery.events.snapshot.Polaroid method)
(celery.utils.threads.LocalManager method)
cleanup_signal (celery.events.snapshot.Polaroid attribute)
clear() (celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.eventlet.TaskPool.Timer method)
(celery.concurrency.gevent.TaskPool.Timer method)
(celery.events.state.State method)
(celery.result.ResultSet method)
(celery.utils.collections.ChainMap method)
(celery.utils.collections.ConfigurationView method)
(celery.utils.collections.LimitedSet method)
(celery.utils.timer2.Timer method)
clear_after (celery.events.snapshot.Polaroid attribute)
clear_tasks() (celery.events.state.State method)
client (celery.backends.cache.CacheBackend attribute)
(celery.backends.consul.ConsulBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.backends.riak.RiakBackend attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
clock (celery.events.state.State.Task attribute)
(celery.events.state.State.Worker attribute)
(celery.events.state.Task attribute)
(celery.events.state.Worker attribute)
clock() (celery.app.control.Inspect method)
clone() (celery.utils.abstract.CallableSignature method)
CLOSE (celery.concurrency.base.BasePool attribute)
close() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.Celery method)
(celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
(celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
(celery.bootsteps.Blueprint method)
(celery.bootsteps.StartStopStep method)
(celery.concurrency.base.BasePool method)
(celery.events.EventDispatcher method)
(celery.platforms.DaemonContext method)
(celery.utils.log.LoggingProxy method)
(celery.worker.components.Pool method)
(celery.worker.state.Persistent method)
close_open_fds() (in module celery.platforms)
closed (celery.utils.log.LoggingProxy attribute)
Cluster (class in celery.apps.multi)
Cluster() (celery.bin.multi.MultiTool method)
cluster_from_argv() (celery.bin.multi.MultiTool method)
cmdline_config_parser() (celery.loaders.base.BaseLoader method)
coerce() (celery.bin.amqp.Spec method)
collect() (celery.result.AsyncResult method)
collection (celery.backends.mongodb.MongoBackend attribute)
colored (celery.bin.base.Command attribute)
(class in celery.utils.term)
colored() (celery.app.log.Logging method)
ColorFormatter (class in celery.utils.log)
COLORS (celery.utils.log.ColorFormatter attribute)
colors (celery.utils.log.ColorFormatter attribute)
Command (class in celery.bin.base)
Command.Error
Command.UsageError
commands (celery.bin.celery.CeleryCommand attribute)
compatible_transport() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.Mingle method)
(celery.worker.consumer.gossip.Gossip method)
(celery.worker.consumer.mingle.Mingle method)
compatible_transports (celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.Mingle attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.mingle.Mingle attribute)
completed_count() (celery.result.ResultSet method)
completenames() (celery.bin.amqp.AMQShell method)
compress() (celery.worker.state.Persistent method)
compression (celery.backends.amqp.AMQPBackend.Producer attribute)
(Task attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
conditional (celery.bootsteps.Step attribute)
(celery.worker.components.Beat attribute)
(celery.worker.consumer.Agent attribute)
(celery.worker.consumer.agent.Agent attribute)
conf (celery.loaders.base.BaseLoader attribute)
conf() (celery.app.control.Inspect method)
config_from_envvar() (celery.Celery method)
config_from_object() (celery.Celery method)
(celery.loaders.base.BaseLoader method)
ConfigurationView (class in celery.utils.collections)
configured (celery.loaders.base.BaseLoader attribute)
conn (celery.bin.amqp.AMQShell attribute)
connect() (celery.bin.amqp.AMQPAdmin method)
(celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
(celery.utils.graph.DependencyGraph method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
connect_on_app_finalize() (in module celery._state)
connect_with() (celery.bootsteps.Blueprint method)
connection
Connection (celery.app.amqp.AMQP attribute)
connection (celery.app.control.Control.Mailbox attribute)
(celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
(celery.beat.Scheduler attribute)
(celery.events.EventReceiver attribute)
Connection (class in celery.worker.consumer)
(class in celery.worker.consumer.connection)
connection() (celery.Celery method)
connection_errors (celery.worker.request.Request attribute)
connection_for_read() (celery.Celery method)
connection_for_write() (celery.Celery method)
connection_or_acquire() (celery.Celery method)
ConnectionPool (celery.backends.redis.RedisBackend attribute)
consistency (celery.backends.consul.ConsulBackend attribute)
CONST_ACTIONS (celery.bin.base.Option attribute)
consul (celery.backends.consul.ConsulBackend attribute)
ConsulBackend (class in celery.backends.consul)
consume() (celery.backends.amqp.AMQPBackend method)
(celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
consume_from (celery.app.amqp.Queues attribute)
consume_from() (celery.backends.async.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer method)
Consumer (celery.app.amqp.AMQP attribute)
consumer (celery.worker.pidbox.Pidbox attribute)
Consumer (class in celery.worker.components)
(class in celery.worker.consumer)
(class in celery.worker.consumer.consumer)
Consumer.Blueprint (class in celery.worker.consumer)
(class in celery.worker.consumer.consumer)
consumers (celery.bootsteps.ConsumerStep attribute)
ConsumerStep (class in celery.bootsteps)
consuming_from() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
container (celery.backends.couchdb.CouchBackend attribute)
content_encoding (celery.worker.request.Request attribute)
content_type (celery.worker.request.Request attribute)
context
control
active_queues
add_consumer
cancel_consumer
disable_events
enable_events
ping
rate_limit
revoke
shutdown
control (celery.Celery attribute)
Control (class in celery.app.control)
(class in celery.worker.consumer)
(class in celery.worker.consumer.control)
Control.Mailbox (class in celery.app.control)
controller
convert_value() (celery.bin.base.Option method)
copy() (celery.utils.collections.ChainMap method)
correlation_id (celery.worker.request.Request attribute)
CouchBackend (class in celery.backends.couchdb)
couchbase_backend_settings
setting
CouchbaseBackend (class in celery.backends.couchbase)
count (celery.contrib.migrate.State attribute)
counter (celery.bin.amqp.AMQShell attribute)
CPendingDeprecationWarning
create() (celery.bootsteps.Step method)
(celery.worker.components.Beat method)
(celery.worker.components.Consumer method)
(celery.worker.components.Hub method)
(celery.worker.components.Pool method)
(celery.worker.components.StateDB method)
(celery.worker.components.Timer method)
(celery.worker.consumer.Agent method)
(celery.worker.consumer.agent.Agent method)
create_exception_cls() (in module celery.utils.serialization)
create_parser() (celery.bin.base.Command method)
create_pidlock() (in module celery.platforms)
create_session() (celery.backends.database.session.SessionManager method)
create_task_handler() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
create_task_message (celery.app.amqp.AMQP attribute)
crontab (class in celery.schedules)
crontab_parser (class in celery.schedules)
crontab_parser.ParseException
current_app (in module celery)
current_task (celery.Celery attribute)
(in module celery)
current_worker_task (celery.Celery attribute)
CursesMonitor (class in celery.events.cursesmon)
cwd_in_path() (in module celery.utils.imports)
cyan() (celery.utils.term.colored method)
CycleError

D

daemon_options() (in module celery.bin.base)
DaemonContext (class in celery.platforms)
data (celery.apps.multi.Cluster attribute)
(celery.worker.control.Panel attribute)
database (celery.backends.mongodb.MongoBackend attribute)
database_name (celery.backends.mongodb.MongoBackend attribute)
DatabaseBackend (class in celery.backends.database)
date_done (celery.backends.database.models.Task attribute)
(celery.backends.database.models.TaskSet attribute)
day_of_month (celery.schedules.crontab attribute)
day_of_week (celery.schedules.crontab attribute)
db (celery.backends.redis.RedisBackend attribute)
(celery.worker.state.Persistent attribute)
debug() (celery.bin.logtool.logtool method)
debugger() (in module celery.contrib.rdb)
declare() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Exchange method)
(celery.backends.rpc.BaseRPCBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
(queue method)
decode() (celery.backends.mongodb.MongoBackend method)
decompress() (celery.worker.state.Persistent method)
dedent() (in module celery.utils.text)
dedent_initial() (in module celery.utils.text)
default() (celery.bin.amqp.AMQShell method)
(in module celery.worker.strategy)
default_app (in module celery.app)
default_dispatcher() (celery.events.Events method)
default_exchange (celery.app.amqp.AMQP attribute)
default_nodename() (in module celery.utils.nodenames)
(in module celery.worker)
default_queue (celery.app.amqp.AMQP attribute)
default_retry_delay (celery.app.task.Task attribute)
(Task attribute)
default_socket_timeout() (in module celery.utils.threads)
default_steps (celery.bootsteps.Blueprint attribute)
(celery.worker.WorkController.Blueprint attribute)
(celery.worker.consumer.Consumer.Blueprint attribute)
(celery.worker.consumer.consumer.Consumer.Blueprint attribute)
defaults (celery.utils.collections.ChainMap attribute)
delay() (celery.app.task.Task method)
(celery.utils.abstract.CallableTask method)
delete() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.riak.RiakBackend method)
(celery.backends.rpc.BaseRPCBackend.Exchange method)
(celery.result.GroupResult method)
(exchange method)
(queue method)
delete_group() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.BaseRPCBackend method)
deleter() (celery.utils.cached_property method)
delivery_info (celery.worker.request.Request attribute)
delivery_mode (celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.rpc.BaseRPCBackend.Exchange attribute), [1]
delta_resolution() (in module celery.utils.time)
DependencyGraph (class in celery.utils.graph)
deprecate_by (celery.app.defaults.Option attribute)
description (celery.bin.base.Command attribute)
deselect() (celery.app.amqp.Queues method)
deserialize() (celery.security.serialization.SecureSerializer method)
destination_for() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.RPCBackend method)
detached() (in module celery.platforms)
df (class in celery.utils.sysinfo)
DictAttribute (class in celery.utils.collections)
dictfilter() (in module celery.utils.functional)
did_start_ok() (celery.concurrency.base.BasePool method)
(celery.concurrency.prefork.TaskPool method)
die() (celery.bin.base.Command method)
DIRS (celery.utils.graph.DOT attribute)
disable() (celery.events.EventDispatcher method)
disable_events
control
disable_events() (celery.app.control.Control method)
disable_trace() (in module celery.app)
DISABLED_TRANSPORTS (celery.events.EventDispatcher attribute)
DisabledBackend (class in celery.backends.base)
discard() (celery.result.ResultSet method)
(celery.utils.collections.LimitedSet method)
discard_all() (celery.app.control.Control method)
disconnect() (celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
dispatch() (celery.bin.amqp.AMQShell method)
Dispatcher (celery.events.Events attribute)
display_command_help() (celery.bin.amqp.AMQShell method)
display_height (celery.events.cursesmon.CursesMonitor attribute)
display_task_row() (celery.events.cursesmon.CursesMonitor method)
display_width (celery.events.cursesmon.CursesMonitor attribute)
DJANGO_SETTINGS_MODULE, [1], [2], [3], [4]
do_exit() (celery.bin.amqp.AMQShell method)
do_help() (celery.bin.amqp.AMQShell method)
doc (celery.bin.base.Command attribute)
(celery.bin.beat.beat attribute)
(celery.bin.events.events attribute)
(celery.bin.worker.worker attribute)
doc_type (celery.backends.elasticsearch.ElasticsearchBackend attribute)
DOT (class in celery.utils.graph)
DOWN (celery.bin.multi.MultiTool attribute)
drain_events() (celery.backends.amqp.AMQPBackend method)
(celery.backends.async.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer method)
drain_events_until() (celery.backends.async.BaseResultConsumer method)
(celery.backends.async.Drainer method)
Drainer (class in celery.backends.async)
draw() (celery.events.cursesmon.CursesMonitor method)
draw_edge() (celery.utils.graph.GraphFormatter method)
draw_node() (celery.utils.graph.GraphFormatter method)
dst() (celery.utils.time.LocalTimezone method)
dump_body() (in module celery.worker.consumer.consumer)
Dumper (class in celery.events.dumper)
DuplicateNodenameWarning
durable (celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.rpc.BaseRPCBackend.Exchange attribute), [1]

E

EagerResult (class in celery.result)
early ack
early acknowledgment
early_version() (celery.bin.base.Command method)
EDGE (celery.utils.graph.DOT attribute)
edge() (celery.utils.graph.GraphFormatter method)
edge_scheme (celery.utils.graph.GraphFormatter attribute)
edges() (celery.utils.graph.DependencyGraph method)
ElasticsearchBackend (class in celery.backends.elasticsearch)
election() (celery.app.control.Control method)
(celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
embed() (celery.utils.term.colored method)
EmbeddedService() (in module celery.beat)
empty() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
enable() (celery.events.EventDispatcher method)
enable_config_from_cmdline (celery.bin.base.Command attribute)
(celery.bin.beat.beat attribute)
(celery.bin.celery.CeleryCommand attribute)
(celery.bin.worker.worker attribute)
enable_events
control
enable_events() (celery.app.control.Control method)
enable_trace() (in module celery.app)
enable_utc
setting
enabled (celery.bootsteps.Step attribute)
encode() (celery.backends.mongodb.MongoBackend method)
ensure() (celery.backends.redis.RedisBackend method)
ensure_sep() (in module celery.utils.text)
ensure_started() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
enter() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
enter_after() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
Entry (celery.beat.Scheduler attribute)
(class in celery.utils.timer2)
environment variable
AWS_ACCESS_KEY_ID
AWS_SECRET_ACCESS_KEY
CELERYCTL
CELERYD_SU_ARGS
CELERY_BENCH
CELERY_BROKER_URL
CELERY_CHDIR
CELERY_CONFIG_MODULE, [1], [2]
CELERY_CREATE_DIRS
CELERY_LOADER, [1], [2], [3], [4], [5]
CELERY_RDBSIG
CELERY_RDB_HOST, [1]
CELERY_RDB_PORT, [1]
CELERY_SU
CELERY_TRACE_APP, [1], [2]
C_FAKEFORK, [1], [2], [3], [4]
C_FORCE_ROOT, [1]
C_IMPDEBUG
DJANGO_SETTINGS_MODULE, [1], [2], [3], [4]
MP_LOG, [1]
NOSE_VERBOSE
USE_FAST_LOCALS
epilog (celery.bin.base.Command attribute)
errbacks (celery.worker.request.Request attribute)
Error
error() (celery.bin.base.Command method)
errors() (celery.bin.logtool.logtool method)
ETA
eta (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.worker.request.Request attribute)
evaluate() (celery.utils.functional.lazy method)
(celery.utils.functional.mlazy method)
evaluated (celery.utils.functional.mlazy attribute)
evcam() (in module celery.events.snapshot)
evdump() (in module celery.events.dumper)
event
task-failed
task-received
task-rejected
task-retried
task-revoked
task-sent
task-started
task-succeeded
worker-heartbeat
worker-offline
worker-online
event (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
event() (celery.events.state.State method)
(celery.events.state.State.Task method)
(celery.events.state.Task method)
Event() (in module celery.events)
event_count (celery.events.state.State attribute)
event_dispatcher
event_from_message() (celery.events.EventReceiver method)
event_queue_expires
setting
event_queue_prefix
setting
event_queue_ttl
setting
event_serializer
setting
EventDispatcher (class in celery.events)
eventer (celery.worker.request.Request attribute)
eventlet_pool_apply
signal
eventlet_pool_postshutdown
signal
eventlet_pool_preshutdown
signal
eventlet_pool_started
signal
eventletDrainer (class in celery.backends.async)
EventReceiver (class in celery.events)
events (celery.Celery attribute)
(class in celery.bin.events)
Events (class in celery.events)
(class in celery.worker.consumer)
(class in celery.worker.consumer.events)
evict() (celery.utils.collections.Evictable method)
Evictable (class in celery.utils.collections)
Evictable.Empty
Evloop (class in celery.worker.consumer.consumer)
evtop() (in module celery.events.cursesmon)
exc (celery.exceptions.Retry attribute)
exc_args (celery.utils.serialization.UnpickleableExceptionWrapper attribute)
exc_cls_name (celery.utils.serialization.UnpickleableExceptionWrapper attribute)
exc_module (celery.utils.serialization.UnpickleableExceptionWrapper attribute)
exception (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
EXCEPTION_STATES
state
exchange (celery.app.control.Control.Mailbox attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
exchange_fmt (celery.app.control.Control.Mailbox attribute)
executable (celery.apps.multi.Node attribute)
(celery.bin.multi.MultiTool.MultiParser.Node attribute)
execute() (celery.bin.celery.CeleryCommand method)
(celery.worker.request.Request method)
execute_from_commandline() (celery.bin.base.Command method)
(celery.bin.celery.CeleryCommand method)
(celery.bin.multi.MultiTool method)
execute_using_pool() (celery.worker.request.Request method)
executing
exit_after() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
exitcode (celery.worker.WorkController attribute)
expand() (celery.bin.multi.MultiTool method)
expand_destination() (celery.app.routes.Router method)
expanduser() (celery.bin.base.Command method)
expire() (celery.backends.redis.RedisBackend method)
expire_window (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
expires (celery.app.task.Task attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.worker.request.Request attribute)
expires_delta (celery.backends.mongodb.MongoBackend attribute)
ext_fmt (celery.bin.celery.CeleryCommand attribute)
extend() (celery.utils.collections.BufferMap method)
(celery.utils.collections.Messagebuffer method)
extend_buffer() (celery.events.EventDispatcher method)
Extensions (class in celery.bin.base)
extra_info() (celery.apps.worker.Worker method)

F

FAILED (celery.bin.multi.MultiTool attribute)
failed (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
failed() (celery.result.AsyncResult method)
(celery.result.ResultSet method)
FAILURE
state
FAILURE (in module celery.states)
FallbackContext (class in celery.utils.objects)
fd_by_path() (in module celery.platforms)
ffwd (class in celery.utils.time)
FilesystemBackend (class in celery.backends.filesystem)
fill_paragraphs() (in module celery.utils.text)
filter_hidden_settings() (in module celery.app.utils)
filter_types() (celery.app.registry.TaskRegistry method)
filtered (celery.contrib.migrate.State attribute)
finalize() (celery.Celery method)
find() (celery.apps.multi.Cluster method)
(in module celery.app.defaults)
find_app() (celery.bin.base.Command method)
(in module celery.app.utils)
find_module() (celery.loaders.base.BaseLoader method)
(in module celery.utils.imports)
find_option() (celery.app.utils.Settings method)
find_pickleable_exception() (in module celery.utils.serialization)
find_position() (celery.events.cursesmon.CursesMonitor method)
find_value_for_key() (celery.app.utils.Settings method)
first() (celery.utils.collections.ConfigurationView method)
(in module celery.utils.functional)
firstmethod() (in module celery.utils.functional)
FixupWarning
flatten() (in module celery.app.defaults)
flatten_reply() (in module celery.app.control)
flow() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
flush() (celery.concurrency.base.BasePool method)
(celery.events.EventDispatcher method)
(celery.utils.log.LoggingProxy method)
flush_routes() (celery.app.amqp.AMQP method)
FMT() (celery.utils.graph.GraphFormatter method)
force_mapping() (in module celery.utils.collections)
foreground (celery.events.cursesmon.CursesMonitor attribute)
forget() (celery.result.AsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
format() (celery.app.amqp.Queues method)
(celery.app.log.TaskFormatter method)
(celery.utils.graph.DependencyGraph method)
(celery.utils.log.ColorFormatter method)
format_arg() (celery.bin.amqp.Spec method)
format_description() (celery.bin.base.HelpFormatter method)
format_epilog() (celery.bin.base.HelpFormatter method)
format_response() (celery.bin.amqp.Spec method)
format_row() (celery.events.cursesmon.CursesMonitor method)
format_signature() (celery.bin.amqp.Spec method)
format_task_event() (celery.events.dumper.Dumper method)
formatException() (celery.utils.log.ColorFormatter method)
freeze() (celery.utils.abstract.CallableSignature method)
(State method)
freeze_while() (celery.events.state.State method)
(State method)
freq (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
from_exception() (celery.utils.serialization.UnpickleableExceptionWrapper class method)
from_kwargs() (celery.apps.multi.Node class method)
(celery.bin.multi.MultiTool.MultiParser.Node class method)
fromkeys() (celery.utils.collections.ChainMap class method)
FSCertStore (class in celery.security.certificate)
fun (celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)

G

gen_task_name() (celery.Celery method)
(in module celery.utils)
(in module celery.utils.imports)
get() (celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.riak.RiakBackend method)
(celery.bin.multi.MultiTool method)
(celery.result.AsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
(celery.utils.collections.ChainMap method)
(celery.utils.collections.ConfigurationView method)
(celery.utils.collections.DictAttribute method)
get_amqp_api_command() (celery.bin.amqp.AMQShell method)
get_backend_by_url() (in module celery.backends)
get_backend_cls() (in module celery.backends)
get_by_parts() (celery.app.utils.Settings method)
get_cls_by_name() (celery.bin.base.Command method)
get_command_info() (celery.bin.celery.CeleryCommand class method)
get_consumers() (celery.bootsteps.ConsumerStep method)
(celery.events.EventReceiver method)
(celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
get_current_app() (in module celery._state)
get_current_task() (in module celery._state)
get_current_worker_task() (in module celery._state)
get_default_logger() (celery.app.log.Logging method)
get_engine() (celery.backends.database.session.SessionManager method)
get_errno_name() (in module celery.platforms)
get_fdmax() (in module celery.platforms)
get_id() (celery.security.certificate.Certificate method)
get_ident() (celery.utils.threads.LocalManager method)
(in module celery.utils.threads)
get_implementation() (in module celery.concurrency)
get_issuer() (celery.security.certificate.Certificate method)
get_leaf() (celery.result.AsyncResult method)
get_loader_cls() (in module celery.loaders)
get_logger() (in module celery.utils.log)
get_many() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.DisabledBackend method)
get_multiprocessing_logger() (in module celery.utils.log)
get_names() (celery.bin.amqp.AMQShell method)
get_opt_string() (celery.bin.base.Option method)
get_options() (celery.bin.base.Command method)
get_or_create_task() (celery.events.state.State method)
get_or_create_worker() (celery.events.state.State method)
get_pickleable_etype() (in module celery.utils.serialization)
get_pickleable_exception() (in module celery.utils.serialization)
get_pickled_exception() (in module celery.utils.serialization)
get_queue() (celery.app.control.Control.Mailbox method)
get_reply_queue() (celery.app.control.Control.Mailbox method)
get_result() (celery.backends.base.DisabledBackend method)
get_schedule() (celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
get_scheduler() (celery.apps.beat.Beat.Service method)
(celery.beat.Service method)
get_serial_number() (celery.security.certificate.Certificate method)
get_state() (celery.backends.base.DisabledBackend method)
get_status() (celery.backends.base.DisabledBackend method)
get_task_logger() (in module celery.utils.log)
get_task_meta() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.BaseRPCBackend method)
get_traceback() (celery.backends.base.DisabledBackend method)
gethostname() (in module celery.utils.nodenames)
getopt() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
getpids() (celery.apps.multi.Cluster method)
geventDrainer (class in celery.backends.async)
gossip
Gossip (class in celery.worker.consumer)
(class in celery.worker.consumer.gossip)
gPidbox (class in celery.worker.pidbox)
graph (celery.result.AsyncResult attribute)
(class in celery.bin.graph)
graph_scheme (celery.utils.graph.GraphFormatter attribute)
GraphFormatter (celery.bootsteps.Blueprint attribute)
(class in celery.utils.graph)
green() (celery.utils.term.colored method)
greenletDrainer (class in celery.backends.async)
greet (celery.events.cursesmon.CursesMonitor attribute)
group (celery.worker.request.Request attribute)
(class in celery)
group_collection (celery.backends.mongodb.MongoBackend attribute)
groupmeta_collection (celery.backends.mongodb.MongoBackend attribute)
GroupResult (celery.Celery attribute)
(class in celery.result)
grow() (celery.concurrency.eventlet.TaskPool method)
(celery.concurrency.gevent.TaskPool method)

H

handle_argv() (celery.bin.base.Command method)
(celery.bin.celery.CeleryCommand method)
handle_error_state() (celery.app.trace.TraceInfo method)
handle_failure() (celery.app.trace.TraceInfo method)
handle_ignore() (celery.app.trace.TraceInfo method)
handle_keypress() (celery.events.cursesmon.CursesMonitor method)
handle_process_exit() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
handle_reject() (celery.app.trace.TraceInfo method)
handle_retry() (celery.app.trace.TraceInfo method)
has_expired() (celery.security.certificate.Certificate method)
HEAD (celery.utils.graph.DOT attribute)
head() (celery.utils.graph.GraphFormatter method)
head_from_fun() (in module celery.utils.functional)
heap_multiplier (celery.events.state.State attribute)
heart
Heart (class in celery.worker.consumer)
(class in celery.worker.consumer.heart)
(class in celery.worker.heartbeat)
heartbeat_expires (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
heartbeat_expires() (in module celery.events.state)
heartbeat_max (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
heartbeat_sent
signal
heartbeats (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
hello() (celery.app.control.Inspect method)
help (celery.events.cursesmon.CursesMonitor attribute)
help() (celery.bin.multi.MultiTool method)
help_title (celery.events.cursesmon.CursesMonitor attribute)
HelpFormatter (class in celery.bin.base)
host (celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.elasticsearch.ElasticsearchBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.backends.riak.RiakBackend attribute)
host_format() (celery.bin.base.Command method)
(in module celery.utils.nodenames)
hostname, [1]
(celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
(celery.worker.request.Request attribute)
hour (celery.schedules.crontab attribute)
hub, [1]
Hub (class in celery.worker.components)
human_seconds (celery.schedules.schedule attribute)
human_state() (celery.bootsteps.Blueprint method)
humaninfo() (celery.worker.request.Request method)
humanize() (celery.app.utils.Settings method)
(celery.exceptions.Retry method)
humanize_seconds() (in module celery.utils.time)

I

iblue() (celery.utils.term.colored method)
icyan() (celery.utils.term.colored method)
id (celery.backends.database.models.Task attribute)
(celery.backends.database.models.TaskSet attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.State.Worker attribute)
(celery.events.state.Task attribute)
(celery.events.state.Worker attribute)
(celery.result.AsyncResult attribute)
(celery.result.GroupResult attribute)
(celery.utils.abstract.CallableSignature attribute)
(celery.worker.request.Request attribute)
idempotent
identchars (celery.bin.amqp.AMQShell attribute)
Ignore
ignore_errno() (in module celery.platforms)
ignore_result (celery.app.task.Task attribute)
(Task attribute)
igreen() (celery.utils.term.colored method)
imagenta() (celery.utils.term.colored method)
immutable (celery.utils.abstract.CallableSignature attribute)
implements_incr (celery.backends.cache.CacheBackend attribute)
import_default_modules() (celery.loaders.base.BaseLoader method)
import_from_cwd() (celery.loaders.base.BaseLoader method)
(in module celery.utils.imports)
import_module() (celery.loaders.base.BaseLoader method)
import_modules
signal
import_task_module() (celery.loaders.base.BaseLoader method)
imports
setting
ImproperlyConfigured
in_sighandler() (in module celery.utils.log)
inc_counter (celery.bin.amqp.AMQShell attribute)
include
setting
include() (celery.bootsteps.StartStopStep method)
(celery.bootsteps.Step method)
include_if() (celery.bootsteps.Step method)
(celery.worker.components.Hub method)
(celery.worker.consumer.Control method)
(celery.worker.consumer.control.Control method)
incomplete() (celery.bin.logtool.logtool method)
IncompleteStream
incr() (celery.backends.cache.CacheBackend method)
(celery.backends.redis.RedisBackend method)
(celery.utils.functional.LRUCache method)
indent() (in module celery.utils.text)
index (celery.backends.elasticsearch.ElasticsearchBackend attribute)
info (celery.beat.PersistentScheduler attribute)
(celery.beat.Scheduler attribute)
(celery.concurrency.base.BasePool attribute)
(celery.result.AsyncResult attribute)
info() (celery.bootsteps.Blueprint method)
(celery.bootsteps.Step method)
(celery.events.state.State.Task method)
(celery.events.state.Task method)
(celery.worker.WorkController method)
(celery.worker.components.Pool method)
(celery.worker.consumer.Connection method)
(celery.worker.consumer.Tasks method)
(celery.worker.consumer.connection.Connection method)
(celery.worker.consumer.tasks.Tasks method)
(celery.worker.request.Request method)
info_str (celery.events.cursesmon.CursesMonitor attribute)
init_callback (celery.worker.consumer.Consumer attribute)
(celery.worker.consumer.consumer.Consumer attribute)
init_loader() (celery.apps.beat.Beat method)
init_screen() (celery.events.cursesmon.CursesMonitor method)
init_worker() (celery.loaders.base.BaseLoader method)
init_worker_process() (celery.loaders.base.BaseLoader method)
initgroups() (in module celery.platforms)
inspect (celery.app.control.Control attribute)
Inspect (class in celery.app.control)
install() (celery.events.snapshot.Polaroid method)
install_default_entries() (celery.beat.Scheduler method)
install_platform_tweaks() (celery.apps.worker.Worker method)
install_sync_handler() (celery.apps.beat.Beat method)
instantiate() (celery.bootsteps.Step method)
(in module celery.utils.imports)
InvalidTaskError
ired() (celery.utils.term.colored method)
is_aborted() (celery.contrib.abortable.AbortableAsyncResult method)
(celery.contrib.abortable.AbortableTask method)
is_ascii() (in module celery.backends.riak)
is_async (celery.backends.async.AsyncBackendMixin attribute)
is_due() (celery.beat.ScheduleEntry method)
(celery.beat.Scheduler method)
(celery.schedules.crontab method)
(celery.schedules.schedule method)
(celery.schedules.solar method)
is_green (celery.concurrency.base.BasePool attribute)
(celery.concurrency.eventlet.TaskPool attribute)
(celery.concurrency.gevent.TaskPool attribute)
is_list() (in module celery.utils.functional)
is_locked() (celery.platforms.Pidfile method)
is_naive() (in module celery.utils.time)
isatty() (celery.utils.log.LoggingProxy method)
(in module celery.platforms)
items() (celery.utils.collections.ChainMap method)
(celery.utils.collections.DictAttribute method)
(celery.utils.functional.LRUCache method)
(celery.utils.graph.DependencyGraph method)
iter_native() (celery.backends.async.AsyncBackendMixin method)
(celery.result.ResultSet method)
iterate() (celery.result.ResultSet method)
itercapture() (celery.events.EventReceiver method)
itercerts() (celery.security.certificate.CertStore method)
iterdeps() (celery.result.AsyncResult method)
iteritems() (celery.utils.collections.ChainMap method)
(celery.utils.collections.DictAttribute method)
(celery.utils.functional.LRUCache method)
(celery.utils.graph.DependencyGraph method)
iterkeys() (celery.utils.collections.ChainMap method)
(celery.utils.collections.DictAttribute method)
(celery.utils.functional.LRUCache method)
itertasks() (celery.events.state.State method)
itervalues() (celery.utils.collections.ChainMap method)
(celery.utils.collections.DictAttribute method)
(celery.utils.functional.LRUCache method)
iwhite() (celery.utils.term.colored method)
iyellow() (celery.utils.term.colored method)

J

join() (celery.bootsteps.Blueprint method)
(celery.result.ResultSet method)
(in module celery.utils.text)
join_native() (celery.result.ResultSet method)

K

key_t (celery.backends.couchbase.CouchbaseBackend attribute)
(celery.utils.collections.ChainMap attribute)
keyalias (celery.events.cursesmon.CursesMonitor attribute)
keymap (celery.events.cursesmon.CursesMonitor attribute)
keys() (celery.utils.collections.ChainMap method)
(celery.utils.collections.DictAttribute method)
(celery.utils.functional.LRUCache method)
KeyValueStoreBackend (class in celery.backends.base)
kill() (celery.apps.multi.Cluster method)
(celery.bin.multi.MultiTool method)
known_suffixes (celery.beat.PersistentScheduler attribute)
kombu
kwargs (celery.beat.ScheduleEntry attribute)
(celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.utils.abstract.CallableSignature attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
kwargsrepr (celery.worker.request.Request attribute)

L

label (celery.bootsteps.Step attribute)
(celery.worker.components.Beat attribute)
(celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.Mingle attribute)
(celery.worker.consumer.consumer.Evloop attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.mingle.Mingle attribute)
label() (celery.utils.graph.GraphFormatter method)
last (celery.bootsteps.Step attribute)
(celery.worker.components.Consumer attribute)
(celery.worker.consumer.consumer.Evloop attribute)
last_run_at (celery.beat.ScheduleEntry attribute)
late ack
late acknowledgment
lazy (class in celery.utils.functional)
leaf (celery.bin.base.Command attribute)
limit (celery.events.cursesmon.CursesMonitor attribute)
LimitedSet (class in celery.utils.collections)
link() (celery.utils.abstract.CallableSignature method)
link_error() (celery.utils.abstract.CallableSignature method)
list_commands() (celery.bin.celery.CeleryCommand class method)
load() (celery.bin.base.Extensions method)
load_average() (in module celery.utils.sysinfo)
load_extension_commands() (celery.bin.celery.CeleryCommand method)
load_step() (celery.bootsteps.Blueprint method)
loadavg (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
loader (celery.Celery attribute)
Loader (class in celery.loaders.default)
Local (class in celery.utils.threads)
localize() (in module celery.utils.time)
LocalManager (class in celery.utils.threads)
LocalStack (in module celery.utils.threads)
LocalTimezone (class in celery.utils.time)
LockFailed
log (celery.Celery attribute)
logfile (celery.apps.multi.Node attribute)
(celery.bin.multi.MultiTool.MultiParser.Node attribute)
logger (celery.beat.Scheduler attribute)
Logging (class in celery.app.log)
LoggingProxy (class in celery.utils.log)
loglevel (celery.utils.log.LoggingProxy attribute)
logtool (class in celery.bin.logtool)
lookup_route() (celery.app.routes.Router method)
loop() (celery.worker.pidbox.gPidbox method)
loop_args() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
lpmerge() (in module celery.utils.collections)
LRUCache (class in celery.utils.functional)

M

macOS_proxy_detection_workaround() (celery.apps.worker.Worker method)
magenta() (celery.utils.term.colored method)
main() (in module celery.bin.celery)
(in module celery.bin.worker)
maintain_pool() (celery.concurrency.base.BasePool method)
make_aware() (in module celery.utils.time)
map() (celery.app.task.Task method)
MapAnnotation (class in celery.app.annotations)
MapRoute (class in celery.app.routes)
maps (celery.utils.collections.ChainMap attribute)
mattrgetter() (in module celery.utils.functional)
max_connections (celery.backends.redis.RedisBackend attribute)
max_heap_percent_overload (celery.utils.collections.LimitedSet attribute)
max_interval (celery.beat.Scheduler attribute)
max_pool_size (celery.backends.mongodb.MongoBackend attribute)
max_retries (celery.app.task.Task attribute)
(Task attribute)
MaxRetriesExceededError
maxsize (celery.utils.collections.BufferMap attribute)
maybe() (in module celery.utils.functional)
maybe_declare() (celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.Producer method)
maybe_detach() (celery.bin.worker.worker method)
maybe_drop_privileges() (in module celery.platforms)
maybe_evaluate() (in module celery.utils.functional)
maybe_expire() (celery.worker.request.Request method)
maybe_iso8601() (in module celery.utils.time)
maybe_list() (in module celery.utils.functional)
maybe_make_aware() (celery.schedules.schedule method)
(in module celery.utils.time)
maybe_patch_concurrency() (celery.bin.base.Command method)
maybe_s_to_ms() (in module celery.utils.time)
maybe_schedule() (in module celery.schedules)
maybe_shutdown() (in module celery.worker.state)
maybe_throw() (celery.result.AsyncResult method)
(celery.result.ResultSet method)
maybe_timedelta() (in module celery.utils.time)
mem_rss() (in module celery.utils.debug)
memdump() (celery.app.control.Inspect method)
(in module celery.utils.debug)
memoize() (in module celery.utils.functional)
memsample() (celery.app.control.Inspect method)
merge() (celery.worker.state.Persistent method)
merge_inplace() (celery.beat.Scheduler method)
merge_rules (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
message (celery.exceptions.Retry attribute)
Message() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.rpc.BaseRPCBackend.Exchange method)
Messagebuffer (class in celery.utils.collections)
Messagebuffer.Empty
meta (celery.worker.control.Panel attribute)
mget() (celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.riak.RiakBackend method)
migrate_task() (in module celery.contrib.migrate)
migrate_tasks() (in module celery.contrib.migrate)
Mingle (class in celery.worker.consumer)
(class in celery.worker.consumer.mingle)
minute (celery.schedules.crontab attribute)
mlazy (class in celery.utils.functional)
mlevel() (in module celery.utils.log)
mode (celery.utils.log.LoggingProxy attribute)
module_file() (in module celery.utils.imports)
mongo_host (celery.backends.mongodb.MongoBackend attribute)
MongoBackend (class in celery.backends.mongodb)
month_of_year (celery.schedules.crontab attribute)
move() (in module celery.contrib.migrate)
move_by_idmap() (in module celery.contrib.migrate)
move_by_taskmap() (in module celery.contrib.migrate)
move_selection() (celery.events.cursesmon.CursesMonitor method)
move_selection_down() (celery.events.cursesmon.CursesMonitor method)
move_selection_up() (celery.events.cursesmon.CursesMonitor method)
move_task_by_id() (in module celery.contrib.migrate)
move_to_end() (celery.utils.collections.OrderedDict method)
MP_LOG, [1]
mro_lookup() (in module celery.utils.objects)
multi_call() (celery.app.control.Control.Mailbox method)
MultiTool (class in celery.bin.multi)
MultiTool.MultiParser (class in celery.bin.multi)
MultiTool.MultiParser.Node (class in celery.bin.multi)

N

name (celery.app.task.Task attribute)
(Task attribute)
(celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.rpc.BaseRPCBackend.Exchange attribute), [1]
(celery.beat.ScheduleEntry attribute)
(celery.bootsteps.Blueprint attribute)
(celery.bootsteps.ConsumerStep attribute)
(celery.bootsteps.StartStopStep attribute)
(celery.bootsteps.Step attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.utils.abstract.CallableSignature attribute)
(celery.utils.log.LoggingProxy attribute)
(celery.worker.WorkController.Blueprint attribute)
(celery.worker.components.Beat attribute)
(celery.worker.components.Consumer attribute)
(celery.worker.components.Hub attribute)
(celery.worker.components.Pool attribute)
(celery.worker.components.StateDB attribute)
(celery.worker.components.Timer attribute)
(celery.worker.consumer.Agent attribute)
(celery.worker.consumer.Connection attribute)
(celery.worker.consumer.Consumer.Blueprint attribute)
(celery.worker.consumer.Control attribute)
(celery.worker.consumer.Events attribute)
(celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.Heart attribute)
(celery.worker.consumer.Mingle attribute)
(celery.worker.consumer.Tasks attribute)
(celery.worker.consumer.agent.Agent attribute)
(celery.worker.consumer.connection.Connection attribute)
(celery.worker.consumer.consumer.Consumer.Blueprint attribute)
(celery.worker.consumer.consumer.Evloop attribute)
(celery.worker.consumer.control.Control attribute)
(celery.worker.consumer.events.Events attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.heart.Heart attribute)
(celery.worker.consumer.mingle.Mingle attribute)
(celery.worker.consumer.tasks.Tasks attribute)
(celery.worker.request.Request attribute)
names() (celery.bin.multi.MultiTool method)
namespace (celery.app.control.Control.Mailbox attribute)
(celery.bin.base.Command attribute)
(celery.bin.celery.CeleryCommand attribute)
(celery.bin.worker.worker attribute)
nap() (celery.events.cursesmon.CursesMonitor method)
needs_reconnect (celery.bin.amqp.AMQShell attribute)
new_missing() (celery.app.amqp.Queues method)
next() (celery.beat.ScheduleEntry method)
(celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
no_ack (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
no_color (celery.bin.base.Command attribute)
no_color() (celery.utils.term.colored method)
no_declare (celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.rpc.BaseRPCBackend.Exchange attribute), [1]
NODE (celery.utils.graph.DOT attribute)
Node (class in celery.apps.multi)
Node() (celery.app.control.Control.Mailbox method)
node() (celery.utils.graph.GraphFormatter method)
(celery.utils.term.colored method)
node_cls (celery.app.control.Control.Mailbox attribute)
node_format() (celery.bin.base.Command method)
(in module celery.utils.nodenames)
node_scheme (celery.utils.graph.GraphFormatter attribute)
nodename() (in module celery.utils)
(in module celery.utils.nodenames)
nodesplit() (in module celery.utils)
(in module celery.utils.nodenames)
noop() (in module celery.utils.functional)
NOSE_VERBOSE
NotAPackage
NotConfigured
note() (celery.bin.amqp.AMQPAdmin method)
(celery.bin.amqp.AMQShell method)
NotRegistered
now() (celery.Celery method)
(celery.loaders.base.BaseLoader method)
(celery.schedules.crontab method)
(celery.schedules.schedule method)
nowfun (celery.schedules.crontab attribute)
nullipotent
num_processes (celery.concurrency.base.BasePool attribute)
(celery.concurrency.gevent.TaskPool attribute)
(celery.concurrency.prefork.TaskPool attribute)

O

obj (celery.bootsteps.StartStopStep attribute)
(celery.utils.collections.DictAttribute attribute)
objgraph() (celery.app.control.Inspect method)
oid (celery.app.control.Control.Mailbox attribute)
(celery.Celery attribute)
(celery.backends.rpc.RPCBackend attribute)
OK (celery.bin.multi.MultiTool attribute)
old (celery.app.defaults.Option attribute)
on_accepted() (celery.worker.request.Request method)
on_ack (celery.worker.request.Request attribute)
on_after_fork() (celery.backends.async.BaseResultConsumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer method)
on_after_init() (celery.apps.worker.Worker method)
(celery.worker.WorkController method)
on_apply() (celery.concurrency.base.BasePool method)
(celery.concurrency.eventlet.TaskPool method)
(celery.concurrency.gevent.TaskPool method)
on_before_init() (celery.apps.worker.Worker method)
(celery.worker.WorkController method)
on_bound() (celery.app.task.Task class method)
on_child_failure() (celery.bin.multi.MultiTool method)
on_child_signalled() (celery.bin.multi.MultiTool method)
on_child_spawn() (celery.bin.multi.MultiTool method)
on_chord_part_return() (celery.backends.redis.RedisBackend method)
on_cleanup() (celery.events.snapshot.Polaroid method)
on_clock_event() (celery.worker.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle method)
on_close() (celery.concurrency.base.BasePool method)
(celery.concurrency.prefork.TaskPool method)
(celery.worker.WorkController method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_concurrency_setup() (celery.bin.base.Command method)
(celery.bin.celery.CeleryCommand method)
on_connection_error() (celery.backends.redis.RedisBackend method)
on_connection_error_after_connected() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_connection_error_before_connected() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_consume_ready() (celery.events.EventReceiver method)
on_consumer_ready() (celery.apps.worker.Worker method)
(celery.worker.WorkController method)
on_crash() (celery.utils.threads.bgThread method)
on_decode_error (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
on_decode_error() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_disabled (celery.events.EventDispatcher attribute)
on_elect() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
on_elect_ack() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
on_enabled (celery.events.EventDispatcher attribute)
on_error() (celery.bin.base.Command method)
on_event() (celery.events.dumper.Dumper method)
on_failure()
(celery.app.task.Task method)
(celery.worker.request.Request method)
on_hard_timeout() (celery.concurrency.base.BasePool method)
on_init() (celery.Celery method)
on_init_blueprint() (celery.apps.worker.Worker method)
(celery.worker.WorkController method)
on_invalid_task() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_message (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
on_message() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
(celery.worker.pidbox.Pidbox method)
on_node_down() (celery.bin.multi.MultiTool method)
on_node_join() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
on_node_leave() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
on_node_lost() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
on_node_reply() (celery.worker.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle method)
on_node_restart() (celery.bin.multi.MultiTool method)
on_node_shutdown_ok() (celery.bin.multi.MultiTool method)
on_node_signal() (celery.bin.multi.MultiTool method)
on_node_signal_dead() (celery.bin.multi.MultiTool method)
on_node_start() (celery.bin.multi.MultiTool method)
on_node_status() (celery.bin.multi.MultiTool method)
on_out_of_band_result() (celery.backends.async.BaseResultConsumer method)
(celery.backends.rpc.BaseRPCBackend method)
on_process_cleanup() (celery.loaders.base.BaseLoader method)
on_ready() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_reject (celery.worker.request.Request attribute)
on_reply_declare() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.RPCBackend method)
on_result_fulfilled() (celery.backends.async.AsyncBackendMixin method)
(celery.backends.rpc.RPCBackend method)
on_retry()
(celery.app.task.Task method)
(celery.worker.request.Request method)
on_return (celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
on_revoked_received() (celery.worker.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle method)
on_send_event_buffered() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_send_signal() (celery.bin.multi.MultiTool method)
on_shutter() (celery.events.snapshot.Polaroid method)
on_soft_timeout() (celery.concurrency.base.BasePool method)
on_start() (celery.apps.worker.Worker method)
(celery.concurrency.base.BasePool method)
(celery.concurrency.eventlet.TaskPool method)
(celery.concurrency.gevent.TaskPool method)
(celery.concurrency.prefork.TaskPool method)
(celery.worker.WorkController method)
on_state_change() (celery.backends.async.BaseResultConsumer method)
on_still_waiting_end() (celery.bin.multi.MultiTool method)
on_still_waiting_for() (celery.bin.multi.MultiTool method)
on_still_waiting_progress() (celery.bin.multi.MultiTool method)
on_stop() (celery.concurrency.base.BasePool method)
(celery.concurrency.eventlet.TaskPool method)
(celery.concurrency.gevent.TaskPool method)
(celery.concurrency.prefork.TaskPool method)
(celery.worker.pidbox.Pidbox method)
(celery.worker.pidbox.gPidbox method)
on_stopped() (celery.worker.WorkController method)
on_stopping_preamble() (celery.bin.multi.MultiTool method)
on_success()
(celery.app.task.Task method)
(celery.worker.request.Request method)
on_task_call() (celery.backends.redis.RedisBackend method)
(celery.backends.rpc.RPCBackend method)
on_task_init() (celery.loaders.base.BaseLoader method)
on_terminate() (celery.concurrency.base.BasePool method)
(celery.concurrency.prefork.TaskPool method)
on_tick (celery.concurrency.base.BasePool.Timer attribute)
(celery.utils.timer2.Timer attribute)
on_timeout() (celery.worker.request.Request method)
on_timer_error() (celery.worker.components.Timer method)
on_timer_tick() (celery.worker.components.Timer method)
on_unknown_message() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_unknown_task() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_usage_error() (celery.bin.base.Command method)
(celery.bin.celery.CeleryCommand method)
on_wait_for_pending() (celery.backends.async.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
on_worker_init() (celery.loaders.base.BaseLoader method)
on_worker_process_init() (celery.loaders.base.BaseLoader method)
on_worker_shutdown() (celery.loaders.base.BaseLoader method)
onecmd() (celery.bin.amqp.AMQShell method)
online_str (celery.events.cursesmon.CursesMonitor attribute)
open() (celery.platforms.DaemonContext method)
(celery.worker.state.Persistent method)
Option (class in celery.app.defaults)
(class in celery.bin.base)
option_list (celery.bin.base.Command attribute)
OptionParser (celery.bin.multi.MultiTool attribute)
options (celery.backends.mongodb.MongoBackend attribute)
(celery.beat.ScheduleEntry attribute)
(celery.utils.abstract.CallableSignature attribute)
OrderedDict (class in celery.utils.collections)
origin (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
out() (celery.bin.base.Command method)
override_backends (celery.loaders.base.BaseLoader attribute)

P

padlist() (in module celery.utils.functional)
Panel (class in celery.worker.control)
parent (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.result.ResultBase attribute)
parent_id (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.worker.request.Request attribute)
parse() (celery.bin.multi.MultiTool.MultiParser method)
(celery.schedules.crontab_parser method)
parse_doc() (celery.bin.base.Command method)
parse_gid() (in module celery.platforms)
parse_iso8601() (in module celery.utils.iso8601)
parse_options() (celery.bin.base.Command method)
parse_preload_options() (celery.bin.base.Command method)
parse_uid() (in module celery.platforms)
ParseException
parseline() (celery.bin.amqp.AMQShell method)
Parser (celery.bin.base.Command attribute)
passive (celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.rpc.BaseRPCBackend.Exchange attribute)
password (celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
(celery.backends.redis.RedisBackend attribute)
patch_all() (celery.worker.consumer.consumer.Evloop method)
path (celery.backends.consul.ConsulBackend attribute)
(celery.platforms.Pidfile attribute)
PENDING
state
PENDING (in module celery.states)
perform_pending_operations() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
periodic() (celery.app.registry.TaskRegistry method)
(celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
persistence (celery.beat.PersistentScheduler attribute)
persistent (celery.backends.amqp.AMQPBackend attribute)
(celery.backends.rpc.BaseRPCBackend attribute)
(celery.backends.rpc.RPCBackend attribute)
Persistent (class in celery.worker.state)
PERSISTENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.rpc.BaseRPCBackend.Exchange attribute)
PersistentScheduler (class in celery.beat)
pid (celery.apps.multi.Node attribute)
(celery.bin.multi.MultiTool.MultiParser.Node attribute)
(celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
pidbox
Pidbox (class in celery.worker.pidbox)
pidfile (celery.apps.multi.Node attribute)
(celery.bin.multi.MultiTool.MultiParser.Node attribute)
Pidfile (class in celery.platforms)
pidlock (celery.worker.WorkController attribute)
ping
control
ping() (celery.app.control.Control method)
(celery.app.control.Inspect method)
pluralize() (in module celery.utils.text)
Polaroid (class in celery.events.snapshot)
poll() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.BaseRPCBackend method)
pool, [1]
(celery.Celery attribute)
Pool (celery.concurrency.prefork.TaskPool attribute)
pool (celery.worker.consumer.Consumer attribute)
(celery.worker.WorkController attribute)
(celery.worker.consumer.consumer.Consumer attribute)
Pool (class in celery.worker.components)
pool_grow() (celery.app.control.Control method)
pool_shrink() (celery.app.control.Control method)
pop() (celery.utils.collections.ChainMap method)
(celery.utils.collections.LimitedSet method)
pop_value() (celery.utils.collections.LimitedSet method)
popitem() (celery.utils.functional.LRUCache method)
port (celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.elasticsearch.ElasticsearchBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.backends.riak.RiakBackend attribute)
precedence() (in module celery.states)
prefetch count
prefetch multiplier
prefetch_count (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
preload_options (celery.bin.base.Command attribute)
prepare() (in module celery.app.annotations)
(in module celery.app.routes)
prepare_args() (celery.bin.base.Command method)
(celery.worker.WorkController method)
prepare_arguments() (celery.bin.base.Command method)
(celery.bin.beat.beat method)
(celery.bin.events.events method)
(celery.bin.worker.worker method)
prepare_argv() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
prepare_config() (celery.Celery method)
prepare_models() (celery.backends.database.session.SessionManager method)
prepare_parser() (celery.bin.base.Command method)
prepare_prog_name() (celery.bin.celery.CeleryCommand method)
preparse_options() (celery.bin.base.Command method)
pretty() (celery.bin.base.Command method)
(in module celery.utils.text)
pretty_dict_ok_error() (celery.bin.base.Command method)
pretty_list() (celery.bin.base.Command method)
PrivateKey (class in celery.security.key)
process() (celery.bin.base.Option method)
(celery.events.EventReceiver method)
process_cleanup() (celery.backends.cassandra.CassandraBackend method)
process_cmdline_config() (celery.bin.base.Command method)
process_destructor() (in module celery.concurrency.prefork)
process_initializer() (in module celery.concurrency.prefork)
processed (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
Producer (celery.app.amqp.AMQP attribute)
producer (celery.beat.Scheduler attribute)
producer_or_acquire() (celery.app.control.Control.Mailbox method)
(celery.Celery method)
producer_pool (celery.app.amqp.AMQP attribute)
(celery.Celery attribute)
(celery.app.control.Control.Mailbox attribute)
prog_name (celery.bin.base.Command attribute)
(celery.bin.celery.CeleryCommand attribute)
prompt (celery.bin.amqp.AMQShell attribute)
prompt_fmt (celery.bin.amqp.AMQShell attribute)
PROPAGATE_STATES
state
Property() (in module celery.utils.deprecated)
protocol (celery.backends.riak.RiakBackend attribute)
(celery.worker.state.Persistent attribute)
ps() (in module celery.utils.debug)
publish() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.Exchange method)
(celery.backends.rpc.BaseRPCBackend.Producer method)
(celery.events.EventDispatcher method)
publisher (celery.events.EventDispatcher attribute)
purge() (celery.app.control.Control method)
(celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
(celery.utils.collections.LimitedSet method)
purge_messages() (celery.apps.worker.Worker method)
put() (celery.utils.collections.BufferMap method)
(celery.utils.collections.Messagebuffer method)
pyimplementation() (in module celery.platforms)
Python Enhancement Proposals
PEP 257
PEP 8, [1], [2]

Q

qos
qos() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
qualname() (in module celery.utils.imports)
query_router() (celery.app.routes.Router method)
query_task() (celery.app.control.Inspect method)
Queue (celery.backends.amqp.AMQPBackend attribute)
(celery.backends.rpc.BaseRPCBackend attribute)
queue (celery.concurrency.base.BasePool.Timer attribute)
(celery.concurrency.eventlet.TaskPool.Timer attribute)
(celery.concurrency.gevent.TaskPool.Timer attribute)
(celery.utils.timer2.Timer attribute)
QueueNotFound
queues (celery.app.amqp.AMQP attribute)
(celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.Consumer attribute)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer attribute)
Queues (class in celery.app.amqp)
Queues() (celery.app.amqp.AMQP method)
quiet (celery.backends.couchbase.CouchbaseBackend attribute)

R

rate() (in module celery.utils.time)
rate_limit
control
rate_limit (celery.app.task.Task attribute)
(Task attribute)
rate_limit() (celery.app.control.Control method)
Rdb (class in celery.contrib.rdb)
read_configuration() (celery.loaders.base.BaseLoader method)
(celery.loaders.default.Loader method)
read_pid() (celery.platforms.Pidfile method)
readline() (celery.events.cursesmon.CursesMonitor method)
ready (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
ready() (celery.result.AsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
READY_STATES
state
rebuild_taskheap() (celery.events.state.State method)
receive() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
received (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
RECEIVED (in module celery.states)
Receiver (celery.events.Events attribute)
receivers (celery.utils.dispatch.Signal attribute)
(celery.utils.dispatch.signal.Signal attribute)
recover() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
red() (celery.utils.term.colored method)
redirect_stdouts() (celery.app.log.Logging method)
redirect_stdouts_to_logger() (celery.app.log.Logging method)
redirect_to_null() (celery.platforms.DaemonContext method)
redis (celery.backends.redis.RedisBackend attribute)
redis_max_connections
setting
redis_socket_timeout
setting
RedisBackend (class in celery.backends.redis)
RedisBackend.ResultConsumer (class in celery.backends.redis)
reentrant
regen() (in module celery.utils.functional)
register() (celery.app.registry.TaskRegistry method)
(celery.worker.control.Panel class method)
register_auth() (in module celery.security.serialization)
register_callback() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
register_command() (celery.bin.celery.CeleryCommand class method)
register_drainer() (in module celery.backends.async)
register_timer() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
register_with_event_loop() (celery.concurrency.base.BasePool method)
(celery.concurrency.prefork.TaskPool method)
(celery.worker.WorkController method)
(celery.worker.components.Pool method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
registered() (celery.app.control.Inspect method)
registered_tasks() (celery.app.control.Inspect method)
regular() (celery.app.registry.TaskRegistry method)
Reject
reject() (celery.worker.request.Request method)
reject_on_worker_lost (celery.app.task.Task attribute)
rejected (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
relative (celery.schedules.schedule attribute)
release() (celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.Producer method)
(celery.platforms.Pidfile method)
reload() (celery.worker.WorkController method)
reload_from_cwd() (in module celery.utils.imports)
reload_group_result() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.BaseRPCBackend method)
reload_task_result() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.BaseRPCBackend method)
remaining() (in module celery.utils.time)
remaining_delta() (celery.schedules.crontab method)
remaining_estimate() (celery.schedules.crontab method)
(celery.schedules.schedule method)
(celery.schedules.solar method)
remove() (celery.platforms.Pidfile method)
(celery.result.ResultSet method)
(hub method)
remove_by (celery.app.defaults.Option attribute)
remove_if_stale() (celery.platforms.Pidfile method)
remove_pending_result() (celery.backends.async.AsyncBackendMixin method)
removed_flags (celery.bin.worker.worker attribute)
replace() (celery.app.task.Task method)
reply_exchange (celery.app.control.Control.Mailbox attribute)
reply_exchange_fmt (celery.app.control.Control.Mailbox attribute)
reply_queue (celery.app.control.Control.Mailbox attribute)
reply_to (celery.worker.request.Request attribute)
report() (celery.app.control.Inspect method)
repr_node() (celery.utils.graph.DependencyGraph method)
reprstream() (in module celery.utils.saferepr)
republish() (in module celery.contrib.migrate)
request
(celery.app.task.Task attribute)
Request (class in celery.worker.request)
request (Task attribute)
request_dict (celery.worker.request.Request attribute)
request_stack (celery.app.task.Task attribute)
requires (celery.bootsteps.ConsumerStep attribute)
(celery.bootsteps.Step attribute)
(celery.worker.components.Hub attribute)
(celery.worker.components.Pool attribute)
(celery.worker.consumer.Agent attribute)
(celery.worker.consumer.Control attribute)
(celery.worker.consumer.Events attribute)
(celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.Heart attribute)
(celery.worker.consumer.Mingle attribute)
(celery.worker.consumer.Tasks attribute)
(celery.worker.consumer.agent.Agent attribute)
(celery.worker.consumer.control.Control attribute)
(celery.worker.consumer.events.Events attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.heart.Heart attribute)
(celery.worker.consumer.mingle.Mingle attribute)
(celery.worker.consumer.tasks.Tasks attribute)
reraise_errors() (in module celery.security.utils)
reserve() (celery.beat.Scheduler method)
reserved() (celery.app.control.Inspect method)
reserved_options (celery.bin.multi.MultiTool attribute)
reserved_requests (in module celery.worker.state)
reset() (celery.utils.term.colored method)
(celery.worker.pidbox.Pidbox method)
(celery.worker.pidbox.gPidbox method)
reset_multiprocessing_logger() (in module celery.utils.log)
reset_rate_limits() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(consumer method)
reset_worker_optimizations() (in module celery.app.trace)
resetscreen() (celery.events.cursesmon.CursesMonitor method)
resolve_all() (in module celery.app.annotations)
respects_app_option (celery.bin.base.Command attribute)
respond() (celery.bin.amqp.AMQShell method)
restart() (celery.apps.multi.Cluster method)
(celery.bin.multi.MultiTool method)
(celery.bootsteps.Blueprint method)
(celery.concurrency.base.BasePool method)
(celery.concurrency.prefork.TaskPool method)
restart_count (celery.worker.consumer.Consumer attribute)
(celery.worker.consumer.consumer.Consumer attribute)
restore() (celery.result.GroupResult class method)
(celery.utils.serialization.UnpickleableExceptionWrapper method)
restore_group() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.BaseRPCBackend method)
result (celery.backends.database.models.Task attribute)
(celery.backends.database.models.TaskSet attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.result.AsyncResult attribute)
(celery.result.EagerResult attribute)
result_backend
setting
result_cache_max
setting
result_compression
setting
result_exchange
setting
result_exchange_type
setting
result_expires
setting
result_from_tuple() (in module celery.result)
result_persistent
setting
result_serializer
setting
ResultBase (class in celery.result)
resultrepr_maxsize (celery.app.task.Task attribute)
results (celery.result.GroupResult attribute)
(celery.result.ResultSet attribute)
ResultSession() (celery.backends.database.DatabaseBackend method)
ResultSet (class in celery.result)
retried (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
retries (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
RETRY
state
Retry
RETRY (in module celery.states)
retry() (celery.app.task.Task method)
retry_policy (celery.backends.amqp.AMQPBackend attribute)
(celery.backends.rpc.BaseRPCBackend attribute)
returns (celery.bin.amqp.Spec attribute)
retval (celery.app.trace.TraceInfo attribute)
reverse() (celery.utils.term.colored method)
revive() (celery.backends.amqp.AMQPBackend method)
(celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend method)
(celery.backends.rpc.BaseRPCBackend.Consumer method)
(celery.backends.rpc.BaseRPCBackend.Producer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer.Consumer method)
revoke
control
revoke() (celery.app.control.Control method)
(celery.result.AsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
revoke_selection() (celery.events.cursesmon.CursesMonitor method)
REVOKED
state
revoked (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
REVOKED (in module celery.states)
revoked (in module celery.worker.state)
revoked() (celery.app.control.Inspect method)
(celery.worker.request.Request method)
riak_backend_settings
setting
RiakBackend (class in celery.backends.riak)
rkey() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.RPCBackend method)
root (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
root_id (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.worker.request.Request attribute)
route() (celery.app.routes.Router method)
router (celery.app.amqp.AMQP attribute)
Router (class in celery.app.routes)
Router() (celery.app.amqp.AMQP method)
routes (celery.app.amqp.AMQP attribute)
routing_key (celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
RPCBackend (class in celery.backends.rpc)
RPCBackend.Consumer (class in celery.backends.rpc)
RUN (celery.concurrency.base.BasePool attribute)
run() (celery.app.task.Task method)
(celery.apps.beat.Beat method)
(celery.backends.async.greenletDrainer method)
(celery.bin.amqp.AMQPAdmin method)
(celery.bin.amqp.amqp method)
(celery.bin.base.Command method)
(celery.bin.beat.beat method)
(celery.bin.events.events method)
(celery.bin.graph.graph method)
(celery.bin.logtool.logtool method)
(celery.bin.worker.worker method)
(celery.concurrency.base.BasePool.Timer method)
(celery.utils.threads.bgThread method)
(celery.utils.timer2.Timer method)
run_evcam() (celery.bin.events.events method)
run_evdump() (celery.bin.events.events method)
run_evtop() (celery.bin.events.events method)
run_from_argv() (celery.bin.base.Command method)
(celery.bin.worker.worker method)
running (celery.concurrency.base.BasePool.Timer attribute)
(celery.utils.timer2.Timer attribute)
runtime (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
rusage() (celery.worker.WorkController method)

S

s() (celery.app.task.Task method)
safe_add_str() (celery.events.cursesmon.CursesMonitor method)
safe_ref() (in module celery.utils.dispatch.saferef)
saferepr() (in module celery.utils.saferepr)
sample() (in module celery.utils.debug)
sample_mem() (in module celery.utils.debug)
save() (celery.result.GroupResult method)
(celery.worker.state.Persistent method)
save_group() (celery.backends.amqp.AMQPBackend method)
(celery.backends.rpc.BaseRPCBackend method)
say() (celery.bin.amqp.AMQShell method)
(celery.events.dumper.Dumper method)
say1() (celery.bin.logtool.logtool method)
say_chat() (celery.bin.base.Command method)
say_remote_command_reply() (celery.bin.base.Command method)
schedule (celery.beat.PersistentScheduler attribute)
(celery.beat.ScheduleEntry attribute)
(celery.beat.Scheduler attribute)
Schedule (celery.concurrency.base.BasePool.Timer attribute)
(celery.utils.timer2.Timer attribute)
schedule (class in celery.schedules)
Schedule (in module celery.utils.timer2)
scheduled() (celery.app.control.Inspect method)
ScheduleEntry (class in celery.beat)
scheduler (celery.apps.beat.Beat.Service attribute)
(celery.beat.Service attribute)
Scheduler (class in celery.beat)
scheduler_cls (celery.apps.beat.Beat.Service attribute)
(celery.beat.Service attribute)
SchedulingError
scheme (celery.backends.couchdb.CouchBackend attribute)
(celery.backends.elasticsearch.ElasticsearchBackend attribute)
(celery.utils.graph.GraphFormatter attribute)
screen_delay (celery.events.cursesmon.CursesMonitor attribute)
screen_height (celery.events.cursesmon.CursesMonitor attribute)
screen_width (celery.events.cursesmon.CursesMonitor attribute)
seconds (celery.schedules.schedule attribute)
SecureSerializer (class in celery.security.serialization)
security_cert_store
setting
security_certificate
setting
security_key
setting
SecurityError
select() (celery.app.amqp.Queues method)
select_add() (celery.app.amqp.Queues method)
select_queues() (celery.Celery method)
selected_position (celery.events.cursesmon.CursesMonitor attribute)
selected_str (celery.events.cursesmon.CursesMonitor attribute)
selected_task (celery.events.cursesmon.CursesMonitor attribute)
selection_info() (celery.events.cursesmon.CursesMonitor method)
selection_rate_limit() (celery.events.cursesmon.CursesMonitor method)
selection_result() (celery.events.cursesmon.CursesMonitor method)
selection_traceback() (celery.events.cursesmon.CursesMonitor method)
semaphore (celery.worker.WorkController attribute)
send() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
(celery.events.EventDispatcher method)
(celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
send_all() (celery.apps.multi.Cluster method)
(celery.bootsteps.Blueprint method)
send_event() (celery.worker.request.Request method)
send_events (celery.app.task.Task attribute)
send_task() (celery.beat.Scheduler method)
(celery.Celery method)
send_task_message (celery.app.amqp.AMQP attribute)
sent (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
serialize() (celery.security.serialization.SecureSerializer method)
serializer (celery.app.control.Control.Mailbox attribute)
(Task attribute)
(celery.app.task.Task attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.rpc.BaseRPCBackend.Producer attribute)
server (celery.backends.elasticsearch.ElasticsearchBackend attribute)
servers (celery.backends.cache.CacheBackend attribute)
(celery.backends.cassandra.CassandraBackend attribute)
Service (class in celery.beat)
session_factory() (celery.backends.database.session.SessionManager method)
SessionManager (class in celery.backends.database.session)
set() (celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.riak.RiakBackend method)
(celery.utils.abstract.CallableSignature method)
set_current() (celery.Celery method)
set_default() (celery.Celery method)
set_default_app() (in module celery._state)
set_in_sighandler() (in module celery.utils.log)
set_mp_process_title() (in module celery.platforms)
set_process_status() (celery.apps.worker.Worker method)
(celery.bin.events.events method)
set_process_title() (celery.apps.beat.Beat method)
(in module celery.platforms)
set_schedule() (celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
set_trace() (in module celery.contrib.rdb)
setdefault() (celery.utils.collections.ChainMap method)
(celery.utils.collections.DictAttribute method)
setgid() (in module celery.platforms)
setgroups() (in module celery.platforms)
setter() (celery.utils.cached_property method)
setting
accept_content
beat_max_loop_interval
beat_schedule
beat_schedule_filename
beat_scheduler
beat_sync_every
broker_connection_max_retries
broker_connection_retry
broker_connection_timeout
broker_failover_strategy
broker_heartbeat
broker_heartbeat_checkrate
broker_login_method
broker_pool_limit
broker_read_url
broker_transport_options
broker_url
broker_use_ssl
broker_write_url
cache_backend
cache_backend_options
cassandra_auth_kwargs
cassandra_auth_provider
cassandra_entry_ttl
cassandra_keyspace
cassandra_port
cassandra_read_consistency
cassandra_servers
cassandra_table
cassandra_write_consistency
couchbase_backend_settings
enable_utc
event_queue_expires
event_queue_prefix
event_queue_ttl
event_serializer
imports
include
redis_max_connections
redis_socket_timeout
result_backend
result_cache_max
result_compression
result_exchange
result_exchange_type
result_expires
result_persistent
result_serializer
riak_backend_settings
security_cert_store
security_certificate
security_key
sqlalchemy_dburi
sqlalchemy_engine_options
sqlalchemy_short_lived_sessions
sqlalchemy_table_names
task_acks_late
task_always_eager
task_annotations
task_compression
task_create_missing_queues
task_default_delivery_mode
task_default_exchange
task_default_exchange_type
task_default_queue
task_default_rate_limit
task_default_routing_key
task_eager_propagates
task_ignore_result
task_protocol
task_publish_retry
task_publish_retry_policy
task_queue_ha_policy
task_queue_max_priority
task_queues
task_reject_on_worker_lost
task_remote_tracebacks
task_routes
task_send_sent_event
task_serializer
task_soft_time_limit
task_store_errors_even_if_ignored
task_time_limit
task_track_started
timezone
worker_concurrency
worker_consumer
worker_direct
worker_disable_rate_limits
worker_enable_remote_control
worker_hijack_root_logger
worker_log_color
worker_log_format
worker_lost_wait
worker_max_memory_per_child
worker_max_tasks_per_child
worker_pool
worker_pool_restarts
worker_prefetch_multiplier
worker_redirect_stdouts
worker_redirect_stdouts_level
worker_send_task_events
worker_state_db
worker_task_log_format
worker_timer
worker_timer_precision
Settings (class in celery.app.utils)
setuid() (in module celery.platforms)
setup() (celery.app.log.Logging method)
setup_app_from_commandline() (celery.bin.base.Command method)
setup_defaults() (celery.worker.WorkController method)
setup_handlers() (celery.app.log.Logging method)
setup_includes() (celery.worker.WorkController method)
setup_instance() (celery.worker.WorkController method)
setup_logger() (celery.app.log.Logging method)
setup_logging
signal
setup_logging() (celery.apps.beat.Beat method)
(celery.apps.worker.Worker method)
setup_logging_subsystem() (celery.app.log.Logging method)
setup_queues() (celery.worker.WorkController method)
setup_schedule() (celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
setup_security() (celery.Celery method)
(in module celery.security)
setup_settings() (celery.loaders.default.Loader method)
setup_task_loggers() (celery.app.log.Logging method)
setup_worker_optimizations() (in module celery.app.trace)
shadow_name() (celery.app.task.Task method)
Shell (celery.bin.amqp.AMQPAdmin attribute)
should_sync() (celery.beat.Scheduler method)
should_use_eventloop() (celery.worker.WorkController method)
show() (celery.bin.multi.MultiTool method)
show_body (celery.bin.base.Command attribute)
show_reply (celery.bin.base.Command attribute)
shrink() (celery.concurrency.eventlet.TaskPool method)
(celery.concurrency.gevent.TaskPool method)
shutdown
control
shutdown() (celery.bootsteps.ConsumerStep method)
(celery.worker.consumer.Connection method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.Consumer.Blueprint method)
(celery.worker.consumer.Events method)
(celery.worker.consumer.Heart method)
(celery.worker.consumer.Tasks method)
(celery.worker.consumer.connection.Connection method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer.Blueprint method)
(celery.worker.consumer.events.Events method)
(celery.worker.consumer.heart.Heart method)
(celery.worker.consumer.tasks.Tasks method)
(celery.worker.pidbox.Pidbox method)
shutdown_nodes() (celery.apps.multi.Cluster method)
shutdown_worker() (celery.loaders.base.BaseLoader method)
shutter() (celery.events.snapshot.Polaroid method)
shutter_signal (celery.events.snapshot.Polaroid attribute)
si() (celery.app.task.Task method)
sign() (celery.security.key.PrivateKey method)
signal
after_setup_logger
after_setup_task_logger
after_task_publish
beat_embedded_init
beat_init
before_task_publish
celeryd_after_setup
celeryd_init
eventlet_pool_apply
eventlet_pool_postshutdown
eventlet_pool_preshutdown
eventlet_pool_started
heartbeat_sent
import_modules
setup_logging
task_failure
task_postrun
task_prerun
task_rejected
task_retry
task_revoked
task_sent
task_success
task_unknown
user_preload_options
worker_init
worker_process_init
worker_process_shutdown
worker_ready
worker_shutdown
Signal (class in celery.utils.dispatch)
(class in celery.utils.dispatch.signal)
signal_consumer_close() (celery.worker.WorkController method)
signal_name() (in module celery.platforms)
signal_safe (celery.concurrency.base.BasePool attribute)
(celery.concurrency.eventlet.TaskPool attribute)
(celery.concurrency.gevent.TaskPool attribute)
Signature (class in celery)
signature() (celery.app.task.Task method)
(celery.Celery method)
(in module celery)
simple_format() (in module celery.utils.text)
soft_time_limit (celery.app.task.Task attribute)
(Task attribute)
SoftTimeLimitExceeded
SOFTWARE_INFO (in module celery.worker.state)
solar (class in celery.schedules)
spawn (celery.backends.async.eventletDrainer attribute)
(celery.backends.async.geventDrainer attribute)
(celery.backends.async.greenletDrainer attribute)
Spec (class in celery.bin.amqp)
sqlalchemy_dburi
setting
sqlalchemy_engine_options
setting
sqlalchemy_short_lived_sessions
setting
sqlalchemy_table_names
setting
starmap() (celery.app.task.Task method)
start() (celery.apps.beat.Beat.Service method)
(celery.Celery method)
(celery.apps.multi.Cluster method)
(celery.apps.multi.Node method)
(celery.backends.async.BaseResultConsumer method)
(celery.backends.async.Drainer method)
(celery.backends.async.greenletDrainer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer method)
(celery.beat.Service method)
(celery.bin.multi.MultiTool method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
(celery.bootsteps.Blueprint method)
(celery.bootsteps.ConsumerStep method)
(celery.bootsteps.StartStopStep method)
(celery.concurrency.base.BasePool method)
(celery.worker.WorkController method)
(celery.worker.components.Hub method)
(celery.worker.consumer.Connection method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.Events method)
(celery.worker.consumer.Gossip method)
(celery.worker.consumer.Heart method)
(celery.worker.consumer.Mingle method)
(celery.worker.consumer.Tasks method)
(celery.worker.consumer.connection.Connection method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.consumer.consumer.Evloop method)
(celery.worker.consumer.events.Events method)
(celery.worker.consumer.gossip.Gossip method)
(celery.worker.consumer.heart.Heart method)
(celery.worker.consumer.mingle.Mingle method)
(celery.worker.consumer.tasks.Tasks method)
(celery.worker.heartbeat.Heart method)
(celery.worker.pidbox.Pidbox method)
(celery.worker.pidbox.gPidbox method)
start_filter() (in module celery.contrib.migrate)
start_node() (celery.apps.multi.Cluster method)
start_scheduler() (celery.apps.beat.Beat method)
STARTED
state
started (celery.bootsteps.Blueprint attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
STARTED (in module celery.states)
StartStopStep (class in celery.bootsteps)
startup_info() (celery.apps.beat.Beat method)
(celery.apps.worker.Worker method)
stat (celery.utils.sysinfo.df attribute)
state
ALL_STATES
EXCEPTION_STATES
FAILURE
PENDING
PROPAGATE_STATES
READY_STATES
RETRY
REVOKED
STARTED
SUCCESS
UNREADY_STATES
state (celery.app.trace.TraceInfo attribute)
(celery.bootsteps.Blueprint attribute)
State (celery.events.Events attribute)
state (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.result.AsyncResult attribute)
(celery.result.EagerResult attribute)
(celery.worker.WorkController attribute)
State (class in celery.contrib.migrate)
(class in celery.events.state)
state (class in celery.states)
State.Task (class in celery.events.state)
State.Worker (class in celery.events.state)
state_to_name (celery.bootsteps.Blueprint attribute)
statedb
StateDB (class in celery.worker.components)
stats() (celery.app.control.Inspect method)
(celery.bin.logtool.logtool method)
(celery.worker.WorkController method)
status (celery.backends.database.models.Task attribute)
(celery.bin.base.Command.Error attribute)
(celery.bin.base.Command.UsageError attribute)
(celery.bin.base.Error attribute)
(celery.bin.base.UsageError attribute)
(celery.result.AsyncResult attribute)
(celery.result.EagerResult attribute)
status_string (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
Step (class in celery.bootsteps)
steps (celery.Celery attribute)
stop() (celery.apps.beat.Beat.Service method)
(celery.apps.multi.Cluster method)
(celery.backends.async.BaseResultConsumer method)
(celery.backends.async.Drainer method)
(celery.backends.async.greenletDrainer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.BaseRPCBackend.ResultConsumer method)
(celery.beat.Service method)
(celery.bin.multi.MultiTool method)
(celery.bootsteps.Blueprint method)
(celery.bootsteps.ConsumerStep method)
(celery.bootsteps.StartStopStep method)
(celery.concurrency.base.BasePool method)
(celery.concurrency.base.BasePool.Timer method)
(celery.utils.threads.bgThread method)
(celery.utils.timer2.Timer method)
(celery.worker.WorkController method)
(celery.worker.components.Hub method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.Events method)
(celery.worker.consumer.Heart method)
(celery.worker.consumer.Tasks method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.consumer.events.Events method)
(celery.worker.consumer.heart.Heart method)
(celery.worker.consumer.tasks.Tasks method)
(celery.worker.heartbeat.Heart method)
(celery.worker.pidbox.Pidbox method)
stop_verify() (celery.bin.multi.MultiTool method)
StopFiltering
stopwait() (celery.apps.multi.Cluster method)
(celery.bin.multi.MultiTool method)
storage (celery.worker.state.Persistent attribute)
STORE_ACTIONS (celery.bin.base.Option attribute)
store_errors (celery.worker.request.Request attribute)
store_errors_even_if_ignored (celery.app.task.Task attribute)
(Task attribute)
store_result() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.DisabledBackend method)
(celery.backends.rpc.BaseRPCBackend method)
str_args_to_python() (celery.bin.amqp.Spec method)
str_decode() (in module celery.backends.riak)
str_to_list() (in module celery.utils.text)
strategies
Strategies (celery.worker.consumer.Consumer attribute)
(celery.worker.consumer.consumer.Consumer attribute)
Strategy (celery.app.task.Task attribute)
strtobool() (in module celery.utils.serialization)
strtotal (celery.contrib.migrate.State attribute)
subclass_exception() (in module celery.utils.serialization)
subpolling_interval (celery.backends.database.DatabaseBackend attribute)
subtask() (celery.app.task.Task method)
subtask_type (celery.utils.abstract.CallableSignature attribute)
succeeded (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
SUCCESS
state
SUCCESS (in module celery.states)
successful() (celery.result.AsyncResult method)
(celery.result.ResultSet method)
supports_args (celery.bin.base.Command attribute)
(celery.bin.beat.beat attribute)
(celery.bin.events.events attribute)
(celery.bin.worker.worker attribute)
supports_autoexpire (celery.backends.amqp.AMQPBackend attribute)
(celery.backends.cache.CacheBackend attribute)
(celery.backends.cassandra.CassandraBackend attribute)
(celery.backends.consul.ConsulBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.backends.rpc.BaseRPCBackend attribute)
supports_color() (celery.app.log.Logging method)
supports_native_join (celery.backends.amqp.AMQPBackend attribute)
(celery.backends.cache.CacheBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.backends.rpc.BaseRPCBackend attribute)
(celery.result.AsyncResult attribute)
(celery.result.EagerResult attribute)
(celery.result.ResultSet attribute)
sw_ident (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
sw_sys (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
sw_ver (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
swap_with() (celery.utils.collections.ConfigurationView method)
symbol_by_name() (celery.bin.base.Command method)
(in module celery.utils.imports)
sync() (celery.apps.beat.Beat.Service method)
(celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
(celery.beat.Service method)
(celery.worker.state.Persistent method)
sync_every (celery.beat.Scheduler attribute)
sync_every_tasks (celery.beat.Scheduler attribute)
sync_with_node() (celery.worker.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle method)
synloop() (in module celery.worker.loops)

T

table() (celery.app.utils.Settings method)
TAIL (celery.utils.graph.DOT attribute)
tail() (celery.utils.graph.GraphFormatter method)
take() (celery.utils.collections.BufferMap method)
(celery.utils.collections.Messagebuffer method)
take_action() (celery.bin.base.Option method)
takes_value() (celery.bin.base.Option method)
Task (celery.Celery attribute)
task (celery.utils.abstract.CallableSignature attribute)
(celery.worker.request.Request attribute)
Task (class in celery.app.task)
(class in celery.backends.database.models)
(class in celery.events.state)
task() (celery.Celery method)
task-failed
event
task-received
event
task-rejected
event
task-retried
event
task-revoked
event
task-sent
event
task-started
event
task-succeeded
event
Task.MaxRetriesExceededError
Task.OperationalError
task_accepted() (in module celery.worker.state)
task_acks_late
setting
task_always_eager
setting
task_annotations
setting
task_buckets
task_compression
setting
task_consumer
task_count (celery.events.state.State attribute)
task_create_missing_queues
setting
task_default_delivery_mode
setting
task_default_exchange
setting
task_default_exchange_type
setting
task_default_queue
setting
task_default_rate_limit
setting
task_default_routing_key
setting
task_eager_propagates
setting
task_event() (celery.events.state.State method)
task_failure
signal
task_id (celery.backends.database.models.Task attribute)
(celery.result.AsyncResult attribute)
(celery.worker.request.Request attribute)
task_id_eq() (in module celery.contrib.migrate)
task_id_in() (in module celery.contrib.migrate)
task_ignore_result
setting
task_join_will_block (celery.concurrency.base.BasePool attribute)
(celery.concurrency.eventlet.TaskPool attribute)
(celery.concurrency.gevent.TaskPool attribute)
task_name (celery.worker.request.Request attribute)
task_postrun
signal
task_prerun
signal
task_protocol
setting
task_publish_retry
setting
task_publish_retry_policy
setting
task_queue_ha_policy
setting
task_queue_max_priority
setting
task_queues
setting
task_ready() (in module celery.worker.state)
task_reject_on_worker_lost
setting
task_rejected
signal
task_remote_tracebacks
setting
task_reserved() (in module celery.worker.state), [1]
task_retry
signal
task_revoked
signal
task_routes
setting
task_send_sent_event
setting
task_sent
signal
task_serializer
setting
task_soft_time_limit
setting
task_store_errors_even_if_ignored
setting
task_success
signal
task_time_limit
setting
task_track_started
setting
task_types() (celery.events.state.State method)
task_unknown
signal
TaskFormatter (class in celery.app.log)
tasklist() (celery.apps.worker.Worker method)
taskmeta_collection (celery.backends.mongodb.MongoBackend attribute)
TaskPool (class in celery.concurrency.eventlet)
(class in celery.concurrency.gevent)
(class in celery.concurrency.prefork)
(class in celery.concurrency.solo)
TaskPool.Timer (class in celery.concurrency.eventlet)
(class in celery.concurrency.gevent)
TaskPredicate
TaskRegistry (class in celery.app.registry)
TaskRegistry.NotRegistered
TaskRevokedError
tasks (celery.Celery attribute)
(celery.events.cursesmon.CursesMonitor attribute)
Tasks (class in celery.worker.consumer)
(class in celery.worker.consumer.tasks)
tasks_by_time() (celery.events.state.State method)
tasks_by_timestamp() (celery.events.state.State method)
TaskSet (class in celery.backends.database.models)
taskset_id (celery.backends.database.models.TaskSet attribute)
TaskType (in module celery.app.task)
term_scheme (celery.utils.graph.GraphFormatter attribute)
terminal_node() (celery.utils.graph.GraphFormatter method)
TERMINATE (celery.concurrency.base.BasePool attribute)
terminate() (celery.bootsteps.StartStopStep method)
(celery.concurrency.base.BasePool method)
(celery.worker.WorkController method)
(celery.worker.components.Hub method)
(celery.worker.components.Pool method)
(celery.worker.request.Request method)
terminate_job() (celery.concurrency.base.BasePool method)
Terminated
thaw() (State method)
then() (celery.result.AsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
throw() (celery.result.AsyncResult method)
throws (celery.app.task.Task attribute)
(Task attribute)
tick() (celery.beat.Scheduler method)
time_limit (celery.app.task.Task attribute)
(Task attribute)
time_limit() (celery.app.control.Control method)
time_limits (celery.worker.request.Request attribute)
time_start (celery.worker.request.Request attribute)
TimeLimitExceeded
timeout (celery.backends.couchbase.CouchbaseBackend attribute)
TimeoutError
timer, [1]
(celery.events.snapshot.Polaroid attribute)
(celery.worker.consumer.Consumer attribute)
(celery.worker.consumer.consumer.Consumer attribute)
Timer (class in celery.utils.timer2)
(class in celery.worker.components)
Timer.Entry (class in celery.utils.timer2)
timestamp (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
timezone
setting
timezone (celery.app.utils.Settings attribute)
(celery.Celery attribute)
to_dict() (celery.backends.database.models.Task method)
(celery.backends.database.models.TaskSet method)
to_dot() (celery.utils.graph.DependencyGraph method)
to_local() (celery.schedules.schedule method)
to_python() (celery.app.defaults.Option method)
to_timestamp() (in module celery.utils.timer2)
to_utc() (in module celery.utils.time)
topsort() (celery.utils.graph.DependencyGraph method)
total (celery.utils.collections.BufferMap attribute)
total_apx (celery.contrib.migrate.State attribute)
total_blocks (celery.utils.sysinfo.df attribute)
total_count (in module celery.worker.state)
total_run_count (celery.beat.ScheduleEntry attribute)
trace_task() (in module celery.app.trace)
traceback (celery.backends.database.models.Task attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.result.AsyncResult attribute)
(celery.result.EagerResult attribute)
TraceInfo (class in celery.app.trace)
traces() (celery.bin.logtool.logtool method)
track_started (celery.app.task.Task attribute)
(Task attribute)
trail (celery.app.task.Task attribute)
TRANSIENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.rpc.BaseRPCBackend.Exchange attribute)
tref (celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
truncate() (in module celery.utils.text)
type (celery.app.control.Control.Mailbox attribute)
(celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.rpc.BaseRPCBackend.Exchange attribute), [1]
(celery.utils.abstract.CallableSignature attribute)
(celery.worker.request.Request attribute)
TYPE_CHECKER (celery.bin.base.Option attribute)
TYPED_ACTIONS (celery.bin.base.Option attribute)
typemap (celery.app.defaults.Option attribute)
TYPES (celery.bin.base.Option attribute)
tz (celery.schedules.schedule attribute)
tzlocal (celery.worker.request.Request attribute)
tzname() (celery.utils.time.LocalTimezone method)

U

unbind_from() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.rpc.BaseRPCBackend.Exchange method)
underline() (celery.utils.term.colored method)
uniq() (in module celery.utils.functional)
UnpickleableExceptionWrapper
UNREADY_STATES
state
unregister() (celery.app.registry.TaskRegistry method)
update() (celery.beat.ScheduleEntry method)
(celery.events.state.State.Worker method)
(celery.events.state.Worker method)
(celery.result.ResultSet method)
(celery.utils.collections.ChainMap method)
(celery.utils.collections.LimitedSet method)
(celery.utils.functional.LRUCache method)
(celery.utils.graph.DependencyGraph method)
update_from_dict() (celery.beat.Scheduler method)
update_state() (celery.app.task.Task method)
update_strategies() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
usage() (celery.bin.base.Command method)
UsageError
USE_FAST_LOCALS
user (celery.backends.mongodb.MongoBackend attribute)
user_options (celery.Celery attribute)
user_preload_options
signal
username (celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
uses_semaphore (celery.concurrency.base.BasePool attribute)
(celery.concurrency.prefork.TaskPool attribute)
utc (celery.worker.request.Request attribute)
utc_enabled (celery.schedules.schedule attribute)
utcoffset() (celery.utils.time.LocalTimezone method)
(in module celery.utils.time)
uuid() (in module celery.utils)

V

valency_of() (celery.utils.graph.DependencyGraph method)
validate_arguments() (celery.bin.multi.MultiTool method)
value_set_for() (celery.app.utils.Settings method)
values() (celery.utils.collections.ChainMap method)
(celery.utils.collections.DictAttribute method)
(celery.utils.functional.LRUCache method)
verify() (celery.security.certificate.Certificate method)
verify_args() (celery.bin.base.Command method)
version (celery.bin.base.Command attribute)

W

wait() (celery.result.AsyncResult method)
(celery.result.EagerResult method)
wait_for() (celery.backends.amqp.AMQPBackend method)
(celery.backends.async.Drainer method)
(celery.backends.async.greenletDrainer method)
(celery.backends.base.DisabledBackend method)
wait_for_pending() (celery.backends.async.AsyncBackendMixin method)
waiting() (celery.result.ResultSet method)
wakeup_workers() (celery.events.EventReceiver method)
warn() (in module celery.utils.deprecated)
weekday() (in module celery.utils.time)
when (celery.exceptions.Retry attribute)
white() (celery.utils.term.colored method)
win (celery.events.cursesmon.CursesMonitor attribute)
with_pool_option() (celery.bin.base.Command method)
(celery.bin.celery.CeleryCommand method)
(celery.bin.worker.worker method)
without_defaults() (celery.app.utils.Settings method)
WorkController (celery.Celery attribute)
(class in celery.worker)
WorkController.Blueprint (class in celery.worker)
Worker (celery.Celery attribute)
worker (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
Worker (class in celery.apps.worker)
worker (class in celery.bin.worker)
Worker (class in celery.events.state)
worker-heartbeat
event
worker-offline
event
worker-online
event
worker_concurrency
setting
worker_consumer
setting
worker_direct
setting
worker_direct() (in module celery.utils)
(in module celery.utils.nodenames)
worker_disable_rate_limits
setting
worker_enable_remote_control
setting
worker_event() (celery.events.state.State method)
worker_hijack_root_logger
setting
worker_init
signal
worker_initialized (celery.loaders.base.BaseLoader attribute)
worker_log_color
setting
worker_log_format
setting
worker_lost_wait
setting
worker_main() (celery.Celery method)
worker_max_memory_per_child
setting
worker_max_tasks_per_child
setting
worker_pid (celery.worker.request.Request attribute)
worker_pool
setting
worker_pool_restarts
setting
worker_prefetch_multiplier
setting
worker_process_init
signal
worker_process_shutdown
signal
worker_ready
signal
worker_redirect_stdouts
setting
worker_redirect_stdouts_level
setting
worker_send_task_events
setting
worker_shutdown
signal
worker_state_db
setting
worker_task_log_format
setting
worker_timer
setting
worker_timer_precision
setting
WorkerLostError
workers (celery.events.cursesmon.CursesMonitor attribute)
workers() (celery.bin.graph.graph method)
WorkerShutdown
WorkerTerminate
write() (celery.utils.log.LoggingProxy method)
write_pid() (celery.platforms.Pidfile method)
write_stats (celery.concurrency.prefork.TaskPool attribute)
writelines() (celery.utils.log.LoggingProxy method)

Y

yellow() (celery.utils.term.colored method)