General 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 , [Link]
- celery-events command line option , [Link]
- celery-worker command line option , [Link]
- --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 , [Link]
- 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.concurrency.base.BasePool property)
- (celery.events.state.State.Worker attribute)
- (celery.events.state.Worker attribute)
- active() (celery.app.control.Inspect method)
- active_queues
- control
- active_queues() (celery.app.control.Inspect method)
- active_requests (in module celery.worker.state)
- add() (celery.app.amqp.Queues method)
- (celery.beat.Scheduler method)
- (celery.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.events.state.State.Worker property)
- (celery.events.state.Worker property)
- alive() (celery.apps.multi.Node method)
- (celery.bin.multi.MultiTool.MultiParser.Node method)
- alive_workers() (celery.events.state.State method)
- ALL_STATES
- state
- already_setup (celery.app.log.Logging attribute)
- AlreadyRegistered
- alt (celery.app.defaults.Option attribute)
- 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
- (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.result.ResultSet property)
- (celery.schedules.crontab attribute)
- (celery.utils.abstract.CallableSignature property)
- (celery.worker.request.Request property)
- (celery.worker.WorkController attribute)
- (celery.worker.worker.WorkController attribute)
- App (class in celery.bin.celery)
- 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.beat.ScheduleEntry attribute)
- (celery.concurrency.base.BasePool.Timer.Entry attribute)
- (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (celery.result.AsyncResult property)
- (celery.utils.abstract.CallableSignature property)
- (celery.utils.timer2.Entry attribute)
- (celery.utils.timer2.Timer.Entry attribute)
- (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.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)
- 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_container_name
- 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.app.task.Task property)
- (celery.Celery attribute)
- (celery.result.AsyncResult attribute)
- (celery.result.ResultSet property)
- (Task attribute)
- 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_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)
- binding() (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
- (celery.worker.WorkController attribute)
- (celery.worker.worker.WorkController attribute)
- Blueprint (class in celery.bootsteps)
- body (celery.worker.request.Request property)
- body() (celery.utils.threads.bgThread method)
- (celery.worker.autoscale.Autoscaler method)
- 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
- C_FORCE_ROOT
- 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.Exchange property)
- (celery.backends.rpc.RPCBackend.Queue attribute)
- 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> , [Link]
- --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> , [Link]
- --umask <umask>
- -c
- -d , [Link]
- -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> , [Link]
- --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.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.amqp
- 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.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_BENCH
- CELERY_BROKER_URL
- CELERY_CHDIR
- CELERY_CONFIG_MODULE
- CELERY_CREATE_DIRS
- CELERY_LOADER
- CELERY_RDB_HOST
- CELERY_RDB_PORT
- CELERY_RDBSIG
- CELERY_SU
- CELERY_TRACE_APP
- 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.Producer property)
- (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer attribute)
- 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.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.consul.ConsulBackend attribute)
- (celery.backends.dynamodb.DynamoDBBackend property)
- (celery.backends.redis.RedisBackend attribute)
- (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- clock (celery.events.state.State.Task attribute)
- (celery.events.state.State.Worker attribute)
- (celery.events.state.Task attribute)
- (celery.events.state.Worker attribute)
- clock() (celery.app.control.Inspect method)
- clone() (celery.utils.abstract.CallableSignature method)
- CLOSE (celery.concurrency.base.BasePool attribute)
- close() (celery.backends.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.loaders.base.BaseLoader property)
- conf() (celery.app.control.Inspect method)
- config_from_envvar() (celery.Celery method)
- config_from_object() (celery.Celery method)
- (celery.loaders.base.BaseLoader method)
- ConfigurationView (class in celery.utils.collections)
- configured (celery.loaders.base.BaseLoader attribute)
- 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.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.beat.Scheduler attribute)
- (celery.events.EventReceiver property)
- (celery.events.receiver.EventReceiver property)
- Connection (class in celery.worker.consumer)
- (class in celery.worker.consumer.connection)
- connection() (celery.Celery method)
- 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)
- consume_from() (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)
- 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.Json 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_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.apps.multi.Cluster property)
- (celery.worker.control.Panel attribute)
- 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
- date_done (celery.result.AsyncResult property)
- day_of_month (celery.schedules.crontab attribute)
- day_of_week (celery.schedules.crontab attribute)
- db (celery.backends.arangodb.ArangoDbBackend property)
- (celery.worker.state.Persistent attribute)
- 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)
- DELIVERY_TAG
- celery-amqp-basic.ack command line option
- delta_resolution() (in module celery.utils.time)
- DependencyGraph (class in celery.utils.graph)
- 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
- 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)
- 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 , [Link], [Link], [Link], [Link]
- C_FORCE_ROOT , [Link]
- C_IMPDEBUG
- CELERY_BENCH
- CELERY_BROKER_URL
- CELERY_CHDIR
- CELERY_CONFIG_MODULE , [Link], [Link]
- CELERY_CREATE_DIRS
- CELERY_LOADER , [Link], [Link], [Link], [Link], [Link]
- CELERY_RDB_HOST , [Link]
- CELERY_RDB_PORT , [Link]
- CELERY_RDBSIG
- CELERY_SU
- CELERY_TRACE_APP , [Link], [Link]
- CELERYCTL
- CELERYD_SU_ARGS
- DJANGO_SETTINGS_MODULE , [Link], [Link], [Link], [Link]
- MP_LOG , [Link]
- 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)
- (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)
- (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)
- 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_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)
- heartbeat_expires() (in module celery.events.state)
- heartbeat_max (celery.events.state.State.Worker attribute)
- (celery.events.state.Worker attribute)
- heartbeat_sent
- signal
- heartbeats (celery.events.state.State.Worker attribute)
- (celery.events.state.Worker attribute)
- hello() (celery.app.control.Inspect method)
- help (celery.events.cursesmon.CursesMonitor attribute)
- help() (celery.bin.multi.MultiTool method)
- help_title (celery.events.cursesmon.CursesMonitor attribute)
- 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
- (celery.events.state.State.Worker attribute)
- (celery.events.state.Worker attribute)
- (celery.worker.request.Request property)
- Hostname (class in celery.bin.worker)
- hour (celery.schedules.crontab attribute)
- http_protocol (celery.backends.arangodb.ArangoDbBackend attribute)
- hub
- 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.events.state.State.Task property)
- (celery.events.state.State.Worker property)
- (celery.events.state.Task property)
- (celery.events.state.Worker property)
- (celery.result.AsyncResult attribute)
- (celery.result.GroupResult attribute)
- (celery.utils.abstract.CallableSignature property)
- (celery.worker.request.Request attribute)
- 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)
- (celery.worker.request.Request property)
- (Task attribute)
- 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.concurrency.base.BasePool property)
- (celery.result.AsyncResult property)
- info() (celery.bootsteps.Blueprint method)
- (celery.bootsteps.Step method)
- (celery.events.state.State.Task method)
- (celery.events.state.Task method)
- (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)
- Json (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.beat.ScheduleEntry attribute)
- (celery.concurrency.base.BasePool.Timer.Entry attribute)
- (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (celery.result.AsyncResult property)
- (celery.utils.abstract.CallableSignature property)
- (celery.utils.timer2.Entry attribute)
- (celery.utils.timer2.Timer.Entry attribute)
- (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) , [Link]
- 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)
- (celery.worker.request.Request property)
- Message() (celery.backends.rpc.RPCBackend.Exchange method)
- 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.dynamodb
- celery.backends.elasticsearch
- celery.backends.filesystem
- celery.backends.mongodb
- celery.backends.redis
- celery.backends.rpc
- celery.backends.s3
- celery.beat
- celery.bin.amqp
- 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.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
- 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.rpc.RPCBackend.Exchange attribute) , [Link]
- (celery.beat.ScheduleEntry attribute)
- (celery.bin.base.CommaSeparatedList attribute)
- (celery.bin.base.ISO8601DateTime attribute)
- (celery.bin.base.ISO8601DateTimeOrFloat attribute)
- (celery.bin.base.Json 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.result.AsyncResult property)
- (celery.utils.abstract.CallableSignature property)
- (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)
- 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)
- 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.app.control.Control.Mailbox attribute)
- (celery.backends.rpc.RPCBackend attribute)
- (celery.Celery attribute)
- 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)
- (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 (celery.loaders.base.BaseLoader attribute)
P
- padlist() (in module celery.utils.functional)
- Panel (class in celery.worker.control)
- parent (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (celery.result.ResultBase attribute)
- parent_id (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (celery.worker.request.Request 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.apps.multi.Node property)
- (celery.bin.multi.MultiTool.MultiParser.Node property)
- (celery.events.state.State.Worker attribute)
- (celery.events.state.Worker attribute)
- pidbox
- Pidbox (class in celery.worker.pidbox)
- pidfile (celery.apps.multi.Node attribute)
- (celery.bin.multi.MultiTool.MultiParser.Node attribute)
- Pidfile (class in celery.platforms)
- pidlock (celery.worker.WorkController attribute)
- (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
- (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)
- 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)
- Python Enhancement Proposals
- PEP 8
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.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)
- (celery.backends.rpc.RPCBackend.ResultConsumer.Consumer property)
- Queues (class in celery.app.amqp)
- Queues() (celery.app.amqp.AMQP method)
- quiet (celery.backends.couchbase.CouchbaseBackend attribute)
R
- rate() (in module celery.utils.time)
- rate_limit
- control
- rate_limit (celery.app.task.Task attribute)
- (Task attribute)
- rate_limit() (celery.app.control.Control method)
- Rdb (class in celery.contrib.rdb)
- read_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)
- ready() (celery.result.AsyncResult method)
- (celery.result.EagerResult method)
- (celery.result.ResultSet method)
- READY_STATES
- state
- rebuild_taskheap() (celery.events.state.State method)
- receive() (celery.backends.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)
- 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)
- request (celery.app.task.Task property)
- Request (class in celery.worker.request)
- request (Task attribute)
- 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.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (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)
- ResultSet (class in celery.result)
- retried (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- retries (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (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)
- (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.PersistentScheduler property)
- (celery.beat.ScheduleEntry attribute)
- (celery.beat.Scheduler property)
- Schedule (celery.concurrency.base.BasePool.Timer attribute)
- (celery.utils.timer2.Timer attribute)
- schedule (class in celery.schedules)
- Schedule (in module celery.utils.timer2)
- scheduled() (celery.app.control.Inspect method)
- ScheduleEntry (class in celery.beat)
- scheduler (celery.apps.beat.Beat.Service attribute)
- (celery.beat.Service attribute)
- Scheduler (class in celery.beat)
- scheduler_cls (celery.apps.beat.Beat.Service attribute)
- (celery.beat.Service attribute)
- 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)
- 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_container_name
- 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
- 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)
- (celery.result.AsyncResult property)
- (celery.result.EagerResult property)
- (celery.worker.WorkController property)
- (celery.worker.worker.WorkController property)
- State (class in celery.contrib.migrate)
- (class in celery.events.state)
- state (class in celery.states)
- State.Task (class in celery.events.state)
- State.Worker (class in celery.events.state)
- state_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.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)
- 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)
- (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)
- task (celery.utils.abstract.CallableSignature property)
- (celery.worker.request.Request property)
- Task (class in celery.app.task)
- (class in celery.events.state)
- task() (celery.Celery method)
- task-failed
- event
- task-received
- event
- task-rejected
- event
- task-retried
- event
- task-revoked
- event
- task-sent
- event
- task-started
- event
- task-succeeded
- event
- Task.MaxRetriesExceededError
- Task.OperationalError
- task_accepted() (in module celery.worker.state)
- task_acks_late
- setting
- task_acks_on_failure_or_timeout
- setting
- task_always_eager
- setting
- task_annotations
- setting
- task_buckets
- task_compression
- setting
- task_consumer
- task_count (celery.events.state.State attribute)
- task_create_missing_queues
- setting
- task_default_delivery_mode
- setting
- task_default_exchange
- setting
- task_default_exchange (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.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
- 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)
- (celery.events.cursesmon.CursesMonitor property)
- Tasks (class in celery.worker.consumer)
- (class in celery.worker.consumer.tasks)
- tasks_by_time() (celery.events.state.State method)
- tasks_by_timestamp() (celery.events.state.State method)
- 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)
- 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
- (celery.events.snapshot.Polaroid attribute)
- (celery.worker.consumer.Consumer attribute)
- (celery.worker.consumer.consumer.Consumer attribute)
- Timer (class in celery.utils.timer2)
- (class in celery.worker.components)
- Timer.Entry (class in celery.utils.timer2)
- timestamp (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- timezone
- setting
- timezone (celery.app.utils.Settings property)
- (celery.Celery attribute)
- 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.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (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) , [Link]
- (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_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.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.Celery attribute)
- worker (celery.events.state.State.Task attribute)
- (celery.events.state.Task attribute)
- (celery.result.AsyncResult property)
- Worker (class in celery.apps.worker)
- (class in celery.events.state)
- 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)