Navigation
index
modules
|
Celery 5.2.7 documentation
»
Index
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
--ack-messages
celery-migrate command line option
--app <app>
celery command line option
--args <args>
celery-call command line option
--autoscale <autoscale>
celery-worker command line option
--beat
celery-worker command line option
--bpython
celery-shell command line option
--broker <broker>
celery command line option
--camera <camera>
celery-events command line option
--compat
celery-upgrade-settings command line option
--concurrency <concurrency>
celery-worker command line option
--config <config>
celery command line option
--countdown <countdown>
celery-call command line option
--destination <destination>
celery-control command line option
celery-inspect command line option
celery-status command line option
--detach
celery-beat command line option
celery-events command line option
celery-worker command line option
--discard
celery-worker command line option
--django
celery-upgrade-settings command line option
--dump
celery-events command line option
--eta <eta>
celery-call command line option
--eventlet
celery-shell command line option
--events
celery-worker command line option
--exchange <exchange>
celery-call command line option
--exclude-queues <exclude_queues>
celery-purge command line option
celery-worker command line option
--executable <executable>
celery-beat command line option
celery-events command line option
celery-worker command line option
--expires <expires>
celery-call command line option
--force
celery-purge command line option
--forever
celery-migrate command line option
--freq <frequency>
celery-events command line option
--frequency
celery-events command line option
--gevent
celery-shell command line option
--gid <gid>
celery-beat command line option
celery-events command line option
celery-worker command line option
--heartbeat-interval <heartbeat_interval>
celery-worker command line option
--hostname <hostname>
celery-worker command line option
--include <include>
celery-worker command line option
--ipython
celery-shell command line option
--json
celery-control command line option
celery-inspect command line option
celery-status command line option
--kwargs <kwargs>
celery-call command line option
--limit <limit>
celery-migrate command line option
--loader <loader>
celery command line option
--logfile <logfile>
celery-beat command line option
celery-events command line option
celery-worker command line option
--loglevel <loglevel>
celery-beat command line option
celery-events command line option
celery-worker command line option
--max-interval <max_interval>
celery-beat command line option
--max-memory-per-child <max_memory_per_child>
celery-worker command line option
--max-tasks-per-child <max_tasks_per_child>
celery-worker command line option
--maxrate <maxrate>
celery-events command line option
--no-backup
celery-upgrade-settings command line option
--no-color
celery command line option
--pidfile <pidfile>
celery-beat command line option
celery-events command line option
celery-worker command line option
--pool <pool>
celery-worker command line option
--prefetch-multiplier <prefetch multiplier>
celery-worker command line option
--purge
celery-worker command line option
--python
celery-shell command line option
--queue <queue>
celery-call command line option
--queues <queues>
celery-migrate command line option
celery-purge command line option
celery-worker command line option
--quiet
celery command line option
--result-backend <result_backend>
celery command line option
--routing-key <routing_key>
celery-call command line option
--schedule <schedule>
celery-beat command line option
--schedule <schedule_filename>
celery-worker command line option
--schedule-filename
celery-worker command line option
--scheduler <scheduler>
celery-beat command line option
celery-worker command line option
--serializer <serializer>
celery-call command line option
--soft-time-limit <soft_time_limit>
celery-worker command line option
--statedb <statedb>
celery-worker command line option
--task <task>
celery-result command line option
--task-events
celery-worker command line option
--tasks <tasks>
celery-migrate command line option
--time-limit <time_limit>
celery-worker command line option
--timeout <timeout>
celery-control command line option
celery-inspect command line option
celery-migrate command line option
celery-status command line option
--traceback
celery-result command line option
--uid <uid>
celery-beat command line option
,
[1]
celery-events command line option
,
[1]
celery-worker command line option
,
[1]
--umask <umask>
celery-beat command line option
celery-events command line option
celery-worker command line option
--version
celery command line option
--without-gossip
celery-worker command line option
--without-heartbeat
celery-worker command line option
--without-mingle
celery-worker command line option
--without-tasks
celery-shell command line option
--workdir <workdir>
celery command line option
-A
celery command line option
-a
celery-call command line option
celery-migrate command line option
-B
celery-shell command line option
celery-worker command line option
-b
celery command line option
-C
celery command line option
-c
celery-events command line option
celery-worker command line option
-D
celery-worker command line option
-d
celery-control command line option
celery-events command line option
,
[1]
celery-inspect command line option
celery-status command line option
-E
celery-worker command line option
-F
celery-events command line option
celery-migrate command line option
-f
celery-beat command line option
celery-events command line option
celery-purge command line option
celery-worker command line option
-I
celery-shell command line option
celery-worker command line option
-j
celery-control command line option
celery-inspect command line option
celery-status command line option
-k
celery-call command line option
-l
celery-beat command line option
celery-events command line option
celery-worker command line option
-n
celery-migrate command line option
celery-worker command line option
-O <optimization>
celery-worker command line option
-P
celery-worker command line option
-Q
celery-migrate command line option
celery-purge command line option
celery-worker command line option
-q
celery command line option
-r
celery-events command line option
-S
celery-beat command line option
celery-worker command line option
-s
celery-beat command line option
celery-worker command line option
-T
celery-migrate command line option
celery-shell command line option
-t
celery-control command line option
celery-inspect command line option
celery-migrate command line option
celery-result command line option
celery-status command line option
-X
celery-purge command line option
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.rpc.RPCBackend.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)
acks_on_failure_or_timeout (celery.app.task.Task attribute)
acquire() (celery.platforms.Pidfile method)
ACTION
celery-control command line option
celery-inspect command line option
active (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
active() (celery.app.control.Inspect method)
(celery.concurrency.base.BasePool property)
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.result.ResultSet method)
(celery.utils.collections.LimitedSet method)
(hub method)
add_arc() (celery.utils.graph.DependencyGraph method)
add_autoretry_behaviour() (in module celery.app.autoretry)
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.asynchronous.AsyncBackendMixin method)
add_pending_results() (celery.backends.asynchronous.AsyncBackendMixin method)
add_periodic_task() (celery.Celery method)
add_queue() (celery.backends.rpc.RPCBackend.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 property)
(celery.bootsteps.Step property)
alive() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
(celery.events.state.State.Worker property)
(celery.events.state.Worker property)
alive_workers() (celery.events.state.State method)
ALL_STATES
state
already_setup (celery.app.log.Logging attribute)
AlreadyRegistered
alt (celery.app.defaults.Option attribute)
AlwaysEagerIgnored
amqp (celery.Celery attribute)
AMQP (class in celery.app.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.dispatcher.EventDispatcher attribute)
(celery.events.EventDispatcher attribute)
(celery.events.EventReceiver attribute)
(celery.events.receiver.EventReceiver attribute)
(celery.result.AsyncResult attribute)
(celery.schedules.crontab attribute)
(celery.worker.WorkController attribute)
(celery.worker.worker.WorkController attribute)
App (class in celery.bin.celery)
app() (celery.result.ResultSet property)
(celery.utils.abstract.CallableSignature property)
(celery.worker.request.Request property)
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)
arangodb_backend_settings
setting
ArangoDbBackend (class in celery.backends.arangodb)
args (celery.backends.database.models.TaskExtended attribute)
(celery.beat.ScheduleEntry attribute)
(celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
args() (celery.result.AsyncResult property)
(celery.utils.abstract.CallableSignature property)
(celery.worker.request.Request property)
argsrepr() (celery.worker.request.Request property)
argsrepr_maxsize (celery.app.amqp.AMQP attribute)
arguments (celery.backends.rpc.RPCBackend.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_list() (celery.result.AsyncResult method)
as_tuple() (celery.result.AsyncResult method)
(celery.result.GroupResult method)
as_uri() (celery.backends.azureblockblob.AzureBlockBlobBackend method)
(celery.backends.base.DisabledBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.cassandra.CassandraBackend method)
(celery.backends.mongodb.MongoBackend method)
(celery.backends.redis.SentinelBackend method)
(celery.backends.rpc.RPCBackend method)
assert_accepted() (celery.contrib.testing.manager.ManagerMixin method)
assert_received() (celery.contrib.testing.manager.ManagerMixin method)
assert_result_tasks_in_progress_or_completed() (celery.contrib.testing.manager.ManagerMixin method)
assert_task_state_from_result() (celery.contrib.testing.manager.ManagerMixin method)
assert_task_worker_state() (celery.contrib.testing.manager.ManagerMixin method)
AsyncBackendMixin (class in celery.backends.asynchronous)
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.rpc.RPCBackend.Exchange attribute)
attrs() (celery.utils.graph.GraphFormatter method)
ATTRSEP (celery.utils.graph.DOT attribute)
auto_declare (celery.backends.rpc.RPCBackend.Consumer attribute)
(celery.backends.rpc.RPCBackend.Producer attribute)
(celery.backends.rpc.RPCBackend.ResultConsumer.Consumer attribute)
AUTO_DELETE
celery-amqp-exchange.declare command line option
celery-amqp-queue.declare command line option
auto_delete (celery.backends.rpc.RPCBackend.Exchange attribute)
,
[1]
autodiscover_tasks() (celery.Celery method)
(celery.loaders.base.BaseLoader method)
autodoc_skip_member_handler() (in module celery.contrib.sphinx)
autoreloader
autoretry_for (Task attribute)
Autoscale (class in celery.bin.worker)
autoscale() (celery.app.control.Control method)
autoscaler
Autoscaler (class in celery.worker.autoscale)
available() (celery.utils.sysinfo.df property)
AWS_ACCESS_KEY_ID
aws_region (celery.backends.dynamodb.DynamoDBBackend attribute)
AWS_SECRET_ACCESS_KEY
azureblockblob_base_path
setting
azureblockblob_connection_timeout
setting
azureblockblob_container_name
setting
azureblockblob_read_timeout
setting
azureblockblob_retry_increment_base
setting
azureblockblob_retry_initial_backoff_sec
setting
azureblockblob_retry_max_attempts
setting
AzureBlockBlobBackend (class in celery.backends.azureblockblob)
B
backend (celery.Celery attribute)
(celery.result.AsyncResult attribute)
(Task attribute)
backend() (celery.app.task.Task property)
(celery.result.ResultSet property)
BackendError
BackendGetMetaError
BackendStoreError
background (celery.events.cursesmon.CursesMonitor attribute)
BacklogLimitExceeded
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.asynchronous)
Beat (celery.Celery attribute)
(class in celery.apps.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_start()
(celery.app.task.Task method)
before_task_publish
signal
bgThread (class in celery.utils.threads)
billiard
bind() (queue method)
bind_to() (celery.backends.rpc.RPCBackend.Exchange method)
(celery.utils.collections.ChainMap method)
binding() (celery.backends.rpc.RPCBackend property)
(celery.backends.rpc.RPCBackend.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)
(celery.worker.worker.WorkController attribute)
Blueprint (class in celery.bootsteps)
body() (celery.utils.threads.bgThread method)
(celery.worker.autoscale.Autoscaler method)
(celery.worker.request.Request property)
body_can_be_buffer (celery.concurrency.base.BasePool attribute)
(celery.concurrency.solo.TaskPool attribute)
(celery.concurrency.thread.TaskPool attribute)
bold() (celery.utils.term.colored 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 property)
broker_transport_options
setting
broker_url
setting
broker_url() (celery.app.utils.Settings property)
broker_use_ssl
setting
broker_write_url
setting
broker_write_url() (celery.app.utils.Settings property)
bucket (celery.backends.couchbase.CouchbaseBackend attribute)
bucket_for_task() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(consumer method)
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)
Bunch (class in celery.utils.objects)
by_name() (in module celery.app.backends)
by_url() (in module celery.app.backends)
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.rpc.RPCBackend.ResultConsumer.Consumer attribute)
calling
can_cache_declaration (celery.backends.rpc.RPCBackend.Queue attribute)
can_cache_declaration() (celery.backends.rpc.RPCBackend.Exchange property)
can_document_member() (celery.contrib.sphinx.TaskDocumenter class method)
cancel() (celery.backends.rpc.RPCBackend.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)
(celery.worker.request.Request method)
cancel_by_queue() (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer method)
cancel_consumer
control
cancel_consumer()
(celery.app.control.Control method)
cancel_for() (celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.RPCBackend.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 property)
(celery.utils.timer2.Entry property)
(celery.utils.timer2.Timer.Entry property)
capacity() (celery.utils.sysinfo.df property)
capture() (celery.events.EventReceiver method)
(celery.events.receiver.EventReceiver method)
(celery.events.snapshot.Polaroid method)
cassandra_auth_kwargs
setting
cassandra_auth_provider
setting
cassandra_entry_ttl
setting
cassandra_keyspace
setting
cassandra_options
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
module
Celery (class in celery)
celery command line option
--app <app>
--broker <broker>
--config <config>
--loader <loader>
--no-color
--quiet
--result-backend <result_backend>
--version
--workdir <workdir>
-A
-b
-C
-q
celery-amqp-basic.ack command line option
DELIVERY_TAG
celery-amqp-basic.get command line option
NO_ACK
QUEUE
celery-amqp-basic.publish command line option
EXCHANGE
IMMEDIATE
MANDATORY
MSG
ROUTING_KEY
celery-amqp-exchange.declare command line option
AUTO_DELETE
DURABLE
EXCHANGE
PASSIVE
TYPE
celery-amqp-exchange.delete command line option
EXCHANGE
IF_UNUSED
celery-amqp-queue.bind command line option
EXCHANGE
QUEUE
ROUTING_KEY
celery-amqp-queue.declare command line option
AUTO_DELETE
DURABLE
PASSIVE
QUEUE
celery-amqp-queue.delete command line option
IF_EMPTY
IF_UNUSED
QUEUE
celery-amqp-queue.purge command line option
QUEUE
celery-beat command line option
--detach
--executable <executable>
--gid <gid>
--logfile <logfile>
--loglevel <loglevel>
--max-interval <max_interval>
--pidfile <pidfile>
--schedule <schedule>
--scheduler <scheduler>
--uid <uid>
,
[1]
--umask <umask>
-f
-l
-s
-S
celery-call command line option
--args <args>
--countdown <countdown>
--eta <eta>
--exchange <exchange>
--expires <expires>
--kwargs <kwargs>
--queue <queue>
--routing-key <routing_key>
--serializer <serializer>
-a
-k
NAME
celery-control command line option
--destination <destination>
--json
--timeout <timeout>
-d
-j
-t
ACTION
celery-events command line option
--camera <camera>
--detach
--dump
--executable <executable>
--freq <frequency>
--frequency
--gid <gid>
--logfile <logfile>
--loglevel <loglevel>
--maxrate <maxrate>
--pidfile <pidfile>
--uid <uid>
,
[1]
--umask <umask>
-c
-d
,
[1]
-F
-f
-l
-r
celery-inspect command line option
--destination <destination>
--json
--timeout <timeout>
-d
-j
-t
ACTION
celery-logtool-debug command line option
FILES
celery-logtool-errors command line option
FILES
celery-logtool-incomplete command line option
FILES
celery-logtool-stats command line option
FILES
celery-logtool-traces command line option
FILES
celery-migrate command line option
--ack-messages
--forever
--limit <limit>
--queues <queues>
--tasks <tasks>
--timeout <timeout>
-a
-F
-n
-Q
-t
-T
DESTINATION
SOURCE
celery-purge command line option
--exclude-queues <exclude_queues>
--force
--queues <queues>
-f
-Q
-X
celery-result command line option
--task <task>
--traceback
-t
TASK_ID
celery-shell command line option
--bpython
--eventlet
--gevent
--ipython
--python
--without-tasks
-B
-I
-T
celery-status command line option
--destination <destination>
--json
--timeout <timeout>
-d
-j
-t
celery-upgrade-settings command line option
--compat
--django
--no-backup
FILENAME
celery-worker command line option
--autoscale <autoscale>
--beat
--concurrency <concurrency>
--detach
--discard
--events
--exclude-queues <exclude_queues>
--executable <executable>
--gid <gid>
--heartbeat-interval <heartbeat_interval>
--hostname <hostname>
--include <include>
--logfile <logfile>
--loglevel <loglevel>
--max-memory-per-child <max_memory_per_child>
--max-tasks-per-child <max_tasks_per_child>
--pidfile <pidfile>
--pool <pool>
--prefetch-multiplier <prefetch multiplier>
--purge
--queues <queues>
--schedule <schedule_filename>
--schedule-filename
--scheduler <scheduler>
--soft-time-limit <soft_time_limit>
--statedb <statedb>
--task-events
--time-limit <time_limit>
--uid <uid>
,
[1]
--umask <umask>
--without-gossip
--without-heartbeat
--without-mingle
-B
-c
-D
-E
-f
-I
-l
-n
-O <optimization>
-P
-Q
-S
-s
-X
celery._state
module
celery.app
module
celery.app.amqp
module
celery.app.annotations
module
celery.app.autoretry
module
celery.app.backends
module
celery.app.builtins
module
celery.app.control
module
celery.app.defaults
module
celery.app.events
module
celery.app.log
module
celery.app.registry
module
celery.app.routes
module
celery.app.task
module
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.arangodb
module
celery.backends.asynchronous
module
celery.backends.azureblockblob
module
celery.backends.base
module
celery.backends.cache
module
celery.backends.cassandra
module
celery.backends.consul
module
celery.backends.cosmosdbsql
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.dynamodb
module
celery.backends.elasticsearch
module
celery.backends.filesystem
module
celery.backends.mongodb
module
celery.backends.redis
module
celery.backends.rpc
module
celery.backends.s3
module
celery.beat
module
celery.bin.base
module
celery.bin.beat
module
celery.bin.call
module
celery.bin.celery
module
celery.bin.control
module
celery.bin.events
module
celery.bin.graph
module
celery.bin.list
module
celery.bin.logtool
module
celery.bin.migrate
module
celery.bin.multi
module
celery.bin.purge
module
celery.bin.result
module
celery.bin.shell
module
celery.bin.upgrade
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.concurrency.thread
module
celery.contrib.abortable
module
celery.contrib.migrate
module
celery.contrib.pytest
module
celery.contrib.rdb
module
celery.contrib.sphinx
module
celery.contrib.testing.app
module
celery.contrib.testing.manager
module
celery.contrib.testing.mocks
module
celery.contrib.testing.worker
module
celery.events
module
celery.events.cursesmon
module
celery.events.dispatcher
module
celery.events.dumper
module
celery.events.event
module
celery.events.receiver
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.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.autoscale
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.worker.worker
module
celery_app() (in module celery.contrib.pytest)
CELERY_BENCH
CELERY_BROKER_URL
CELERY_CHDIR
celery_class_tasks() (in module celery.contrib.pytest)
celery_config() (in module celery.contrib.pytest)
CELERY_CONFIG_MODULE
,
[1]
,
[2]
CELERY_CREATE_DIRS
celery_enable_logging() (in module celery.contrib.pytest)
celery_includes() (in module celery.contrib.pytest)
CELERY_LOADER
,
[1]
,
[2]
,
[3]
,
[4]
,
[5]
celery_parameters() (in module celery.contrib.pytest)
CELERY_RDB_HOST
CELERY_RDB_PORT
CELERY_RDBSIG
celery_session_app() (in module celery.contrib.pytest)
celery_session_worker() (in module celery.contrib.pytest)
CELERY_SU
CELERY_TRACE_APP
,
[1]
,
[2]
celery_worker() (in module celery.contrib.pytest)
celery_worker_parameters() (in module celery.contrib.pytest)
celery_worker_pool() (in module celery.contrib.pytest)
CeleryBeat (class in celery.bin.worker)
CeleryCommand (class in celery.bin.base)
CeleryCommandException
CELERYCTL
celeryd_after_setup
signal
celeryd_init
signal
CELERYD_SU_ARGS
CeleryDaemonCommand (class in celery.bin.base)
CeleryError
CeleryOption (class in celery.bin.base)
CeleryWarning
Certificate (class in celery.security.certificate)
CertStore (class in celery.security.certificate)
chain (class in celery)
ChainMap (class in celery.utils.collections)
changes (celery.utils.collections.ChainMap attribute)
channel (celery.backends.rpc.RPCBackend.Exchange attribute)
(celery.backends.rpc.RPCBackend.ResultConsumer.Consumer attribute)
channel() (celery.backends.rpc.RPCBackend.Producer property)
check_module() (celery.contrib.sphinx.TaskDocumenter method)
children() (celery.result.AsyncResult property)
(celery.result.GroupResult property)
chord (celery.worker.request.Request attribute)
(in module celery)
chord_size() (celery.utils.abstract.CallableSignature property)
ChordError
chunks() (celery.app.task.Task method)
(in module celery.utils)
(in module celery.utils.functional)
cipater
claim_steps() (celery.bootsteps.Blueprint method)
cleanup() (celery.backends.arangodb.ArangoDbBackend method)
(celery.backends.database.DatabaseBackend method)
(celery.backends.filesystem.FilesystemBackend 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)
CLIContext (class in celery.bin.base)
client (celery.backends.cache.CacheBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
client() (celery.backends.consul.ConsulBackend method)
(celery.backends.dynamodb.DynamoDBBackend property)
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.rpc.RPCBackend.Producer method)
(celery.backends.rpc.RPCBackend.ResultConsumer.Consumer method)
(celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
(celery.bootsteps.Blueprint method)
(celery.bootsteps.StartStopStep method)
(celery.Celery method)
(celery.concurrency.base.BasePool method)
(celery.events.dispatcher.EventDispatcher 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)
collect() (celery.result.AsyncResult method)
collection (celery.backends.arangodb.ArangoDbBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
colored (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)
CommaSeparatedList (class in celery.bin.base)
compatible_transport() (celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
(celery.worker.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle method)
compatible_transports (celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.Mingle attribute)
(celery.worker.consumer.mingle.Mingle attribute)
completed_count() (celery.result.ResultSet method)
compress() (celery.worker.state.Persistent method)
compression (celery.backends.rpc.RPCBackend.Producer attribute)
(Task attribute)
conditional (celery.bootsteps.Step attribute)
(celery.worker.autoscale.WorkerComponent attribute)
(celery.worker.components.Beat attribute)
(celery.worker.consumer.Agent attribute)
(celery.worker.consumer.agent.Agent attribute)
conf() (celery.app.control.Inspect method)
(celery.loaders.base.BaseLoader property)
config_from_envvar() (celery.Celery method)
config_from_object() (celery.Celery method)
(celery.loaders.base.BaseLoader method)
ConfigurationView (class in celery.utils.collections)
configure() (celery.backends.database.models.Task class method)
(celery.backends.database.models.TaskSet class method)
configured (celery.loaders.base.BaseLoader attribute)
connect() (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.beat.Scheduler attribute)
Connection (class in celery.worker.consumer)
(class in celery.worker.consumer.connection)
connection() (celery.backends.arangodb.ArangoDbBackend property)
(celery.backends.couchbase.CouchbaseBackend property)
(celery.backends.couchdb.CouchBackend property)
(celery.backends.rpc.RPCBackend.Producer property)
(celery.backends.rpc.RPCBackend.ResultConsumer.Consumer property)
(celery.Celery method)
(celery.events.EventReceiver property)
(celery.events.receiver.EventReceiver property)
connection_class_ssl (celery.backends.redis.RedisBackend attribute)
(celery.backends.redis.SentinelBackend attribute)
connection_errors() (celery.worker.request.Request property)
connection_for_read() (celery.Celery method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
connection_for_write() (celery.Celery method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
connection_or_acquire() (celery.Celery method)
ConnectionPool() (celery.backends.redis.RedisBackend property)
consistency (celery.backends.consul.ConsulBackend attribute)
consul (celery.backends.consul.ConsulBackend attribute)
ConsulBackend (class in celery.backends.consul)
consume() (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer method)
consume_from() (celery.app.amqp.Queues property)
(celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.RPCBackend.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.rpc.RPCBackend.ResultConsumer.Consumer method)
container (celery.backends.couchdb.CouchBackend attribute)
content_encoding() (celery.worker.request.Request property)
content_type() (celery.worker.request.Request property)
context
Context (class in celery.app.task)
ContextMock() (in module celery.contrib.testing.mocks)
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)
control_exchange
setting
control_queue_expires
setting
control_queue_ttl
setting
controller
convert() (celery.bin.base.CommaSeparatedList method)
(celery.bin.base.ISO8601DateTime method)
(celery.bin.base.ISO8601DateTimeOrFloat method)
(celery.bin.base.JsonArray method)
(celery.bin.base.JsonObject method)
(celery.bin.base.LogLevel method)
(celery.bin.celery.App method)
(celery.bin.worker.Autoscale method)
(celery.bin.worker.CeleryBeat method)
(celery.bin.worker.Hostname method)
(celery.bin.worker.WorkersPool method)
copy() (celery.utils.collections.ChainMap method)
correlation_id() (celery.worker.request.Request property)
cosmosdbsql_collection_name
setting
cosmosdbsql_consistency_level
setting
cosmosdbsql_database_name
setting
cosmosdbsql_max_retry_attempts
setting
cosmosdbsql_max_retry_wait_time
setting
CosmosDBSQLBackend (class in celery.backends.cosmosdbsql)
CouchBackend (class in celery.backends.couchdb)
couchbase_backend_settings
setting
CouchbaseBackend (class in celery.backends.couchbase)
count (celery.contrib.migrate.State attribute)
CPendingDeprecationWarning
create() (celery.bootsteps.Step method)
(celery.worker.autoscale.WorkerComponent 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_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)
(in module celery._state)
current_task (celery.Celery attribute)
(in module celery)
(in module celery._state)
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
DaemonContext (class in celery.platforms)
data (celery.worker.control.Panel attribute)
data() (celery.apps.multi.Cluster property)
database (celery.backends.arangodb.ArangoDbBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
database_engine_options
setting
database_name (celery.backends.mongodb.MongoBackend attribute)
database_short_lived_sessions
setting
database_table_names
setting
database_table_schemas
setting
DatabaseBackend (class in celery.backends.database)
date_done (celery.backends.database.models.Task attribute)
(celery.backends.database.models.TaskExtended attribute)
(celery.backends.database.models.TaskSet attribute)
date_done() (celery.result.AsyncResult property)
day_of_month (celery.schedules.crontab attribute)
day_of_week (celery.schedules.crontab attribute)
db (celery.worker.state.Persistent attribute)
db() (celery.backends.arangodb.ArangoDbBackend property)
debugger() (in module celery.contrib.rdb)
declare() (celery.backends.rpc.RPCBackend.Exchange method)
(celery.backends.rpc.RPCBackend.Producer method)
(celery.backends.rpc.RPCBackend.ResultConsumer.Consumer method)
(queue method)
decode() (celery.backends.elasticsearch.ElasticsearchBackend method)
(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() (in module celery.worker.strategy)
default_app (in module celery.app)
default_dispatcher() (celery.app.events.Events method)
default_exchange (celery.app.amqp.AMQP attribute)
default_modules (celery.loaders.base.BaseLoader attribute)
default_nodename() (in module celery.utils.nodenames)
default_now() (celery.beat.ScheduleEntry method)
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.consumer.Consumer.Blueprint attribute)
(celery.worker.consumer.consumer.Consumer.Blueprint attribute)
(celery.worker.WorkController.Blueprint attribute)
(celery.worker.worker.WorkController.Blueprint attribute)
DEFAULT_TEST_CONFIG (in module celery.contrib.testing.app)
defaults (celery.utils.collections.ChainMap attribute)
delay() (celery.app.task.Task method)
(celery.utils.abstract.CallableTask method)
delete() (celery.backends.arangodb.ArangoDbBackend method)
(celery.backends.azureblockblob.AzureBlockBlobBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.cosmosdbsql.CosmosDBSQLBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.dynamodb.DynamoDBBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.rpc.RPCBackend.Exchange method)
(celery.backends.s3.S3Backend method)
(celery.result.GroupResult method)
(exchange method)
(queue method)
delete_group() (celery.backends.rpc.RPCBackend method)
deleter() (celery.utils.cached_property method)
delivery_info() (celery.worker.request.Request property)
delivery_mode (celery.backends.rpc.RPCBackend.Exchange attribute)
,
[1]
DELIVERY_TAG
celery-amqp-basic.ack command line option
delta_resolution() (in module celery.utils.time)
DependencyGraph (class in celery.utils.graph)
depends_on_current_app() (in module celery.contrib.pytest)
deprecate_by (celery.app.defaults.Option attribute)
deselect() (celery.app.amqp.Queues method)
deserialize() (celery.security.serialization.SecureSerializer method)
DESTINATION
celery-migrate command line option
destination_for() (celery.backends.rpc.RPCBackend method)
detach() (in module celery.bin.worker)
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)
DIRS (celery.utils.graph.DOT attribute)
disable() (celery.events.dispatcher.EventDispatcher method)
(celery.events.EventDispatcher method)
disable_events
control
disable_events() (celery.app.control.Control method)
disable_trace() (in module celery.app)
DISABLED_TRANSPORTS (celery.events.dispatcher.EventDispatcher attribute)
(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)
Dispatcher (celery.app.events.Events attribute)
dispatcher_cls (celery.app.events.Events attribute)
display_height() (celery.events.cursesmon.CursesMonitor property)
display_task_row() (celery.events.cursesmon.CursesMonitor method)
display_width() (celery.events.cursesmon.CursesMonitor property)
DJANGO_SETTINGS_MODULE
,
[1]
,
[2]
,
[3]
,
[4]
doc_type (celery.backends.elasticsearch.ElasticsearchBackend attribute)
document_members() (celery.contrib.sphinx.TaskDocumenter method)
DOT (class in celery.utils.graph)
DOWN (celery.bin.multi.MultiTool attribute)
drain_events() (celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.RPCBackend.ResultConsumer method)
drain_events_until() (celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.asynchronous.Drainer method)
Drainer (class in celery.backends.asynchronous)
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-amqp-exchange.declare command line option
celery-amqp-queue.declare command line option
durable (celery.backends.rpc.RPCBackend.Exchange attribute)
,
[1]
DynamoDBBackend (class in celery.backends.dynamodb)
E
EagerResult (class in celery.result)
early ack
early acknowledgment
echo() (celery.bin.base.CLIContext 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)
editable_fields_equal() (celery.beat.ScheduleEntry method)
elasticsearch_max_retries
setting
elasticsearch_retry_on_timeout
setting
elasticsearch_save_meta_as_text
setting
elasticsearch_timeout
setting
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)
emit_banner() (celery.apps.worker.Worker method)
empty() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
enable() (celery.events.dispatcher.EventDispatcher method)
(celery.events.EventDispatcher method)
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.elasticsearch.ElasticsearchBackend method)
(celery.backends.mongodb.MongoBackend method)
endpoint_url (celery.backends.dynamodb.DynamoDBBackend attribute)
ensure() (celery.backends.redis.RedisBackend method)
ensure_chords_allowed() (celery.backends.base.DisabledBackend method)
(celery.backends.rpc.RPCBackend method)
ensure_connected() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
ensure_newlines() (in module celery.utils.text)
ensure_not_for_a_while() (celery.contrib.testing.manager.ManagerMixin method)
ensure_sep() (in module celery.utils.text)
ensure_started() (celery.concurrency.base.BasePool.Timer method)
(celery.contrib.testing.worker.TestWorkController 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
C_FAKEFORK
,
[1]
,
[2]
,
[3]
,
[4]
C_FORCE_ROOT
,
[1]
C_IMPDEBUG
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
,
[1]
CELERY_RDB_PORT
,
[1]
CELERY_RDBSIG
CELERY_SU
CELERY_TRACE_APP
,
[1]
,
[2]
CELERYCTL
CELERYD_SU_ARGS
DJANGO_SETTINGS_MODULE
,
[1]
,
[2]
,
[3]
,
[4]
MP_LOG
,
[1]
NOSE_VERBOSE
USE_FAST_LOCALS
errbacks (celery.worker.request.Request attribute)
ERROR (celery.bin.base.CLIContext attribute)
error() (celery.bin.base.CLIContext method)
es_max_retries (celery.backends.elasticsearch.ElasticsearchBackend attribute)
es_retry_on_timeout (celery.backends.elasticsearch.ElasticsearchBackend attribute)
es_timeout (celery.backends.elasticsearch.ElasticsearchBackend attribute)
ETA
eta (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
eta() (celery.worker.request.Request property)
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)
(in module celery.events.event)
event_count (celery.events.state.State attribute)
event_dispatcher
event_exchange
setting
event_exchange (in module celery.events.event)
event_from_message() (celery.events.EventReceiver method)
(celery.events.receiver.EventReceiver method)
event_queue_expires
setting
event_queue_prefix
setting
event_queue_ttl
setting
event_serializer
setting
EventDispatcher (class in celery.events)
(class in celery.events.dispatcher)
eventer() (celery.worker.request.Request property)
eventlet_pool_apply
signal
eventlet_pool_postshutdown
signal
eventlet_pool_preshutdown
signal
eventlet_pool_started
signal
EventReceiver (class in celery.events)
(class in celery.events.receiver)
events (celery.Celery attribute)
Events (class in celery.app.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_safe_to_retry() (celery.backends.elasticsearch.ElasticsearchBackend method)
EXCEPTION_STATES
state
EXCHANGE
celery-amqp-basic.publish command line option
celery-amqp-exchange.declare command line option
celery-amqp-exchange.delete command line option
celery-amqp-queue.bind command line option
exchange (celery.app.control.Control.Mailbox attribute)
(celery.backends.rpc.RPCBackend.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.worker.request.Request method)
execute_from_commandline() (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)
(celery.worker.worker.WorkController attribute)
expand() (celery.bin.multi.MultiTool method)
expand_destination() (celery.app.routes.Router method)
expire() (celery.backends.cache.CacheBackend method)
(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)
expires() (celery.worker.request.Request property)
expires_delta (celery.backends.arangodb.ArangoDbBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
extend() (celery.utils.collections.BufferMap method)
(celery.utils.collections.Messagebuffer method)
extend_buffer() (celery.events.dispatcher.EventDispatcher method)
(celery.events.EventDispatcher method)
extended_result() (celery.backends.database.DatabaseBackend property)
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)
FILENAME
celery-upgrade-settings command line option
FILES
celery-logtool-debug command line option
celery-logtool-errors command line option
celery-logtool-incomplete command line option
celery-logtool-stats command line option
celery-logtool-traces command line option
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.app.utils.Settings method)
(celery.Celery method)
find() (celery.apps.multi.Cluster method)
(in module celery.app.defaults)
find_app() (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.rpc.RPCBackend.ResultConsumer.Consumer method)
flush() (celery.concurrency.base.BasePool method)
(celery.events.dispatcher.EventDispatcher 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.backends.redis.RedisBackend method)
(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_args() (celery.contrib.sphinx.TaskDocumenter method)
format_options() (celery.bin.base.CeleryCommand method)
format_row() (celery.events.cursesmon.CursesMonitor 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)
fromutc() (celery.utils.time.LocalTimezone 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)
fun_accepts_kwargs() (in module celery.utils.functional)
G
gen_task_name() (celery.Celery method)
(in module celery.utils)
(in module celery.utils.imports)
gen_unique_id() (in module celery.utils)
get() (celery.backends.arangodb.ArangoDbBackend method)
(celery.backends.azureblockblob.AzureBlockBlobBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.cosmosdbsql.CosmosDBSQLBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.dynamodb.DynamoDBBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.s3.S3Backend 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_available_pool_names() (in module celery.concurrency)
get_by_parts() (celery.app.utils.Settings method)
get_cls_by_name() (in module celery.utils)
get_consumers() (celery.bootsteps.ConsumerStep method)
(celery.events.EventReceiver method)
(celery.events.receiver.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() (celery.bin.base.CeleryOption method)
get_default_logger() (celery.app.log.Logging method)
get_digest_algorithm() (in module celery.security.utils)
get_engine() (celery.backends.database.session.SessionManager method)
get_errno_name() (in module celery.platforms)
get_exchange() (in module celery.events)
(in module celery.events.event)
get_exponential_backoff_interval() (in module celery.utils.time)
get_fdmax() (in module celery.platforms)
get_full_cls_name() (in module celery.utils)
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.base.DisabledBackend method)
get_multiprocessing_logger() (in module celery.utils.log)
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_pubkey() (celery.security.certificate.Certificate method)
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_signature_prefix() (celery.contrib.sphinx.TaskDirective 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.rpc.RPCBackend method)
get_task_meta_for() (celery.backends.base.DisabledBackend method)
get_traceback() (celery.backends.base.DisabledBackend method)
gethostname() (in module celery.utils.nodenames)
getitem_property (class in celery.utils.objects)
getopt() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
getpids() (celery.apps.multi.Cluster method)
gossip
Gossip (class in celery.worker.consumer)
(class in celery.worker.consumer.gossip)
gPidbox (class in celery.worker.pidbox)
graph (celery.result.AsyncResult attribute)
graph_scheme (celery.utils.graph.GraphFormatter attribute)
GraphFormatter (celery.bootsteps.Blueprint attribute)
(class in celery.utils.graph)
green() (celery.utils.term.colored method)
greet (celery.events.cursesmon.CursesMonitor attribute)
group (celery.worker.request.Request attribute)
(class in celery)
group_collection (celery.backends.mongodb.MongoBackend attribute)
group_from() (in module celery.events)
(in module celery.events.event)
group_index (celery.worker.request.Request 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_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_preload_options() (in module celery.bin.base)
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)
has_listeners() (celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal 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() (celery.app.control.Control method)
heartbeat_expires() (celery.events.state.State.Worker property)
(celery.events.state.Worker property)
(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)
host (celery.backends.arangodb.ArangoDbBackend attribute)
(celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.elasticsearch.ElasticsearchBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
host_format() (in module celery.utils.nodenames)
hostname
,
[1]
(celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
Hostname (class in celery.bin.worker)
hostname() (celery.worker.request.Request property)
hour (celery.schedules.crontab attribute)
http_protocol (celery.backends.arangodb.ArangoDbBackend attribute)
hub
,
[1]
Hub (class in celery.worker.components)
human_seconds() (celery.schedules.schedule property)
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.TaskExtended attribute)
(celery.backends.database.models.TaskSet attribute)
(celery.result.AsyncResult attribute)
(celery.result.GroupResult attribute)
(celery.worker.request.Request attribute)
id() (celery.events.state.State.Task property)
(celery.events.state.State.Worker property)
(celery.events.state.Task property)
(celery.events.state.Worker property)
(celery.utils.abstract.CallableSignature property)
idempotent
IF_EMPTY
celery-amqp-queue.delete command line option
IF_UNUSED
celery-amqp-exchange.delete command line option
celery-amqp-queue.delete command line option
Ignore
ignore_errno() (in module celery.platforms)
ignore_result (celery.app.task.Task attribute)
(Task attribute)
ignore_result() (celery.worker.request.Request property)
ignored() (celery.result.AsyncResult property)
igreen() (celery.utils.term.colored method)
imagenta() (celery.utils.term.colored method)
IMMEDIATE
celery-amqp-basic.publish command line option
immutable() (celery.utils.abstract.CallableSignature property)
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)
(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)
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)
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 property)
(celery.beat.Scheduler property)
(celery.bootsteps.Blueprint method)
(celery.bootsteps.Step method)
(celery.concurrency.base.BasePool property)
(celery.events.state.State.Task method)
(celery.events.state.Task method)
(celery.result.AsyncResult property)
(celery.worker.autoscale.Autoscaler method)
(celery.worker.autoscale.WorkerComponent method)
(celery.worker.components.Pool method)
(celery.worker.consumer.Connection method)
(celery.worker.consumer.connection.Connection method)
(celery.worker.consumer.Tasks method)
(celery.worker.consumer.tasks.Tasks method)
(celery.worker.request.Request method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController 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)
inspect() (celery.contrib.testing.manager.ManagerMixin method)
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)
(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_accepted() (celery.contrib.testing.manager.ManagerMixin method)
is_async() (celery.backends.asynchronous.AsyncBackendMixin property)
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)
is_received() (celery.contrib.testing.manager.ManagerMixin method)
is_result_task_in_progress() (celery.contrib.testing.manager.ManagerMixin static method)
isatty() (celery.utils.log.LoggingProxy method)
(in module celery.platforms)
ISO8601DateTime (class in celery.bin.base)
ISO8601DateTimeOrFloat (class in celery.bin.base)
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.asynchronous.AsyncBackendMixin method)
(celery.result.ResultSet method)
itercapture() (celery.events.EventReceiver method)
(celery.events.receiver.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.contrib.testing.manager.ManagerMixin method)
(celery.result.ResultSet method)
(in module celery.utils.text)
join_native() (celery.result.ResultSet method)
JsonArray (class in celery.bin.base)
JsonObject (class in celery.bin.base)
K
key_t (celery.backends.arangodb.ArangoDbBackend attribute)
(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.backends.database.models.TaskExtended attribute)
(celery.beat.ScheduleEntry attribute)
(celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
kwargs() (celery.result.AsyncResult property)
(celery.utils.abstract.CallableSignature property)
(celery.worker.request.Request property)
kwargsrepr() (celery.worker.request.Request property)
kwargsrepr_maxsize (celery.app.amqp.AMQP attribute)
L
label (celery.bootsteps.Step attribute)
(celery.worker.autoscale.WorkerComponent attribute)
(celery.worker.components.Beat attribute)
(celery.worker.consumer.consumer.Evloop attribute)
(celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.Mingle 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)
limit() (celery.events.cursesmon.CursesMonitor property)
LimitedSet (class in celery.utils.collections)
link() (celery.utils.abstract.CallableSignature method)
link_error() (celery.utils.abstract.CallableSignature method)
load_average() (in module celery.utils.sysinfo)
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)
LogLevel (class in celery.bin.base)
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)
maintain_pool() (celery.concurrency.base.BasePool method)
make_aware() (in module celery.utils.time)
Manager (class in celery.contrib.testing.manager)
ManagerMixin (class in celery.contrib.testing.manager)
MANDATORY
celery-amqp-basic.publish command line option
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)
,
[1]
MaxRetriesExceededError
maxsize (celery.utils.collections.BufferMap attribute)
maybe() (in module celery.utils.functional)
maybe_declare() (celery.backends.rpc.RPCBackend.Producer 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() (in module celery.utils.time)
maybe_reraise() (celery.result.AsyncResult method)
(celery.result.ResultSet method)
maybe_scale() (celery.worker.autoscale.Autoscaler method)
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)
maybe_warn_deprecated_settings() (celery.app.utils.Settings method)
mem_rss() (in module celery.utils.debug)
memdump() (celery.app.control.Inspect method)
(in module celery.utils.debug)
memoize() (in module celery.utils)
(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.rpc.RPCBackend.Exchange method)
message() (celery.worker.request.Request property)
Messagebuffer (class in celery.utils.collections)
Messagebuffer.Empty
meta (celery.worker.control.Panel attribute)
mget() (celery.backends.arangodb.ArangoDbBackend method)
(celery.backends.azureblockblob.AzureBlockBlobBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.cosmosdbsql.CosmosDBSQLBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.dynamodb.DynamoDBBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend 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)
missing_results() (celery.contrib.testing.manager.ManagerMixin method)
mlazy (class in celery.utils.functional)
mlevel() (in module celery.utils.log)
mode (celery.utils.log.LoggingProxy attribute)
module
celery
celery._state
celery.app
celery.app.amqp
celery.app.annotations
celery.app.autoretry
celery.app.backends
celery.app.builtins
celery.app.control
celery.app.defaults
celery.app.events
celery.app.log
celery.app.registry
celery.app.routes
celery.app.task
celery.app.trace
celery.app.utils
celery.apps.beat
celery.apps.multi
celery.apps.worker
celery.backends
celery.backends.arangodb
celery.backends.asynchronous
celery.backends.azureblockblob
celery.backends.base
celery.backends.cache
celery.backends.cassandra
celery.backends.consul
celery.backends.cosmosdbsql
celery.backends.couchbase
celery.backends.couchdb
celery.backends.database
celery.backends.database.models
celery.backends.database.session
celery.backends.dynamodb
celery.backends.elasticsearch
celery.backends.filesystem
celery.backends.mongodb
celery.backends.redis
celery.backends.rpc
celery.backends.s3
celery.beat
celery.bin.base
celery.bin.beat
celery.bin.call
celery.bin.celery
celery.bin.control
celery.bin.events
celery.bin.graph
celery.bin.list
celery.bin.logtool
celery.bin.migrate
celery.bin.multi
celery.bin.purge
celery.bin.result
celery.bin.shell
celery.bin.upgrade
celery.bin.worker
celery.bootsteps
celery.concurrency
celery.concurrency.base
celery.concurrency.eventlet
celery.concurrency.gevent
celery.concurrency.prefork
celery.concurrency.solo
celery.concurrency.thread
celery.contrib.abortable
celery.contrib.migrate
celery.contrib.pytest
celery.contrib.rdb
celery.contrib.sphinx
celery.contrib.testing.app
celery.contrib.testing.manager
celery.contrib.testing.mocks
celery.contrib.testing.worker
celery.events
celery.events.cursesmon
celery.events.dispatcher
celery.events.dumper
celery.events.event
celery.events.receiver
celery.events.snapshot
celery.events.state
celery.exceptions
celery.loaders
celery.loaders.app
celery.loaders.base
celery.loaders.default
celery.platforms
celery.result
celery.schedules
celery.security
celery.security.certificate
celery.security.key
celery.security.serialization
celery.security.utils
celery.signals
celery.states
celery.utils
celery.utils.abstract
celery.utils.collections
celery.utils.debug
celery.utils.deprecated
celery.utils.dispatch
celery.utils.dispatch.signal
celery.utils.functional
celery.utils.graph
celery.utils.imports
celery.utils.iso8601
celery.utils.log
celery.utils.nodenames
celery.utils.objects
celery.utils.saferepr
celery.utils.serialization
celery.utils.sysinfo
celery.utils.term
celery.utils.text
celery.utils.threads
celery.utils.time
celery.utils.timer2
celery.worker
celery.worker.autoscale
celery.worker.components
celery.worker.consumer
celery.worker.consumer.agent
celery.worker.consumer.connection
celery.worker.consumer.consumer
celery.worker.consumer.control
celery.worker.consumer.events
celery.worker.consumer.gossip
celery.worker.consumer.heart
celery.worker.consumer.mingle
celery.worker.consumer.tasks
celery.worker.control
celery.worker.heartbeat
celery.worker.loops
celery.worker.pidbox
celery.worker.request
celery.worker.state
celery.worker.strategy
celery.worker.worker
module_file() (in module celery.utils.imports)
mongo_host (celery.backends.mongodb.MongoBackend attribute)
MongoBackend (class in celery.backends.mongodb)
mongodb_backend_settings
setting
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_direct() (in module celery.contrib.migrate)
move_direct_by_id() (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)
MP_LOG
,
[1]
mro_lookup() (in module celery.utils.objects)
MSG
celery-amqp-basic.publish command line option
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-call command line option
name (celery.app.task.Task attribute)
(celery.backends.database.models.TaskExtended attribute)
(celery.backends.rpc.RPCBackend.Exchange attribute)
,
[1]
(celery.beat.ScheduleEntry attribute)
(celery.bin.base.CommaSeparatedList attribute)
(celery.bin.base.ISO8601DateTime attribute)
(celery.bin.base.ISO8601DateTimeOrFloat attribute)
(celery.bin.base.JsonArray attribute)
(celery.bin.base.JsonObject attribute)
(celery.bin.celery.App attribute)
(celery.bin.worker.Autoscale attribute)
(celery.bin.worker.CeleryBeat attribute)
(celery.bin.worker.Hostname attribute)
(celery.bin.worker.WorkersPool 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.log.LoggingProxy attribute)
(celery.worker.autoscale.WorkerComponent 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.agent.Agent attribute)
(celery.worker.consumer.Connection attribute)
(celery.worker.consumer.connection.Connection attribute)
(celery.worker.consumer.Consumer.Blueprint attribute)
(celery.worker.consumer.consumer.Consumer.Blueprint attribute)
(celery.worker.consumer.consumer.Evloop attribute)
(celery.worker.consumer.Control attribute)
(celery.worker.consumer.control.Control attribute)
(celery.worker.consumer.Events attribute)
(celery.worker.consumer.events.Events attribute)
(celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.Heart attribute)
(celery.worker.consumer.heart.Heart attribute)
(celery.worker.consumer.Mingle attribute)
(celery.worker.consumer.mingle.Mingle attribute)
(celery.worker.consumer.Tasks attribute)
(celery.worker.consumer.tasks.Tasks attribute)
(celery.worker.request.Request attribute)
(celery.worker.WorkController.Blueprint attribute)
(celery.worker.worker.WorkController.Blueprint attribute)
(Task attribute)
name() (celery.result.AsyncResult property)
(celery.utils.abstract.CallableSignature property)
names() (celery.bin.multi.MultiTool method)
namespace (celery.app.control.Control.Mailbox attribute)
nap() (celery.events.cursesmon.CursesMonitor method)
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-amqp-basic.get command line option
no_ack (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer attribute)
no_color() (celery.utils.term.colored method)
no_declare (celery.backends.rpc.RPCBackend.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() (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)
(in module celery.utils.functional)
NOSE_VERBOSE
NotAPackage
NotConfigured
NotRegistered
now() (celery.Celery method)
(celery.loaders.base.BaseLoader method)
nowfun (celery.schedules.crontab attribute)
nullipotent
num_processes() (celery.concurrency.base.BasePool property)
(celery.concurrency.gevent.TaskPool property)
(celery.concurrency.prefork.TaskPool property)
O
obj (celery.bootsteps.StartStopStep attribute)
(celery.utils.collections.DictAttribute attribute)
objgraph() (celery.app.control.Inspect method)
oid (celery.backends.rpc.RPCBackend attribute)
(celery.Celery attribute)
oid() (celery.app.control.Control.Mailbox property)
OK (celery.bin.base.CLIContext attribute)
(celery.bin.multi.MultiTool attribute)
old (celery.app.defaults.Option attribute)
on_accepted() (celery.worker.request.Request method)
on_ack() (celery.worker.request.Request property)
on_after_fork() (celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.RPCBackend.ResultConsumer method)
on_after_init() (celery.apps.worker.Worker method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
on_apply() (celery.concurrency.base.BasePool method)
(celery.concurrency.eventlet.TaskPool method)
(celery.concurrency.gevent.TaskPool method)
(celery.concurrency.thread.TaskPool method)
on_before_init() (celery.apps.worker.Worker method)
(celery.worker.WorkController method)
(celery.worker.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.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController 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)
(celery.events.receiver.EventReceiver method)
on_consumer_ready() (celery.apps.worker.Worker method)
(celery.contrib.testing.worker.TestWorkController method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
on_crash() (celery.utils.threads.bgThread method)
on_decode_error (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer attribute)
on_decode_error() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_disabled (celery.events.dispatcher.EventDispatcher attribute)
(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.dispatcher.EventDispatcher attribute)
(celery.events.EventDispatcher attribute)
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)
(celery.worker.worker.WorkController method)
on_invalid_task() (celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
on_message (celery.backends.rpc.RPCBackend.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.asynchronous.BaseResultConsumer method)
(celery.backends.rpc.RPCBackend 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 property)
on_reply_declare() (celery.backends.rpc.RPCBackend method)
on_result_fulfilled() (celery.backends.asynchronous.AsyncBackendMixin method)
(celery.backends.rpc.RPCBackend method)
on_retry()
(celery.app.task.Task method)
(celery.worker.request.Request method)
on_return (celery.backends.rpc.RPCBackend.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)
(celery.worker.worker.WorkController method)
on_state_change() (celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.redis.RedisBackend.ResultConsumer 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.concurrency.thread.TaskPool method)
(celery.worker.pidbox.gPidbox method)
(celery.worker.pidbox.Pidbox method)
on_stopped() (celery.worker.WorkController method)
(celery.worker.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_wait_for_pending() (celery.backends.asynchronous.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)
online_str (celery.events.cursesmon.CursesMonitor attribute)
open() (celery.platforms.DaemonContext method)
(celery.worker.state.Persistent method)
OperationalError
Option (class in celery.app.defaults)
OptionParser (celery.bin.multi.MultiTool attribute)
options (celery.backends.mongodb.MongoBackend attribute)
(celery.beat.ScheduleEntry attribute)
options() (celery.utils.abstract.CallableSignature property)
OrderedDict (class in celery.utils.collections)
origin() (celery.events.state.State.Task property)
(celery.events.state.Task property)
override_backends
setting
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)
parent_id() (celery.worker.request.Request property)
parse() (celery.bin.multi.MultiTool.MultiParser method)
(celery.schedules.crontab_parser method)
parse_gid() (in module celery.platforms)
parse_iso8601() (in module celery.utils.iso8601)
parse_uid() (in module celery.platforms)
ParseException
PASSIVE
celery-amqp-exchange.declare command line option
celery-amqp-queue.declare command line option
passive (celery.backends.rpc.RPCBackend.Exchange attribute)
password (celery.backends.arangodb.ArangoDbBackend attribute)
(celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.elasticsearch.ElasticsearchBackend attribute)
(celery.backends.mongodb.MongoBackend 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.rpc.RPCBackend attribute)
Persistent (class in celery.worker.state)
PERSISTENT_DELIVERY_MODE (celery.backends.rpc.RPCBackend.Exchange attribute)
PersistentScheduler (class in celery.beat)
pid (celery.events.state.State.Worker attribute)
(celery.events.state.Worker attribute)
pid() (celery.apps.multi.Node property)
(celery.bin.multi.MultiTool.MultiParser.Node property)
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)
(celery.worker.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.rpc.RPCBackend method)
pool
,
[1]
(celery.Celery attribute)
Pool (celery.concurrency.prefork.TaskPool attribute)
pool (celery.worker.consumer.Consumer attribute)
(celery.worker.consumer.consumer.Consumer attribute)
(celery.worker.WorkController attribute)
(celery.worker.worker.WorkController attribute)
Pool (class in celery.worker.components)
pool_grow() (celery.app.control.Control method)
pool_restart() (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)
populate_heap() (celery.beat.Scheduler method)
port (celery.backends.arangodb.ArangoDbBackend attribute)
(celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.elasticsearch.ElasticsearchBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
precedence() (in module celery.states)
prefetch count
prefetch multiplier
prefetch_count (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer attribute)
prepare() (in module celery.app.annotations)
(in module celery.app.routes)
prepare_args() (celery.worker.WorkController method)
(celery.worker.worker.WorkController 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)
pretty() (celery.bin.base.CLIContext method)
(in module celery.utils.text)
pretty_dict_ok_error() (celery.bin.base.CLIContext method)
pretty_list() (celery.bin.base.CLIContext method)
priority (celery.app.task.Task attribute)
PrivateKey (class in celery.security.key)
process() (celery.events.EventReceiver method)
(celery.events.receiver.EventReceiver 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)
processes() (celery.worker.autoscale.Autoscaler property)
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.app.control.Control.Mailbox attribute)
(celery.Celery attribute)
PROPAGATE_STATES
state
Property() (in module celery.utils.deprecated)
protocol (celery.worker.state.Persistent attribute)
ps() (in module celery.utils.debug)
publish() (celery.backends.rpc.RPCBackend.Exchange method)
(celery.backends.rpc.RPCBackend.Producer method)
(celery.events.dispatcher.EventDispatcher method)
(celery.events.EventDispatcher method)
publisher() (celery.events.dispatcher.EventDispatcher property)
(celery.events.EventDispatcher property)
purge() (celery.app.control.Control method)
(celery.backends.rpc.RPCBackend.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)
pytest_configure() (in module celery.contrib.pytest)
Python Enhancement Proposals
PEP 257
PEP 8
,
[1]
,
[2]
Q
qos
qos() (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer method)
qty() (celery.worker.autoscale.Autoscaler property)
qualname() (in module celery.utils.imports)
query_router() (celery.app.routes.Router method)
query_task() (celery.app.control.Inspect method)
query_task_states() (celery.contrib.testing.manager.ManagerMixin method)
query_tasks() (celery.contrib.testing.manager.ManagerMixin method)
QUEUE
celery-amqp-basic.get command line option
celery-amqp-queue.bind command line option
celery-amqp-queue.declare command line option
celery-amqp-queue.delete command line option
celery-amqp-queue.purge command line option
queue (celery.backends.database.models.TaskExtended attribute)
queue() (celery.concurrency.base.BasePool.Timer property)
(celery.concurrency.eventlet.TaskPool.Timer property)
(celery.concurrency.gevent.TaskPool.Timer property)
(celery.result.AsyncResult property)
(celery.utils.timer2.Timer property)
QueueNotFound
queues (celery.app.amqp.AMQP attribute)
Queues (class in celery.app.amqp)
Queues() (celery.app.amqp.AMQP method)
queues() (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer property)
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_capacity_units (celery.backends.dynamodb.DynamoDBBackend attribute)
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 property)
(celery.events.state.Task property)
(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.rpc.RPCBackend.ResultConsumer.Consumer method)
received (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
RECEIVED (in module celery.states)
Receiver (celery.app.events.Events attribute)
receiver_cls (celery.app.events.Events attribute)
receivers (celery.utils.dispatch.Signal attribute)
(celery.utils.dispatch.signal.Signal attribute)
reconnect_on_error() (celery.backends.redis.RedisBackend.ResultConsumer method)
recover() (celery.backends.rpc.RPCBackend.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_backend_health_check_interval
setting
redis_backend_use_ssl
setting
redis_max_connections
setting
redis_retry_on_timeout
setting
redis_socket_connect_timeout
setting
redis_socket_keepalive
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.rpc.RPCBackend.ResultConsumer.Consumer method)
register_drainer() (in module celery.backends.asynchronous)
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.autoscale.WorkerComponent method)
(celery.worker.components.Pool method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController 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.rpc.RPCBackend.Producer method)
(celery.platforms.Pidfile method)
reload() (celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
reload_from_cwd() (in module celery.utils.imports)
reload_group_result() (celery.backends.rpc.RPCBackend method)
reload_task_result() (celery.backends.rpc.RPCBackend 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)
remark() (celery.contrib.testing.manager.ManagerMixin 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.asynchronous.AsyncBackendMixin method)
replace() (celery.app.task.Task method)
replaced_task_nesting() (celery.worker.request.Request property)
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 property)
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
Request (celery.app.task.Task attribute)
(class in celery.worker.request)
request (Task attribute)
request() (celery.app.task.Task property)
request_dict() (celery.worker.request.Request property)
request_stack (celery.app.task.Task attribute)
requires (celery.bootsteps.ConsumerStep attribute)
(celery.bootsteps.Step attribute)
(celery.worker.autoscale.WorkerComponent attribute)
(celery.worker.components.Hub attribute)
(celery.worker.components.Pool attribute)
(celery.worker.consumer.Agent attribute)
(celery.worker.consumer.agent.Agent attribute)
(celery.worker.consumer.Control attribute)
(celery.worker.consumer.control.Control attribute)
(celery.worker.consumer.Events attribute)
(celery.worker.consumer.events.Events attribute)
(celery.worker.consumer.Gossip attribute)
(celery.worker.consumer.gossip.Gossip attribute)
(celery.worker.consumer.Heart attribute)
(celery.worker.consumer.heart.Heart attribute)
(celery.worker.consumer.Mingle attribute)
(celery.worker.consumer.mingle.Mingle attribute)
(celery.worker.consumer.Tasks attribute)
(celery.worker.consumer.tasks.Tasks attribute)
reraise() (in module celery.exceptions)
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.gPidbox method)
(celery.worker.pidbox.Pidbox 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)
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.rpc.RPCBackend method)
result (celery.backends.database.models.Task attribute)
(celery.backends.database.models.TaskExtended attribute)
(celery.backends.database.models.TaskSet attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
result() (celery.result.AsyncResult property)
(celery.result.EagerResult property)
result_accept_content
setting
result_backend
setting
result_backend() (celery.app.utils.Settings property)
result_backend_always_retry
setting
result_backend_base_sleep_between_retries_ms
setting
result_backend_max_retries
setting
result_backend_max_sleep_between_retries_ms
setting
result_backend_transport_options
setting
result_cache_max
setting
result_chord_join_timeout
setting
result_chord_retry_interval
setting
result_compression
setting
result_expires
setting
result_extended
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.backends.database.models.TaskExtended attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
retries() (celery.result.AsyncResult property)
RETRY
state
Retry
RETRY (in module celery.states)
retry() (celery.app.task.Task method)
retry_backoff (Task attribute)
retry_backoff_max (Task attribute)
retry_jitter (Task attribute)
retry_over_time() (celery.contrib.testing.manager.ManagerMixin method)
retry_policy (celery.backends.redis.RedisBackend attribute)
(celery.backends.rpc.RPCBackend attribute)
retval (celery.app.trace.TraceInfo attribute)
reverse() (celery.utils.term.colored method)
revive() (celery.backends.rpc.RPCBackend method)
(celery.backends.rpc.RPCBackend.Producer method)
(celery.backends.rpc.RPCBackend.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)
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)
root_id() (celery.worker.request.Request property)
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-amqp-basic.publish command line option
celery-amqp-queue.bind command line option
routing_key (celery.backends.rpc.RPCBackend.Producer attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
RPCBackend (class in celery.backends.rpc)
RPCBackend.BacklogLimitExceeded
RPCBackend.Consumer (class in celery.backends.rpc)
RPCBackend.Exchange (class in celery.backends.rpc)
RPCBackend.Producer (class in celery.backends.rpc)
RPCBackend.Queue (class in celery.backends.rpc)
RPCBackend.ResultConsumer (class in celery.backends.rpc)
RPCBackend.ResultConsumer.Consumer (class in celery.backends.rpc)
RPCBackend.ResultConsumer.Consumer.ContentDisallowed
RUN (celery.concurrency.base.BasePool attribute)
run() (celery.app.task.Task method)
(celery.apps.beat.Beat method)
(celery.concurrency.base.BasePool.Timer method)
(celery.utils.threads.bgThread method)
(celery.utils.timer2.Timer 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)
(celery.worker.worker.WorkController method)
S
s() (celery.app.task.Task method)
s3_access_key_id
setting
s3_base_path
setting
s3_bucket
setting
s3_endpoint_url
setting
s3_region
setting
s3_secret_access_key
setting
S3Backend (class in celery.backends.s3)
safe_add_str() (celery.events.cursesmon.CursesMonitor method)
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.rpc.RPCBackend method)
say() (celery.events.dumper.Dumper method)
say_chat() (celery.bin.base.CLIContext method)
scale_down() (celery.worker.autoscale.Autoscaler method)
scale_up() (celery.worker.autoscale.Autoscaler method)
schedule (celery.beat.ScheduleEntry attribute)
Schedule (celery.concurrency.base.BasePool.Timer attribute)
(celery.utils.timer2.Timer attribute)
schedule (class in celery.schedules)
Schedule (in module celery.utils.timer2)
schedule() (celery.beat.PersistentScheduler property)
(celery.beat.Scheduler property)
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)
schedules_equal() (celery.beat.Scheduler method)
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 property)
screen_width() (celery.events.cursesmon.CursesMonitor property)
secho() (celery.bin.base.CLIContext method)
seconds() (celery.schedules.schedule property)
SecureSerializer (class in celery.security.serialization)
security_cert_store
setting
security_certificate
setting
security_digest
setting
security_key
setting
SecurityError
SecurityWarning
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)
(celery.worker.worker.WorkController attribute)
send() (celery.apps.multi.Node method)
(celery.bin.multi.MultiTool.MultiParser.Node method)
(celery.events.dispatcher.EventDispatcher 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.app.task.Task method)
(celery.worker.request.Request method)
send_events (celery.app.task.Task attribute)
send_hello() (celery.worker.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle method)
send_robust() (celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
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)
Sentinel
sentinel (celery.backends.redis.SentinelBackend attribute)
SentinelBackend (class in celery.backends.redis)
serialize() (celery.security.serialization.SecureSerializer method)
serializer (celery.app.control.Control.Mailbox attribute)
(celery.app.task.Task attribute)
(celery.backends.rpc.RPCBackend.Producer attribute)
(Task attribute)
server() (celery.backends.elasticsearch.ElasticsearchBackend property)
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.arangodb.ArangoDbBackend method)
(celery.backends.azureblockblob.AzureBlockBlobBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.consul.ConsulBackend method)
(celery.backends.cosmosdbsql.CosmosDBSQLBackend method)
(celery.backends.couchbase.CouchbaseBackend method)
(celery.backends.couchdb.CouchBackend method)
(celery.backends.dynamodb.DynamoDBBackend method)
(celery.backends.elasticsearch.ElasticsearchBackend method)
(celery.backends.filesystem.FilesystemBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.s3.S3Backend method)
(celery.utils.abstract.CallableSignature method)
set_chord_size() (celery.backends.redis.RedisBackend 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)
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)
set_trap() (in module celery.contrib.testing.app)
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
arangodb_backend_settings
azureblockblob_base_path
azureblockblob_connection_timeout
azureblockblob_container_name
azureblockblob_read_timeout
azureblockblob_retry_increment_base
azureblockblob_retry_initial_backoff_sec
azureblockblob_retry_max_attempts
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_options
cassandra_port
cassandra_read_consistency
cassandra_servers
cassandra_table
cassandra_write_consistency
control_exchange
control_queue_expires
control_queue_ttl
cosmosdbsql_collection_name
cosmosdbsql_consistency_level
cosmosdbsql_database_name
cosmosdbsql_max_retry_attempts
cosmosdbsql_max_retry_wait_time
couchbase_backend_settings
database_engine_options
database_short_lived_sessions
database_table_names
database_table_schemas
elasticsearch_max_retries
elasticsearch_retry_on_timeout
elasticsearch_save_meta_as_text
elasticsearch_timeout
enable_utc
event_exchange
event_queue_expires
event_queue_prefix
event_queue_ttl
event_serializer
imports
include
mongodb_backend_settings
override_backends
redis_backend_health_check_interval
redis_backend_use_ssl
redis_max_connections
redis_retry_on_timeout
redis_socket_connect_timeout
redis_socket_keepalive
redis_socket_timeout
result_accept_content
result_backend
result_backend_always_retry
result_backend_base_sleep_between_retries_ms
result_backend_max_retries
result_backend_max_sleep_between_retries_ms
result_backend_transport_options
result_cache_max
result_chord_join_timeout
result_chord_retry_interval
result_compression
result_expires
result_extended
result_persistent
result_serializer
s3_access_key_id
s3_base_path
s3_bucket
s3_endpoint_url
s3_region
s3_secret_access_key
security_cert_store
security_certificate
security_digest
security_key
task_acks_late
task_acks_on_failure_or_timeout
task_always_eager
task_annotations
task_compression
task_create_missing_queues
task_default_delivery_mode
task_default_exchange
task_default_exchange_type
task_default_priority
task_default_queue
task_default_rate_limit
task_default_routing_key
task_eager_propagates
task_ignore_result
task_inherit_parent_priority
task_protocol
task_publish_retry
task_publish_retry_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_eager_result
task_store_errors_even_if_ignored
task_time_limit
task_track_started
timezone
worker_autoscaler
worker_cancel_long_running_tasks_on_connection_loss
worker_concurrency
worker_consumer
worker_deduplicate_successful_tasks
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_proc_alive_timeout
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)
(in module celery.contrib.sphinx)
setup_app_for_worker() (in module celery.contrib.testing.worker)
setup_default_app() (in module celery.contrib.testing.app)
setup_defaults() (celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
setup_handlers() (celery.app.log.Logging method)
setup_includes() (celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
setup_instance() (celery.worker.WorkController method)
(celery.worker.worker.WorkController 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)
(celery.worker.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)
should_sync() (celery.beat.Scheduler method)
should_use_eventloop() (celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
show() (celery.bin.multi.MultiTool method)
shrink() (celery.concurrency.eventlet.TaskPool method)
(celery.concurrency.gevent.TaskPool method)
shutdown
control
shutdown() (celery.app.control.Control method)
(celery.bootsteps.ConsumerStep method)
(celery.worker.consumer.Connection method)
(celery.worker.consumer.connection.Connection method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.Consumer.Blueprint method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer.Blueprint method)
(celery.worker.consumer.Events method)
(celery.worker.consumer.events.Events method)
(celery.worker.consumer.Heart method)
(celery.worker.consumer.heart.Heart method)
(celery.worker.consumer.Tasks 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_internal_error
task_postrun
task_prerun
task_received
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
worker_shutting_down
Signal (class in celery.utils.dispatch)
(class in celery.utils.dispatch.signal)
signal_consumer_close() (celery.worker.WorkController method)
(celery.worker.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)
(celery.concurrency.thread.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)
SOURCE
celery-migrate command line option
starmap() (celery.app.task.Task method)
start() (celery.apps.beat.Beat.Service method)
(celery.apps.multi.Cluster method)
(celery.apps.multi.Node method)
(celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.asynchronous.Drainer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.RPCBackend.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.components.Hub method)
(celery.worker.consumer.Connection method)
(celery.worker.consumer.connection.Connection method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.consumer.consumer.Evloop method)
(celery.worker.consumer.Events method)
(celery.worker.consumer.events.Events method)
(celery.worker.consumer.Gossip method)
(celery.worker.consumer.gossip.Gossip method)
(celery.worker.consumer.Heart method)
(celery.worker.consumer.heart.Heart method)
(celery.worker.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle method)
(celery.worker.consumer.Tasks method)
(celery.worker.consumer.tasks.Tasks method)
(celery.worker.heartbeat.Heart method)
(celery.worker.pidbox.gPidbox method)
(celery.worker.pidbox.Pidbox method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
start_filter() (in module celery.contrib.migrate)
start_node() (celery.apps.multi.Cluster method)
start_scheduler() (celery.apps.beat.Beat method)
start_worker() (in module celery.contrib.testing.worker)
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.events.Events attribute)
state (celery.app.trace.TraceInfo attribute)
(celery.bootsteps.Blueprint attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
State (class in celery.contrib.migrate)
(class in celery.events.state)
state (class in celery.states)
state() (celery.result.AsyncResult property)
(celery.result.EagerResult property)
(celery.worker.WorkController property)
(celery.worker.worker.WorkController property)
State.Task (class in celery.events.state)
State.Worker (class in celery.events.state)
state_cls (celery.app.events.Events attribute)
state_to_name (celery.bootsteps.Blueprint attribute)
statedb
StateDB (class in celery.worker.components)
stats() (celery.app.control.Inspect method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
status (celery.backends.database.models.Task attribute)
(celery.backends.database.models.TaskExtended attribute)
status() (celery.result.AsyncResult property)
(celery.result.EagerResult property)
status_string() (celery.events.state.State.Worker property)
(celery.events.state.Worker property)
Step (class in celery.bootsteps)
steps (celery.Celery attribute)
stop() (celery.apps.beat.Beat.Service method)
(celery.apps.multi.Cluster method)
(celery.backends.asynchronous.BaseResultConsumer method)
(celery.backends.asynchronous.Drainer method)
(celery.backends.redis.RedisBackend.ResultConsumer method)
(celery.backends.rpc.RPCBackend.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.components.Hub method)
(celery.worker.consumer.Consumer method)
(celery.worker.consumer.consumer.Consumer method)
(celery.worker.consumer.Events method)
(celery.worker.consumer.events.Events method)
(celery.worker.consumer.Heart method)
(celery.worker.consumer.heart.Heart method)
(celery.worker.consumer.Tasks method)
(celery.worker.consumer.tasks.Tasks method)
(celery.worker.heartbeat.Heart method)
(celery.worker.pidbox.Pidbox method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController 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_errors() (celery.worker.request.Request property)
store_errors_even_if_ignored (celery.app.task.Task attribute)
(Task attribute)
store_result() (celery.backends.base.DisabledBackend method)
(celery.backends.rpc.RPCBackend method)
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 property)
style() (celery.bin.base.CLIContext method)
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 property)
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_autoexpire (celery.backends.cache.CacheBackend attribute)
(celery.backends.cassandra.CassandraBackend attribute)
(celery.backends.consul.ConsulBackend attribute)
(celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.dynamodb.DynamoDBBackend attribute)
(celery.backends.mongodb.MongoBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.backends.rpc.RPCBackend attribute)
supports_color() (celery.app.log.Logging method)
supports_native_join (celery.backends.cache.CacheBackend attribute)
(celery.backends.redis.RedisBackend attribute)
(celery.backends.rpc.RPCBackend attribute)
supports_native_join() (celery.result.AsyncResult property)
(celery.result.EagerResult property)
(celery.result.ResultSet property)
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() (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.consumer.Mingle method)
(celery.worker.consumer.mingle.Mingle 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)
table_name (celery.backends.dynamodb.DynamoDBBackend attribute)
TAIL (celery.utils.graph.DOT attribute)
tail() (celery.utils.graph.GraphFormatter method)
take() (celery.utils.collections.BufferMap method)
(celery.utils.collections.Messagebuffer method)
Task (celery.Celery attribute)
(class in celery.app.task)
(class in celery.backends.database.models)
(class in celery.events.state)
task() (celery.Celery method)
(celery.utils.abstract.CallableSignature property)
(celery.worker.request.Request property)
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_acks_on_failure_or_timeout
setting
task_always_eager
setting
task_annotations
setting
task_buckets
task_cls (celery.backends.database.DatabaseBackend attribute)
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() (celery.app.utils.Settings property)
task_default_exchange_type
setting
task_default_priority
setting
task_default_queue
setting
task_default_rate_limit
setting
task_default_routing_key
setting
task_default_routing_key() (celery.app.utils.Settings property)
task_eager_propagates
setting
task_event() (celery.events.state.State method)
task_failure
signal
TASK_ID
celery-result command line option
task_id (celery.backends.database.models.Task attribute)
(celery.backends.database.models.TaskExtended attribute)
task_id() (celery.result.AsyncResult property)
(celery.worker.request.Request property)
task_id_eq() (in module celery.contrib.migrate)
task_id_in() (in module celery.contrib.migrate)
task_ignore_result
setting
task_inherit_parent_priority
setting
task_internal_error
signal
task_join_will_block (celery.concurrency.base.BasePool attribute)
(celery.concurrency.eventlet.TaskPool attribute)
(celery.concurrency.gevent.TaskPool attribute)
task_message_from_sig() (in module celery.contrib.testing.mocks)
task_name() (celery.worker.request.Request property)
task_postrun
signal
task_prerun
signal
task_protocol
setting
task_publish_retry
setting
task_publish_retry_policy
setting
task_queue_max_priority
setting
task_queues
setting
task_ready() (in module celery.worker.state)
task_received
signal
task_reject_on_worker_lost
setting
task_rejected
signal
task_remote_tracebacks
setting
task_reserved() (in module celery.worker.state)
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_eager_result
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
TaskDirective (class in celery.contrib.sphinx)
TaskDocumenter (class in celery.contrib.sphinx)
TaskError
TaskExtended (class in celery.backends.database.models)
TaskFormatter (class in celery.app.log)
tasklist() (celery.apps.worker.Worker method)
TaskMessage() (in module celery.contrib.testing.mocks)
TaskMessage1() (in module celery.contrib.testing.mocks)
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)
(class in celery.concurrency.thread)
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)
Tasks (class in celery.worker.consumer)
(class in celery.worker.consumer.tasks)
tasks() (celery.events.cursesmon.CursesMonitor property)
tasks_by_time() (celery.events.state.State method)
tasks_by_timestamp() (celery.events.state.State method)
TaskSet (class in celery.backends.database.models)
taskset_cls (celery.backends.database.DatabaseBackend attribute)
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.app.control.Control method)
(celery.bootsteps.StartStopStep method)
(celery.concurrency.base.BasePool method)
(celery.worker.components.Hub method)
(celery.worker.components.Pool method)
(celery.worker.request.Request method)
(celery.worker.WorkController method)
(celery.worker.worker.WorkController method)
terminate_job() (celery.concurrency.base.BasePool method)
(celery.concurrency.eventlet.TaskPool method)
Terminated
TestApp() (in module celery.contrib.testing.app)
TestWorkController (class in celery.contrib.testing.worker)
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)
time_to_live_seconds (celery.backends.dynamodb.DynamoDBBackend 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.Celery attribute)
timezone() (celery.app.utils.Settings property)
to_dict() (celery.backends.database.models.Task method)
(celery.backends.database.models.TaskExtended method)
(celery.backends.database.models.TaskSet method)
to_dot() (celery.utils.graph.DependencyGraph 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 property)
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.backends.database.models.TaskExtended attribute)
(celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
traceback() (celery.result.AsyncResult property)
(celery.result.EagerResult property)
TraceInfo (class in celery.app.trace)
track_started (celery.app.task.Task attribute)
(Task attribute)
trail (celery.app.task.Task attribute)
TRANSIENT_DELIVERY_MODE (celery.backends.rpc.RPCBackend.Exchange attribute)
Trap (class in celery.contrib.testing.app)
tref (celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
true_or_raise() (celery.contrib.testing.manager.ManagerMixin method)
truncate() (in module celery.utils.text)
TYPE
celery-amqp-exchange.declare command line option
type (celery.app.control.Control.Mailbox attribute)
(celery.backends.rpc.RPCBackend.Exchange attribute)
,
[1]
type() (celery.utils.abstract.CallableSignature property)
(celery.worker.request.Request property)
typemap (celery.app.defaults.Option attribute)
typing (celery.app.task.Task attribute)
tzlocal() (celery.worker.request.Request property)
tzname() (celery.utils.time.LocalTimezone method)
U
unbind_from() (celery.backends.rpc.RPCBackend.Exchange method)
underline() (celery.utils.term.colored method)
uniq() (in module celery.utils.functional)
UnitLogging (class in celery.contrib.testing.app)
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)
(celery.worker.autoscale.Autoscaler 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)
use_celery_app_trap() (in module celery.contrib.pytest)
USE_FAST_LOCALS
user (celery.backends.mongodb.MongoBackend attribute)
user_options (celery.Celery attribute)
user_preload_options
signal
username (celery.backends.arangodb.ArangoDbBackend attribute)
(celery.backends.couchbase.CouchbaseBackend attribute)
(celery.backends.couchdb.CouchBackend attribute)
(celery.backends.elasticsearch.ElasticsearchBackend attribute)
uses_semaphore (celery.concurrency.base.BasePool attribute)
(celery.concurrency.prefork.TaskPool attribute)
utc() (celery.worker.request.Request property)
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.backends.arangodb.ArangoDbBackend attribute)
verify() (celery.security.certificate.Certificate method)
W
wait() (celery.result.AsyncResult method)
(celery.result.EagerResult method)
wait_for() (celery.backends.asynchronous.Drainer method)
(celery.backends.base.DisabledBackend method)
(celery.contrib.testing.manager.ManagerMixin method)
wait_for_pending() (celery.backends.asynchronous.AsyncBackendMixin method)
waiting() (celery.result.ResultSet method)
wakeup_workers() (celery.events.EventReceiver method)
(celery.events.receiver.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)
without_defaults() (celery.app.utils.Settings method)
WorkController (celery.Celery attribute)
(class in celery.worker)
(class in celery.worker.worker)
WorkController.Blueprint (class in celery.worker)
(class in celery.worker.worker)
worker (celery.backends.database.models.TaskExtended attribute)
Worker (celery.Celery attribute)
worker (celery.events.state.State.Task attribute)
(celery.events.state.Task attribute)
Worker (class in celery.apps.worker)
(class in celery.events.state)
worker() (celery.result.AsyncResult property)
worker-heartbeat
event
worker-offline
event
worker-online
event
worker_autoscaler
setting
worker_cancel_long_running_tasks_on_connection_loss
setting
worker_concurrency
setting
worker_consumer
setting
worker_deduplicate_successful_tasks
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_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_proc_alive_timeout
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_shutting_down
signal
worker_state_db
setting
worker_task_log_format
setting
worker_timer
setting
worker_timer_precision
setting
WorkerComponent (class in celery.worker.autoscale)
WorkerLostError
workers() (celery.events.cursesmon.CursesMonitor property)
WorkerShutdown
WorkersPool (class in celery.bin.worker)
WorkerTerminate
write() (celery.utils.log.LoggingProxy method)
write_capacity_units (celery.backends.dynamodb.DynamoDBBackend attribute)
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)
Donations
Please help support this community project with a donation.
Quick search
Navigation
index
modules
|
Celery 5.2.7 documentation
»
Index