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

--maxtasksperchild
celeryd command line option
--purge, --discard
celeryd command line option
--scheduler
celeryd command line option
--soft-time-limit
celeryd command line option
--time-limit
celeryd command line option
-B, --beat
celeryd command line option
-c, --concurrency
celeryd command line option
-E, --events
celeryd command line option
-f, --logfile
celerybeat command line option
celeryd command line option
-I, --include
celeryd command line option
-l, --loglevel
celerybeat command line option
celeryd command line option
-n, --hostname
celeryd command line option
-Q, --queues
celeryd command line option
-s, --schedule
celerybeat command line option
celeryd command line option
-S, --scheduler
celerybeat command line option

_

_all_instances (celery.utils.dispatch.saferef.BoundMethodWeakref attribute)

A

abbr() (in module celery.utils)
abbreviations() (in module celery.bin.celeryd_multi)
abbrtask() (in module celery.utils)
abcast() (celery.task.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.BaseTask attribute)
(Task attribute)
accept_magic_kwargs (celery.app.task.BaseTask attribute)
(celery.task.chords.Chord attribute)
(celery.task.chords.chord.Chord attribute)
acknowledge() (celery.worker.job.TaskRequest method)
acknowledged (celery.worker.job.TaskRequest attribute)
acks_late (celery.app.task.BaseTask attribute)
(Task attribute)
acquire() (celery.platforms.PIDFile method)
active (celery.concurrency.base.BasePool attribute)
active() (celery.task.control.Inspect method)
active_queues() (celery.task.control.Inspect method)
active_requests (in module celery.worker.state)
add() (celery.app.amqp.Queues method)
(celery.beat.Scheduler method)
(celery.datastructures.LimitedSet method)
(celery.result.ResultSet method)
add_bucket_for_type() (celery.worker.buckets.TaskBucket method)
add_consumer() (celery.task.control.Inspect method)
add_option() (celery.bin.celeryd_multi.NamespacedOptionParser method)
add_queue() (celery.backends.amqp.AMQPBackend.Consumer method)
ADMINS
setting
after_return()
(celery.app.task.BaseTask method)
(celery.task.base.BaseTask method)
after_setup_logger
signal
after_setup_task_logger
signal
alert() (celery.events.cursesmon.CursesMonitor method)
alert_remote_control_reply() (celery.events.cursesmon.CursesMonitor method)
alias (celery.backends.amqp.AMQPBackend.Queue attribute)
alive (celery.events.state.Worker attribute)
alive_workers() (celery.events.state.State method)
ALL_STATES
state
AlreadyRegistered
amqp (celery.app.App attribute)
(celery.bin.camqadm.AMQShell attribute), [1]
AMQP (class in celery.app.amqp)
AMQPAdmin (class in celery.bin.camqadm)
AMQPAdminCommand (class in celery.bin.camqadm)
AMQPBackend (class in celery.backends.amqp)
AMQPBackend.BacklogLimitExceeded
AMQPBackend.Consumer (class in celery.backends.amqp)
AMQPBackend.Exchange (class in celery.backends.amqp)
AMQPBackend.Producer (class in celery.backends.amqp)
AMQPBackend.Queue (class in celery.backends.amqp)
AMQShell (class in celery.bin.camqadm)
app (celery.app.task.BaseTask attribute)
App (class in celery.app)
app_or_default() (in module celery.app)
AppLoader (class in celery.loaders.app)
apply (class in celery.bin.celeryctl)
apply() (celery.app.task.BaseTask class method)
(celery.concurrency.processes.TaskPool.Pool method)
(celery.concurrency.processes.pool.Pool method)
(celery.task.base.BaseTask class method)
(celery.task.sets.TaskSet method)
(celery.task.sets.subtask method)
apply_after() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
apply_async() (celery.app.task.BaseTask class method)
(celery.beat.Scheduler method)
(celery.concurrency.base.BasePool method)
(celery.concurrency.processes.TaskPool.Pool method)
(celery.concurrency.processes.pool.Pool method)
(celery.task.base.BaseTask class method)
(celery.task.sets.TaskSet method)
(celery.task.sets.subtask method)
apply_at() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
apply_buffer() (celery.contrib.batches.Batches method)
apply_entry() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
apply_eta_task() (celery.worker.consumer.Consumer method)
apply_interval() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
apply_target() (in module celery.concurrency.base)
(in module celery.concurrency.evlet)
args (celery.beat.ScheduleEntry attribute)
(celery.bin.base.Command attribute)
(celery.bin.celeryctl.Command attribute)
(celery.bin.celeryctl.apply attribute)
(celery.bin.celeryctl.list_ attribute)
(celery.bin.celeryctl.result attribute)
(celery.contrib.batches.SimpleRequest attribute)
(celery.worker.job.TaskRequest attribute)
arguments (celery.backends.amqp.AMQPBackend.Exchange attribute)
as_dict() (celery.datastructures.LimitedSet method)
AsyncResult (class in celery.result)
AsyncResult() (celery.app.App method)
(celery.app.task.BaseTask class method)
(celery.contrib.abortable.AbortableTask class method)
(celery.task.base.BaseTask class method)
AttributeDict (class in celery.datastructures)
AttributeDictMixin (class in celery.datastructures)
attrs (celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.amqp.AMQPBackend.Queue attribute)
authkey (celery.concurrency.processes.pool.Pool.Process attribute)
(celery.concurrency.processes.TaskPool.Pool.Process attribute)
auto_declare (celery.app.amqp.TaskPublisher attribute)
(celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
auto_delete (celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.amqp.AMQPBackend.Queue attribute), [1]
autoregister (celery.app.task.BaseTask attribute)
Autoscaler (class in celery.worker.autoscale)

B

backend (celery.app.App attribute)
(Task attribute)
(celery.app.task.BaseTask attribute)
(celery.result.AsyncResult attribute)
(celery.result.BaseAsyncResult attribute)
background (celery.events.cursesmon.CursesMonitor attribute)
BacklogLimitExceeded
BaseAsyncResult (class in celery.result)
BaseAsyncResult.TimeoutError
BaseBackend (class in celery.backends.base)
BaseBackend.TimeoutError
BaseDictBackend (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)
BasePool.Timer.Schedule (class in celery.concurrency.base)
BaseTask (class in celery.app.task)
(class in celery.task.base)
BaseTask.MaxRetriesExceededError, [1]
Batches (class in celery.contrib.batches)
Beat (class in celery.apps.beat)
Beat() (celery.app.App method)
Beat.Service (class in celery.apps.beat)
beat_embedded_init
signal
beat_init
signal
BeatCommand (class in celery.bin.celerybeat)
bind() (queue method)
binding_arguments (celery.backends.amqp.AMQPBackend.Queue attribute)
black() (celery.utils.term.colored method)
blink() (celery.utils.term.colored method)
blue() (celery.utils.term.colored method)
body() (celery.concurrency.processes.pool.Pool.ResultHandler method)
(celery.concurrency.processes.TaskPool.Pool.ResultHandler method)
(celery.concurrency.processes.TaskPool.Pool.Supervisor method)
(celery.concurrency.processes.TaskPool.Pool.TaskHandler method)
(celery.concurrency.processes.TaskPool.Pool.TimeoutHandler method)
(celery.concurrency.processes.pool.Pool.Supervisor method)
(celery.concurrency.processes.pool.Pool.TaskHandler method)
(celery.concurrency.processes.pool.Pool.TimeoutHandler method)
bold() (celery.utils.term.colored method)
BoundMethodWeakref (class in celery.utils.dispatch.saferef)
BoundNonDescriptorMethodWeakref (class in celery.utils.dispatch.saferef)
bright() (celery.utils.term.colored method)
broadcast() (celery.task.control.Control method)
broadcast_consumer (celery.worker.consumer.Consumer attribute)
broker_connection() (celery.app.App method)
BROKER_CONNECTION_MAX_RETRIES
setting
BROKER_CONNECTION_RETRY
setting
BROKER_CONNECTION_TIMEOUT
setting
BROKER_HOST
setting
BROKER_PASSWORD
setting
BROKER_POOL_LIMIT
setting
BROKER_PORT
setting
BROKER_TRANSPORT
setting
BROKER_TRANSPORT_OPTIONS
setting
BROKER_USE_SSL
setting
BROKER_USER
setting
BROKER_VHOST
setting
BrokerConnection (celery.app.amqp.AMQP attribute)
builtin_modules (celery.loaders.base.BaseLoader attribute)
builtins (celery.bin.camqadm.AMQShell attribute)
Bunch (class in celery.backends.mongodb)

C

CacheBackend (class in celery.backends.cache)
calculate_key() (celery.utils.dispatch.saferef.BoundMethodWeakref class method)
call() (celery.task.control.Control.Mailbox method)
callback (celery.worker.mediator.Mediator attribute)
callbacks (celery.backends.amqp.AMQPBackend.Consumer attribute)
camqadm() (in module celery.bin.camqadm)
can_consume() (celery.datastructures.TokenBucket method)
cancel() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Queue method)
(celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.base.BasePool.Timer.Entry method)
(celery.concurrency.evlet.TaskPool.Timer method)
(celery.concurrency.evlet.Timer method)
(celery.events.snapshot.Polaroid method)
(celery.utils.timer2.Entry method)
(celery.utils.timer2.Timer method)
(celery.utils.timer2.Timer.Entry method)
cancel_by_queue() (celery.backends.amqp.AMQPBackend.Consumer method)
cancel_consumer()
(celery.task.control.Inspect method)
cancelled (celery.concurrency.base.BasePool.Timer.Entry attribute)
(celery.utils.timer2.Entry attribute)
(celery.utils.timer2.Timer.Entry attribute)
capacity (celery.datastructures.TokenBucket attribute)
capture() (celery.events.EventReceiver method)
(celery.events.snapshot.Polaroid method)
CassandraBackend (class in celery.backends.cassandra)
cast() (celery.task.control.Control.Mailbox method)
celery.app (module)
celery.app.amqp (module)
celery.app.defaults (module)
celery.app.task (module)
celery.apps.beat (module)
celery.apps.worker (module)
celery.backends (module)
celery.backends.amqp (module)
celery.backends.base (module)
celery.backends.cache (module)
celery.backends.cassandra (module)
celery.backends.database (module)
celery.backends.mongodb (module)
celery.backends.redis (module)
celery.backends.tyrant (module)
celery.beat (module)
celery.bin.base (module)
celery.bin.camqadm (module)
celery.bin.celerybeat (module)
celery.bin.celeryctl (module)
celery.bin.celeryd (module)
celery.bin.celeryd_multi (module)
celery.bin.celeryev (module)
celery.concurrency (module)
celery.concurrency.base (module)
celery.concurrency.evg (module)
celery.concurrency.evlet (module)
celery.concurrency.processes (module)
celery.concurrency.processes.pool (module)
celery.concurrency.solo (module)
celery.concurrency.threads (module)
celery.contrib.abortable (module)
celery.contrib.batches (module)
celery.contrib.rdb (module)
celery.datastructures (module)
celery.db.models (module)
celery.db.session (module)
celery.events (module)
celery.events.cursesmon (module)
celery.events.dumper (module)
celery.events.snapshot (module)
celery.events.state (module)
celery.exceptions (module)
celery.execute.trace (module)
celery.loaders (module)
celery.loaders.app (module)
celery.loaders.base (module)
celery.loaders.default (module)
celery.log (module)
celery.platforms (module)
celery.registry (module)
celery.result (module)
celery.routes (module)
celery.schedules (module)
celery.signals (module)
celery.states (module)
celery.task (module)
celery.task.base (module), [1]
celery.task.chords (module)
celery.task.control (module)
celery.task.http (module), [1]
celery.task.sets (module)
celery.utils (module)
celery.utils.compat (module)
celery.utils.dispatch (module)
celery.utils.dispatch.saferef (module)
celery.utils.dispatch.signal (module)
celery.utils.encoding (module)
celery.utils.mail (module)
celery.utils.patch (module)
celery.utils.serialization (module)
celery.utils.term (module)
celery.utils.timer2 (module)
celery.utils.timeutils (module)
celery.worker (module)
celery.worker.autoscale (module)
celery.worker.buckets (module)
celery.worker.consumer (module)
celery.worker.heartbeat (module)
celery.worker.job (module)
celery.worker.mediator (module)
celery.worker.state (module)
CELERY_ACKS_LATE
setting
CELERY_ALWAYS_EAGER
setting
CELERY_AMQP_TASK_RESULT_CONNECTION_MAX
setting
CELERY_AMQP_TASK_RESULT_EXPIRES
setting
CELERY_BROADCAST_EXCHANGE
setting
CELERY_BROADCAST_EXCHANGE_TYPE
setting
CELERY_BROADCAST_QUEUE
setting
CELERY_CACHE_BACKEND
setting
CELERY_CACHE_BACKEND_OPTIONS
setting
CELERY_CONFIG_MODULE, [1]
CELERY_CREATE_MISSING_QUEUES
setting
CELERY_DEFAULT_DELIVERY_MODE
setting
CELERY_DEFAULT_EXCHANGE
setting
CELERY_DEFAULT_EXCHANGE_TYPE
setting
CELERY_DEFAULT_QUEUE
setting
CELERY_DEFAULT_RATE_LIMIT
setting
CELERY_DEFAULT_ROUTING_KEY
setting
CELERY_DISABLE_RATE_LIMITS
setting
CELERY_EAGER_PROPAGATES_EXCEPTIONS
setting
CELERY_EVENT_SERIALIZER
setting
CELERY_IGNORE_RESULT
setting
CELERY_IMPORTS
setting
CELERY_LOADER, [1], [2], [3], [4], [5]
CELERY_MAX_CACHED_RESULTS
setting
CELERY_MESSAGE_COMPRESSION
setting
CELERY_MONGODB_BACKEND_SETTINGS
setting
CELERY_QUEUES
setting
CELERY_RDB_HOST
CELERY_RDB_PORT
CELERY_RDBSIG
CELERY_REDIRECT_STDOUTS
setting
CELERY_REDIRECT_STDOUTS_LEVEL
setting
CELERY_REDIS_DB
setting
CELERY_REDIS_HOST
setting
CELERY_REDIS_PASSWORD
setting
CELERY_REDIS_PORT
setting
CELERY_RESULT_BACKEND
setting
CELERY_RESULT_DBURI
setting
CELERY_RESULT_ENGINE_OPTIONS
setting
CELERY_RESULT_EXCHANGE
setting
CELERY_RESULT_EXCHANGE_TYPE
setting
CELERY_RESULT_PERSISTENT
setting
CELERY_RESULT_SERIALIZER
setting
CELERY_ROUTES
setting
CELERY_SEND_EVENTS
setting
CELERY_SEND_TASK_ERROR_EMAILS
setting
CELERY_SEND_TASK_SENT_EVENT
setting
CELERY_STORE_ERRORS_EVEN_IF_IGNORED
setting
CELERY_TASK_ERROR_WHITELIST
setting
CELERY_TASK_PUBLISH_RETRY
setting
CELERY_TASK_PUBLISH_RETRY_POLICY
setting
CELERY_TASK_RESULT_EXPIRES
setting
CELERY_TASK_SERIALIZER
setting
CELERY_TRACE_APP, [1]
CELERY_TRACK_STARTED
setting
celerybeat command line option
-S, --scheduler
-f, --logfile
-l, --loglevel
-s, --schedule
CELERYBEAT_LOG_FILE
setting
CELERYBEAT_LOG_LEVEL
setting
CELERYBEAT_MAX_LOOP_INTERVAL
setting
CELERYBEAT_SCHEDULE
setting
CELERYBEAT_SCHEDULE_FILENAME
setting
CELERYBEAT_SCHEDULER
setting
celeryctl (class in celery.bin.celeryctl)
celeryd command line option
--maxtasksperchild
--purge, --discard
--scheduler
--soft-time-limit
--time-limit
-B, --beat
-E, --events
-I, --include
-Q, --queues
-c, --concurrency
-f, --logfile
-l, --loglevel
-n, --hostname
-s, --schedule
CELERYD_AUTOSCALER
setting
CELERYD_CONCURRENCY
setting
CELERYD_CONSUMER
setting
CELERYD_ETA_SCHEDULER
setting
CELERYD_ETA_SCHEDULER_PRECISION
setting
CELERYD_HIJACK_ROOT_LOGGER
setting
CELERYD_LOG_COLOR
setting
CELERYD_LOG_FILE
setting
CELERYD_LOG_FORMAT
setting
CELERYD_LOG_LEVEL
setting
CELERYD_MAX_TASKS_PER_CHILD
setting
CELERYD_MEDIATOR
setting
CELERYD_POOL
setting
CELERYD_PREFETCH_MULTIPLIER
setting
CELERYD_STATE_DB
setting
CELERYD_TASK_LOG_FORMAT
setting
CELERYD_TASK_SOFT_TIME_LIMIT
setting
CELERYD_TASK_TIME_LIMIT
setting
CELERYMON_LOG_FILE
setting
CELERYMON_LOG_FORMAT
setting
CELERYMON_LOG_LEVEL
setting
chain_from_iterable() (in module celery.utils.compat)
(in module celery.worker.buckets)
chan (celery.bin.camqadm.AMQShell attribute)
changes (celery.datastructures.ConfigurationView attribute)
channel (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.amqp.AMQPBackend.Exchange attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.amqp.AMQPBackend.Queue attribute)
choices (celery.bin.celeryctl.inspect attribute)
chord (celery.worker.job.TaskRequest attribute)
Chord (class in celery.task.chords)
chord (class in celery.task.chords)
chord.Chord (class in celery.task.chords)
chronologically (celery.datastructures.LimitedSet attribute)
chunks() (in module celery.utils)
cleanup() (celery.backends.base.BaseBackend method)
(celery.backends.database.DatabaseBackend method)
(celery.backends.mongodb.MongoBackend method)
(celery.events.snapshot.Polaroid method)
cleanup_signal (celery.events.snapshot.Polaroid attribute)
clear() (celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.base.BasePool.Timer.Schedule method)
(celery.concurrency.evg.Schedule method)
(celery.concurrency.evg.TaskPool.Timer.Schedule method)
(celery.concurrency.evg.Timer.Schedule method)
(celery.concurrency.evlet.Schedule method)
(celery.concurrency.evlet.TaskPool.Timer.Schedule method)
(celery.concurrency.evlet.Timer.Schedule method)
(celery.datastructures.LimitedSet method)
(celery.events.state.State method)
(celery.result.ResultSet method)
(celery.utils.timer2.Schedule method)
(celery.utils.timer2.Timer method)
(celery.utils.timer2.Timer.Schedule method)
(celery.worker.buckets.FastQueue method)
(celery.worker.buckets.TaskBucket method)
(celery.worker.buckets.TokenBucketQueue method)
clear_after (celery.events.snapshot.Polaroid attribute)
clear_tasks() (celery.events.state.State method)
client (celery.backends.cache.CacheBackend attribute)
(celery.backends.redis.RedisBackend attribute)
CLOSE (celery.apps.worker.Worker.WorkController attribute)
(celery.concurrency.base.BasePool attribute)
(celery.worker.WorkController attribute)
close() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.tyrant.TyrantBackend method)
(celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
(celery.concurrency.processes.TaskPool.Pool method)
(celery.concurrency.processes.pool.Pool method)
(celery.events.EventDispatcher method)
(celery.log.LoggingProxy method)
(celery.platforms.DaemonContext method)
(celery.worker.state.Persistent method)
close_connection() (celery.worker.consumer.Consumer method)
closed (celery.log.LoggingProxy attribute)
cmdline_config_parser() (celery.loaders.base.BaseLoader method)
coerce() (celery.bin.camqadm.Spec method)
colored (class in celery.utils.term)
colored() (celery.log.Logging method)
ColorFormatter (class in celery.log)
colors (celery.log.ColorFormatter attribute)
COLORS (celery.log.ColorFormatter attribute)
column_family (celery.backends.cassandra.CassandraBackend attribute)
Command (class in celery.bin.base)
(class in celery.bin.celeryctl)
command() (in module celery.bin.celeryctl)
commands (celery.bin.celeryctl.celeryctl attribute)
completed_count() (celery.result.ResultSet method)
completenames() (celery.bin.camqadm.AMQShell method)
compression (celery.backends.amqp.AMQPBackend.Producer attribute)
concurrency (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
conf (celery.app.App attribute)
(celery.loaders.base.BaseLoader attribute)
config_from_cmdline() (celery.app.App method)
config_from_envvar() (celery.app.App method)
(celery.loaders.base.BaseLoader method)
config_from_object() (celery.app.App method)
(celery.loaders.base.BaseLoader method)
ConfigurationView (class in celery.datastructures)
configured (celery.loaders.base.BaseLoader attribute)
conn (celery.bin.camqadm.AMQShell attribute)
connect() (celery.bin.camqadm.AMQPAdmin method)
(celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
connection (celery.beat.Scheduler attribute)
(celery.task.control.Control.Mailbox attribute)
(celery.worker.consumer.Consumer attribute)
consume() (celery.backends.amqp.AMQPBackend method)
(celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Queue method)
consume_messages() (celery.worker.consumer.Consumer method)
consume_queue() (in module celery.datastructures)
Consumer (celery.app.amqp.AMQP attribute)
consumer (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
Consumer (class in celery.worker.consumer)
consumer() (celery.events.EventReceiver method)
ConsumerSet (celery.app.amqp.AMQP attribute)
consuming_from() (celery.backends.amqp.AMQPBackend.Consumer method)
control
disable_events
enable_events
ping
rate_limit
revoke
shutdown
control (celery.app.App attribute)
Control (class in celery.task.control)
Control.Mailbox (class in celery.task.control)
copy_buffer() (celery.events.EventDispatcher method)
counter (celery.bin.camqadm.AMQShell attribute)
cpu_count() (in module celery.apps.worker)
create_exception_cls() (in module celery.utils.serialization)
create_parser() (celery.bin.base.Command method)
(celery.bin.celeryctl.Command method)
create_pidlock() (in module celery.platforms)
create_session() (in module celery.db.session)
create_task_cls() (celery.app.App method)
crontab (class in celery.schedules)
crontab_parser (class in celery.schedules)
cry() (in module celery.utils)
current_loader() (in module celery.loaders)
CursesMonitor (class in celery.events.cursesmon)
cwd_in_path() (in module celery.utils)
cyan() (celery.utils.term.colored method)

D

daemon (celery.concurrency.processes.pool.Pool.Process attribute)
(celery.concurrency.processes.TaskPool.Pool.Process attribute)
daemon_options() (in module celery.bin.base)
DaemonContext (class in celery.platforms)
DatabaseBackend (class in celery.backends.database)
date_done (celery.db.models.Task attribute)
(celery.db.models.TaskSet attribute)
day_of_week (celery.schedules.crontab attribute)
db (celery.backends.redis.RedisBackend attribute)
(celery.worker.state.Persistent attribute)
debug() (celery.contrib.batches.Batches method)
debugger() (in module celery.contrib.rdb)
declare() (celery.app.amqp.TaskPublisher method)
(celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.amqp.AMQPBackend.Producer method)
(celery.backends.amqp.AMQPBackend.Queue method)
(queue method)
decrement() (celery.worker.consumer.QoS method)
decrement_eventually() (celery.worker.consumer.QoS method)
default (celery.platforms.Signals attribute)
default() (celery.bin.camqadm.AMQShell method)
default_dispatcher() (celery.events.Events method)
default_encode() (in module celery.worker.job)
default_encoding() (in module celery.utils.encoding)
default_retry_delay (celery.app.task.BaseTask attribute)
(Task attribute)
defaults (celery.datastructures.ConfigurationView attribute)
delay() (celery.app.task.BaseTask class method)
(celery.task.base.BaseTask class method)
(celery.task.sets.subtask method)
delay_task() (celery.app.amqp.TaskPublisher method)
delete() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.amqp.AMQPBackend.Queue method)
(celery.backends.base.KeyValueStoreBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.cache.DummyClient method)
(celery.backends.redis.RedisBackend method)
(celery.backends.tyrant.TyrantBackend method)
(celery.result.TaskSetResult method)
(exchange method)
(queue method)
delete_taskset() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
deletion_methods (celery.utils.dispatch.saferef.BoundMethodWeakref attribute)
delivery_info (celery.contrib.batches.SimpleRequest attribute)
(celery.worker.job.TaskRequest attribute)
delivery_mode (celery.app.task.BaseTask attribute)
(celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
delta_resolution() (in module celery.utils.timeutils)
deprecated() (in module celery.utils)
detached() (in module celery.platforms)
DictAttribute (class in celery.datastructures)
die() (celery.apps.worker.Worker method)
disable() (celery.events.EventDispatcher method)
disable_events
control
disable_events() (celery.task.control.Inspect method)
DisabledBackend (class in celery.backends.base)
discard() (celery.result.ResultSet method)
discard_all() (celery.task.control.Control method)
disconnect() (celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
dispatch() (celery.bin.camqadm.AMQShell method)
(celery.task.http.HttpDispatch method)
dispatcher (celery.task.http.URL attribute)
Dispatcher() (celery.events.Events method)
display_command_help() (celery.bin.camqadm.AMQShell method)
display_height (celery.events.cursesmon.CursesMonitor attribute)
display_task_row() (celery.events.cursesmon.CursesMonitor method)
display_width (celery.events.cursesmon.CursesMonitor attribute)
DisplayThread (class in celery.events.cursesmon)
do_exit() (celery.bin.camqadm.AMQShell method)
do_help() (celery.bin.camqadm.AMQShell method)
drain_events() (celery.backends.amqp.AMQPBackend method)
(celery.events.EventReceiver method)
draw() (celery.events.cursesmon.CursesMonitor method)
DummyClient (class in celery.backends.cache)
dump_message() (in module celery.bin.camqadm)
Dumper (class in celery.events.dumper)
durable (celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.amqp.AMQPBackend.Queue attribute), [1]

E

EagerResult (class in celery.result)
EagerResult.TimeoutError
either() (celery.app.App method)
Element (class in celery.events.state)
email_body (celery.worker.job.TaskRequest attribute)
EMAIL_HOST
setting
EMAIL_HOST_PASSWORD
setting
EMAIL_HOST_USER
setting
EMAIL_PORT
setting
email_subject (celery.worker.job.TaskRequest attribute)
EMAIL_TIMEOUT
setting
EMAIL_USE_SSL
setting
embed() (celery.utils.term.colored method)
embed_clockservice (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
EmbeddedService() (in module celery.beat)
empty() (celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.base.BasePool.Timer.Schedule method)
(celery.utils.timer2.Schedule method)
(celery.utils.timer2.Timer method)
(celery.utils.timer2.Timer.Schedule method)
(celery.worker.buckets.TaskBucket method)
(celery.worker.buckets.TokenBucketQueue method)
enable() (celery.events.EventDispatcher method)
enable_config_from_cmdline (celery.bin.base.Command attribute)
(celery.bin.celeryd.WorkerCommand attribute)
enable_events
control
enable_events() (celery.task.control.Inspect method)
encode_result() (celery.backends.base.BaseBackend method)
ensure_process_aware_logger() (in module celery.utils.patch)
ensure_started() (celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.evg.TaskPool.Timer method)
(celery.concurrency.evg.Timer method)
(celery.concurrency.evlet.TaskPool.Timer method)
(celery.concurrency.evlet.Timer method)
(celery.utils.timer2.Timer method)
enter() (celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.base.BasePool.Timer.Schedule method)
(celery.concurrency.evg.Schedule method)
(celery.concurrency.evg.TaskPool.Timer.Schedule method)
(celery.concurrency.evg.Timer.Schedule method)
(celery.concurrency.evlet.Schedule method)
(celery.concurrency.evlet.TaskPool.Timer.Schedule method)
(celery.concurrency.evlet.Timer.Schedule method)
(celery.utils.timer2.Schedule method)
(celery.utils.timer2.Timer method)
(celery.utils.timer2.Timer.Schedule 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
CELERY_CONFIG_MODULE, [1]
CELERY_LOADER, [1], [2], [3], [4], [5]
CELERY_RDBSIG
CELERY_RDB_HOST, [1]
CELERY_RDB_PORT, [1]
CELERY_TRACE_APP, [1]
NOSE_VERBOSE
PATH
Error
error() (celery.bin.celeryctl.Command method)
(celery.bin.celeryd_multi.MultiTool method)
error_envvar_not_set (celery.loaders.base.BaseLoader attribute)
error_msg (celery.worker.job.TaskRequest attribute)
error_whitelist (celery.app.task.BaseTask attribute)
(Task attribute)
establish_connection() (celery.app.task.BaseTask class method)
(celery.task.base.BaseTask class method)
eta (celery.worker.job.TaskRequest attribute)
eta_schedule (celery.worker.consumer.Consumer attribute)
evaluate() (celery.utils.mpromise method)
(celery.utils.promise method)
evaluated (celery.utils.mpromise attribute), [1]
evcam() (in module celery.events.snapshot)
EvCommand (class in celery.bin.celeryev)
evdump() (in module celery.events.dumper)
event() (celery.events.state.State method)
Event() (in module celery.events)
event_count (celery.events.state.State attribute)
event_dispatcher (celery.worker.consumer.Consumer attribute)
EventDispatcher (class in celery.events)
eventlet_pool_apply
signal
eventlet_pool_postshutdown
signal
eventlet_pool_preshutdown
signal
eventlet_pool_started
signal
EventReceiver (class in celery.events)
Events (class in celery.events)
evtop() (in module celery.events.cursesmon)
exc_args (celery.utils.serialization.UnpickleableExceptionWrapper attribute)
exc_cls_name (celery.utils.serialization.UnpickleableExceptionWrapper attribute)
exc_module (celery.utils.serialization.UnpickleableExceptionWrapper attribute)
exception (celery.datastructures.ExceptionInfo attribute)
EXCEPTION_STATES
state
EXCEPTION_STATES (celery.backends.base.BaseBackend attribute)
exception_to_python() (celery.backends.base.BaseBackend method)
ExceptionInfo (class in celery.datastructures)
exchange (celery.app.task.BaseTask attribute)
(Task attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.amqp.AMQPBackend.Queue attribute), [1]
(celery.task.control.Control.Mailbox attribute)
exchange_fmt (celery.task.control.Control.Mailbox attribute)
exchange_type (celery.app.task.BaseTask attribute)
exclusive (celery.backends.amqp.AMQPBackend.Queue attribute), [1]
execute() (celery.app.task.BaseTask method)
(celery.bin.celeryctl.celeryctl method)
(celery.contrib.batches.Batches method)
(celery.execute.trace.TaskTrace method)
(celery.task.base.BaseTask method)
(celery.worker.job.TaskRequest method)
(celery.worker.job.WorkerTaskTrace method)
execute_and_trace() (in module celery.worker.job)
execute_from_commandline() (celery.bin.base.Command method)
(celery.bin.celeryd_multi.MultiTool method)
execute_safe() (celery.worker.job.WorkerTaskTrace method)
execute_using_pool() (celery.worker.job.TaskRequest method)
exit_after() (celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
exitcode (celery.concurrency.processes.pool.Pool.Process attribute)
(celery.concurrency.processes.TaskPool.Pool.Process attribute)
expand() (celery.bin.celeryd_multi.MultiTool method)
expand_destination() (celery.routes.Router method)
expected_time() (celery.datastructures.TokenBucket method)
(celery.worker.buckets.FastQueue method)
(celery.worker.buckets.TokenBucketQueue method)
expires (celery.app.task.BaseTask attribute)
(celery.datastructures.LimitedSet attribute)
(celery.worker.job.TaskRequest attribute)
extend_with_default_kwargs() (celery.worker.job.TaskRequest method)
extra_info() (celery.apps.worker.Worker method)
extract_response() (in module celery.task.http)

F

failed() (celery.result.BaseAsyncResult method)
(celery.result.ResultSet method)
FAILURE
state
FastQueue (class in celery.worker.buckets)
fg() (in module celery.utils.term)
fileno() (celery.log.LoggingProxy method)
fill_rate (celery.datastructures.TokenBucket attribute)
filter_types() (celery.registry.TaskRegistry method)
find_module() (celery.loaders.default.Loader method)
(in module celery.utils)
find_nearest_pickleable_exception() (in module celery.utils.serialization)
find_position() (celery.events.cursesmon.CursesMonitor method)
findsig() (in module celery.bin.celeryd_multi)
first (celery.datastructures.LimitedSet attribute)
first() (in module celery.utils)
firstmethod() (in module celery.utils)
flatten_reply() (in module celery.task.control)
flow() (celery.backends.amqp.AMQPBackend.Consumer method)
flush() (celery.contrib.batches.Batches method)
(celery.events.EventDispatcher method)
(celery.log.LoggingProxy method)
flush_every (celery.contrib.batches.Batches attribute)
flush_interval (celery.contrib.batches.Batches attribute)
force_scale_down() (celery.worker.autoscale.Autoscaler method)
force_scale_up() (celery.worker.autoscale.Autoscaler method)
foreground (celery.events.cursesmon.CursesMonitor attribute)
forget() (celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
(celery.result.BaseAsyncResult method)
(celery.result.ResultSet method)
format() (celery.app.amqp.Queues method)
(celery.log.ColorFormatter method)
format_arg() (celery.bin.camqadm.Spec method)
format_declare_queue() (in module celery.bin.camqadm)
format_opt() (in module celery.bin.celeryd_multi)
format_response() (celery.bin.camqadm.Spec method)
format_row() (celery.events.cursesmon.CursesMonitor method)
format_signature() (celery.bin.camqadm.Spec method)
format_task_event() (celery.events.dumper.Dumper method)
formatException() (celery.log.ColorFormatter method)
freeze() (State method)
freeze_while() (celery.events.state.State method)
(State method)
from_exception() (celery.utils.serialization.UnpickleableExceptionWrapper class method)
from_message() (celery.worker.job.TaskRequest class method)
from_request() (celery.contrib.batches.SimpleRequest class method)
fun_takes_kwargs() (in module celery.utils)

G

get() (celery.backends.amqp.AMQPBackend.Queue method)
(celery.backends.base.KeyValueStoreBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.cache.DummyClient method)
(celery.backends.redis.RedisBackend method)
(celery.backends.tyrant.TyrantBackend method)
(celery.bin.celeryd_multi.MultiTool method)
(celery.datastructures.ConfigurationView method)
(celery.datastructures.DictAttribute method)
(celery.result.BaseAsyncResult method)
(celery.result.EagerResult method)
(celery.worker.buckets.TaskBucket method)
(celery.worker.buckets.TokenBucketQueue method)
get_amqp_api_command() (celery.bin.camqadm.AMQShell method)
get_async() (celery.task.http.URL method)
get_backend_cls() (in module celery.backends)
get_best_memcache() (in module celery.backends.cache)
get_bound_method_weakref() (in module celery.utils.dispatch.saferef)
get_bucket_for_type() (celery.worker.buckets.TaskBucket method)
get_cls_by_name() (celery.bin.base.Command method)
(in module celery.utils)
get_consumer() (celery.app.task.BaseTask class method)
(celery.task.base.BaseTask class method)
get_default_logger() (celery.log.Logging method)
get_default_queue() (celery.app.amqp.AMQP method)
get_engine() (in module celery.db.session)
get_fdmax() (in module celery.platforms)
get_full_cls_name() (in module celery.utils)
get_implementation() (in module celery.concurrency)
get_instance_attrs() (celery.worker.job.TaskRequest method)
get_key_for_task() (celery.backends.base.KeyValueStoreBackend method)
get_key_for_taskset() (celery.backends.base.KeyValueStoreBackend method)
get_loader_cls() (in module celery.loaders)
get_logger() (celery.app.task.BaseTask class method)
(celery.task.base.BaseTask class method)
get_many() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.KeyValueStoreBackend method)
get_multi() (celery.backends.cache.DummyClient method)
get_names() (celery.bin.camqadm.AMQShell method)
get_nowait() (celery.worker.buckets.TaskBucket method)
(celery.worker.buckets.TokenBucketQueue method)
get_options() (celery.bin.base.Command method)
(celery.bin.celerybeat.BeatCommand method)
(celery.bin.celeryd.WorkerCommand method)
(celery.bin.celeryev.EvCommand method)
get_or_create_task() (celery.events.state.State method)
get_or_create_worker() (celery.events.state.State method)
get_pickleable_exception() (in module celery.utils.serialization)
get_pickled_exception() (in module celery.utils.serialization)
get_process_name() (in module celery.apps.worker)
get_publisher() (celery.app.task.BaseTask class method)
(celery.task.base.BaseTask class method)
get_queue() (celery.task.control.Control.Mailbox method)
get_reply_queue() (celery.task.control.Control.Mailbox method)
get_result() (celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
(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_status() (celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
(celery.backends.base.DisabledBackend method)
get_symbol_by_name() (in module celery.utils)
get_task_consumer() (celery.app.amqp.AMQP method)
get_task_logger() (celery.log.Logging method)
get_task_meta() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.BaseDictBackend method)
get_taskset_meta() (celery.backends.base.BaseDictBackend method)
get_traceback() (celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
(celery.backends.base.DisabledBackend method)
getpids() (celery.bin.celeryd_multi.MultiTool method)
green() (celery.utils.term.colored method)
greet (celery.events.cursesmon.CursesMonitor attribute)
grow() (celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.TaskPool method)
(celery.concurrency.processes.TaskPool.Pool method)

H

handle_after_return() (celery.execute.trace.TaskTrace method)
handle_argv() (celery.bin.base.Command method)
(celery.bin.celeryctl.celeryctl method)
handle_error() (celery.concurrency.base.BasePool.Timer.Schedule method)
(celery.utils.timer2.Schedule method)
(celery.utils.timer2.Timer.Schedule method)
handle_failure() (celery.execute.trace.TaskTrace method)
(celery.worker.job.WorkerTaskTrace method)
handle_keypress() (celery.events.cursesmon.CursesMonitor method)
handle_retry() (celery.execute.trace.TaskTrace method)
(celery.worker.job.WorkerTaskTrace method)
handle_success() (celery.execute.trace.TaskTrace method)
(celery.worker.job.WorkerTaskTrace method)
handlers (celery.events.EventReceiver attribute)
heart (celery.worker.consumer.Consumer attribute)
Heart (class in celery.worker.heartbeat)
HEARTBEAT_EXPIRE (in module celery.events.state)
heartbeat_max (celery.events.state.Worker attribute)
help (celery.bin.celeryctl.Command attribute)
(celery.events.cursesmon.CursesMonitor attribute)
(class in celery.bin.celeryctl)
help() (celery.bin.celeryd_multi.MultiTool method)
help_title (celery.events.cursesmon.CursesMonitor attribute)
host (celery.backends.redis.RedisBackend attribute)
hostname (celery.contrib.batches.SimpleRequest attribute)
(celery.worker.consumer.Consumer attribute)
(celery.worker.job.WorkerTaskTrace attribute)
hour (celery.schedules.crontab attribute)
http_headers (celery.task.http.HttpDispatch attribute)
HttpDispatch (class in celery.task.http)
HttpDispatchTask (class in celery.task.http)
humanize_seconds() (in module celery.utils.timeutils)
humanize_type() (in module celery.events.dumper)

I

iblue() (celery.utils.term.colored method)
icyan() (celery.utils.term.colored method)
id (celery.contrib.batches.SimpleRequest attribute)
(celery.db.models.Task attribute)
(celery.db.models.TaskSet attribute)
ident (celery.concurrency.processes.pool.Pool.Process attribute)
(celery.concurrency.processes.TaskPool.Pool.Process attribute)
identchars (celery.bin.camqadm.AMQShell attribute)
ignore() (celery.platforms.Signals method)
ignore_result (celery.app.task.BaseTask attribute)
(Task attribute)
ignored (celery.platforms.Signals attribute)
igreen() (celery.utils.term.colored method)
imagenta() (celery.utils.term.colored method)
imap() (celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.TaskPool.Pool method)
imap_unordered() (celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.TaskPool.Pool method)
immediate (celery.app.task.BaseTask attribute)
(Task attribute)
import_best_memcache() (in module celery.backends.cache)
import_default_modules() (celery.loaders.base.BaseLoader method)
import_from_cwd() (celery.loaders.base.BaseLoader method)
(in module celery.utils)
import_module() (celery.loaders.base.BaseLoader method)
import_task_module() (celery.loaders.base.BaseLoader method)
ImproperlyConfigured
inc_counter (celery.bin.camqadm.AMQShell attribute)
increment() (celery.worker.consumer.QoS method)
indent() (in module celery.bin.celeryctl)
info (celery.beat.PersistentScheduler attribute)
(celery.beat.Scheduler attribute)
(celery.concurrency.base.BasePool attribute)
(celery.result.BaseAsyncResult attribute)
(celery.worker.consumer.Consumer attribute)
info() (celery.bin.celeryd_multi.MultiTool method)
(celery.concurrency.base.BasePool.Timer.Schedule method)
(celery.events.state.Task method)
(celery.utils.timer2.Schedule method)
(celery.utils.timer2.Timer.Schedule method)
(celery.worker.autoscale.Autoscaler method)
(celery.worker.job.TaskRequest method)
info_str (celery.events.cursesmon.CursesMonitor attribute)
init_callback (celery.worker.consumer.Consumer attribute)
init_loader() (celery.apps.beat.Beat method)
(celery.apps.worker.Worker method)
init_queues() (celery.apps.worker.Worker method)
init_screen() (celery.events.cursesmon.CursesMonitor method)
init_with_registry() (celery.worker.buckets.TaskBucket method)
init_worker() (celery.loaders.base.BaseLoader method)
initial_prefetch_count (celery.worker.consumer.Consumer attribute)
inspect (class in celery.bin.celeryctl)
Inspect (class in celery.task.control)
inspect() (celery.task.control.Control method)
install() (celery.events.snapshot.Polaroid method)
install_cry_handler() (in module celery.apps.worker)
install_default_entries() (celery.beat.Scheduler method)
install_HUP_not_supported_handler() (in module celery.apps.worker)
install_platform_tweaks() (celery.apps.worker.Worker method)
install_rdb_handler() (in module celery.apps.worker)
install_sync_handler() (celery.apps.beat.Beat method)
install_worker_int_again_handler() (in module celery.apps.worker)
install_worker_int_handler() (in module celery.apps.worker)
install_worker_restart_handler() (in module celery.apps.worker)
install_worker_term_handler() (in module celery.apps.worker)
instantiate() (in module celery.utils)
INVALID_TASK_ERROR (in module celery.worker.consumer)
InvalidResponseError
InvalidTaskError
ired() (celery.utils.term.colored method)
is_aborted() (celery.contrib.abortable.AbortableAsyncResult method)
(celery.contrib.abortable.AbortableTask method)
is_alive() (celery.concurrency.processes.pool.Pool.Process method)
(celery.concurrency.processes.TaskPool.Pool.Process method)
is_due() (celery.beat.ScheduleEntry method)
(celery.schedules.crontab method)
(celery.schedules.schedule method)
(celery.task.base.PeriodicTask method)
is_green (celery.concurrency.base.BasePool attribute)
(celery.concurrency.evg.TaskPool attribute)
(celery.concurrency.evlet.TaskPool attribute)
is_iterable() (in module celery.utils)
is_locked() (celery.platforms.PIDFile method)
isatty() (celery.log.LoggingProxy method)
(in module celery.utils)
items (celery.worker.buckets.FastQueue attribute)
(celery.worker.buckets.TaskBucket attribute)
(celery.worker.buckets.TokenBucketQueue attribute)
items() (celery.datastructures.ConfigurationView method)
iter_native() (celery.result.ResultSet method)
iterate() (celery.result.ResultSet method)
itercapture() (celery.events.EventReceiver method)
iteritems() (celery.datastructures.ConfigurationView method)
(celery.datastructures.DictAttribute method)
iterkeys() (celery.datastructures.ConfigurationView method)
itersubtasks() (celery.result.TaskSetResult method)
itervalues() (celery.datastructures.ConfigurationView method)
iwhite() (celery.utils.term.colored method)
iyellow() (celery.utils.term.colored method)

J

join() (celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.TaskPool.Pool method)
(celery.concurrency.processes.TaskPool.Pool.Process method)
(celery.concurrency.processes.pool.Pool.Process method)
(celery.result.ResultSet method)
join_native() (celery.result.ResultSet method)

K

key (celery.utils.dispatch.saferef.BoundMethodWeakref attribute)
keyalias (celery.events.cursesmon.CursesMonitor attribute)
keymap (celery.events.cursesmon.CursesMonitor attribute)
keys() (celery.datastructures.ConfigurationView method)
keyspace (celery.backends.cassandra.CassandraBackend attribute)
KeyValueStoreBackend (class in celery.backends.base)
kill() (celery.bin.celeryd_multi.MultiTool method)
kwargs (celery.beat.ScheduleEntry attribute)
(celery.contrib.batches.SimpleRequest attribute)
(celery.worker.job.TaskRequest attribute)
kwdict() (in module celery.utils)

L

last_run_at (celery.beat.ScheduleEntry attribute)
limit (celery.concurrency.processes.TaskPool attribute)
(celery.events.cursesmon.CursesMonitor attribute)
LimitedSet (class in celery.datastructures)
list_ (class in celery.bin.celeryctl)
list_bindings() (celery.bin.celeryctl.list_ method)
load_settings() (in module celery.loaders)
loader (celery.app.App attribute)
(celery.worker.job.WorkerTaskTrace attribute)
Loader (class in celery.loaders.default)
LocalCache (class in celery.datastructures)
LockFailed
log (celery.app.App attribute)
logfile (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
logger (celery.apps.worker.Worker.WorkController attribute)
(celery.beat.Scheduler attribute)
(celery.concurrency.processes.TaskPool attribute)
(celery.contrib.batches.Batches attribute)
(celery.worker.WorkController attribute)
(celery.worker.consumer.Consumer attribute)
Logging (class in celery.log)
LoggingProxy (class in celery.log)
loglevel (celery.apps.worker.Worker.WorkController attribute)
(celery.log.LoggingProxy attribute)
(celery.worker.WorkController attribute)
lookup_route() (celery.routes.Router method)
lpmerge() (in module celery.utils)

M

magenta() (celery.utils.term.colored method)
mail (celery.loaders.base.BaseLoader attribute)
mail_admins() (celery.app.App method)
(celery.loaders.base.BaseLoader method)
Mailer (class in celery.utils.mail)
main (celery.app.App attribute)
main() (in module celery.bin.camqadm)
(in module celery.bin.celerybeat)
(in module celery.bin.celeryctl)
(in module celery.bin.celeryd)
(in module celery.bin.celeryd_multi)
(in module celery.bin.celeryev)
make_request() (celery.task.http.HttpDispatch method)
mandatory (celery.app.task.BaseTask attribute)
(Task attribute)
map() (celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.TaskPool.Pool method)
map_async() (celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.TaskPool.Pool method)
MapRoute (class in celery.routes)
mark_as_done() (celery.backends.base.BaseBackend method)
mark_as_failure() (celery.backends.base.BaseBackend method)
mark_as_retry() (celery.backends.base.BaseBackend method)
mark_as_revoked() (celery.backends.base.BaseBackend method)
mark_as_started() (celery.backends.base.BaseBackend method)
mattrgetter() (in module celery.utils)
max_interval (celery.beat.Scheduler attribute)
max_retries (celery.app.task.BaseTask attribute)
(Task attribute)
maxlen (celery.datastructures.LimitedSet attribute)
MaxRetriesExceededError
maybe_conn_error() (celery.worker.consumer.Consumer method)
maybe_due() (celery.beat.Scheduler method)
maybe_expire() (celery.worker.job.TaskRequest method)
maybe_iso8601() (in module celery.utils.timeutils)
maybe_promise() (in module celery.utils)
maybe_schedule() (in module celery.schedules)
maybe_timedelta() (in module celery.utils.timeutils)
maybe_utf8() (in module celery.task.http)
mediator (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
Mediator (class in celery.worker.mediator)
merge() (celery.app.App method)
(celery.events.state.Task method)
(celery.worker.state.Persistent method)
merge_inplace() (celery.beat.Scheduler method)
merge_rules (celery.events.state.Task attribute)
message (celery.worker.job.TaskRequest attribute)
Message (class in celery.utils.mail)
Message() (celery.backends.amqp.AMQPBackend.Exchange method)
method (celery.task.http.HttpDispatchTask attribute), [1]
mget() (celery.backends.base.KeyValueStoreBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.redis.RedisBackend method)
minute (celery.schedules.crontab attribute)
mode (celery.log.LoggingProxy attribute)
MongoBackend (class in celery.backends.mongodb)
mongodb_database (celery.backends.mongodb.MongoBackend attribute)
mongodb_host (celery.backends.mongodb.MongoBackend attribute)
mongodb_password (celery.backends.mongodb.MongoBackend attribute)
mongodb_port (celery.backends.mongodb.MongoBackend attribute)
mongodb_taskmeta_collection (celery.backends.mongodb.MongoBackend attribute)
mongodb_user (celery.backends.mongodb.MongoBackend attribute)
move() (celery.worker.mediator.Mediator method)
move_selection() (celery.events.cursesmon.CursesMonitor method)
move_selection_down() (celery.events.cursesmon.CursesMonitor method)
move_selection_up() (celery.events.cursesmon.CursesMonitor method)
mpromise (class in celery.utils)
multi_args() (in module celery.bin.celeryd_multi)
multi_call() (celery.task.control.Control.Mailbox method)
MultiTool (class in celery.bin.celeryd_multi)
MutableURL (class in celery.task.http)

N

name (celery.app.task.BaseTask attribute)
(Task attribute)
(celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.backends.amqp.AMQPBackend.Queue attribute), [1]
(celery.beat.ScheduleEntry attribute)
(celery.concurrency.processes.TaskPool.Pool.Process attribute)
(celery.concurrency.processes.pool.Pool.Process attribute)
(celery.contrib.abortable.AbortableTask attribute)
(celery.contrib.batches.SimpleRequest attribute)
(celery.log.LoggingProxy attribute)
(celery.task.chords.Chord attribute)
(celery.task.chords.chord.Chord attribute)
(celery.task.http.HttpDispatchTask attribute)
(celery.worker.job.TaskRequest attribute)
names() (celery.bin.celeryd_multi.MultiTool method)
namespace (celery.bin.base.Command attribute)
(celery.bin.celeryd.WorkerCommand attribute)
(celery.task.control.Control.Mailbox attribute)
NamespacedOptionParser (class in celery.bin.celeryd_multi)
nap() (celery.events.cursesmon.CursesMonitor method)
needs_reconnect (celery.bin.camqadm.AMQShell attribute)
next() (celery.beat.ScheduleEntry method)
(celery.concurrency.base.BasePool.Timer method)
(celery.utils.timer2.Timer method)
no_ack (celery.backends.amqp.AMQPBackend.Consumer attribute)
(celery.backends.amqp.AMQPBackend.Queue attribute)
no_color() (celery.utils.term.colored method)
Node() (celery.task.control.Control.Mailbox method)
node() (celery.utils.term.colored method)
node_alive() (celery.bin.celeryd_multi.MultiTool method)
node_cls (celery.task.control.Control.Mailbox attribute)
noop() (in module celery.utils)
NOSE_VERBOSE
NotConfigured
note() (celery.bin.celeryd_multi.MultiTool method)
NotRegistered

O

on_accepted() (celery.worker.job.TaskRequest method)
on_ack (celery.worker.job.TaskRequest attribute)
on_apply() (celery.concurrency.base.BasePool method)
(celery.concurrency.evg.TaskPool method)
(celery.concurrency.evlet.TaskPool method)
(celery.concurrency.solo.TaskPool method)
(celery.concurrency.threads.TaskPool method)
on_chord_apply() (celery.backends.base.BaseBackend method)
(celery.backends.redis.RedisBackend method)
on_chord_part_return() (celery.backends.base.BaseBackend method)
(celery.backends.redis.RedisBackend method)
on_cleanup() (celery.events.snapshot.Polaroid method)
on_consumer_ready() (celery.apps.worker.Worker method)
on_control() (celery.worker.consumer.Consumer method)
on_decode_error (celery.backends.amqp.AMQPBackend.Consumer attribute)
on_decode_error() (celery.worker.consumer.Consumer method)
on_error (celery.concurrency.base.BasePool.Timer.Schedule attribute)
(celery.utils.timer2.Schedule attribute)
(celery.utils.timer2.Timer.Schedule attribute)
on_event() (celery.events.dumper.Dumper method)
on_failed() (celery.events.state.Task method)
on_failure()
(celery.app.task.BaseTask method)
(celery.task.base.BaseTask method)
(celery.worker.job.TaskRequest method)
on_heartbeat() (celery.events.state.Worker method)
on_offline() (celery.events.state.Worker method)
on_online() (celery.events.state.Worker method)
on_process_cleanup() (celery.loaders.base.BaseLoader method)
on_ready() (celery.concurrency.base.BasePool method)
on_received() (celery.events.state.Task method)
on_retried() (celery.events.state.Task method)
on_retry()
(celery.app.task.BaseTask method)
(celery.task.base.BaseTask method)
(celery.worker.job.TaskRequest method)
on_return (celery.backends.amqp.AMQPBackend.Producer attribute)
on_revoked() (celery.events.state.Task method)
on_sent() (celery.events.state.Task method)
on_shutter() (celery.events.snapshot.Polaroid method)
on_start() (celery.concurrency.base.BasePool method)
(celery.concurrency.evg.TaskPool method)
(celery.concurrency.evlet.TaskPool method)
(celery.concurrency.processes.TaskPool method)
(celery.concurrency.solo.TaskPool method)
(celery.concurrency.threads.TaskPool method)
on_started() (celery.events.state.Task method)
on_stop() (celery.concurrency.base.BasePool method)
(celery.concurrency.evg.TaskPool method)
(celery.concurrency.evlet.TaskPool method)
(celery.concurrency.processes.TaskPool method)
(celery.concurrency.threads.TaskPool method)
on_succeeded() (celery.events.state.Task method)
on_success()
(celery.app.task.BaseTask method)
(celery.task.base.BaseTask method)
(celery.worker.job.TaskRequest method)
on_task() (celery.worker.consumer.Consumer method)
on_task_init() (celery.loaders.base.BaseLoader method)
on_terminate() (celery.concurrency.base.BasePool method)
(celery.concurrency.processes.TaskPool method)
on_tick (celery.concurrency.base.BasePool.Timer attribute)
(celery.utils.timer2.Timer attribute)
on_timeout() (celery.worker.job.TaskRequest method)
on_timer_error() (celery.apps.worker.Worker.WorkController method)
(celery.worker.WorkController method)
on_timer_tick() (celery.apps.worker.Worker.WorkController method)
(celery.worker.WorkController method)
on_unknown_event() (celery.events.state.Task method)
on_worker_error() (celery.concurrency.base.BasePool method)
on_worker_init() (celery.loaders.app.AppLoader method)
(celery.loaders.base.BaseLoader method)
(celery.loaders.default.Loader method)
onecmd() (celery.bin.camqadm.AMQShell method)
online_str (celery.events.cursesmon.CursesMonitor attribute)
open() (celery.backends.tyrant.TyrantBackend method)
(celery.platforms.DaemonContext method)
(celery.worker.state.Persistent method)
Option (class in celery.app.defaults)
option_list (celery.bin.base.Command attribute)
(celery.bin.celeryctl.Command attribute)
(celery.bin.celeryctl.apply attribute)
(celery.bin.celeryctl.inspect attribute)
(celery.bin.celeryctl.result attribute)
(celery.bin.celeryctl.status attribute)
options (celery.beat.ScheduleEntry attribute)
options() (celery.app.amqp.Queues method)
optmerge() (celery.bin.celeryd_multi.NamespacedOptionParser method)
osx_proxy_detection_workaround() (celery.apps.worker.Worker method)
out() (celery.bin.celeryctl.Command method)
override_backends (celery.loaders.base.BaseLoader attribute)

P

padlist() (in module celery.utils)
parse() (celery.bin.celeryd_multi.NamespacedOptionParser method)
(celery.schedules.crontab_parser method)
parse_gid() (in module celery.platforms)
parse_ns_range() (in module celery.bin.celeryd_multi)
parse_options() (celery.bin.base.Command method)
parse_preload_options() (celery.bin.base.Command method)
parse_uid() (in module celery.platforms)
parseline() (celery.bin.camqadm.AMQShell method)
Parser (celery.bin.base.Command attribute)
password (celery.backends.redis.RedisBackend attribute)
PATH
PENDING
state
periodic() (celery.registry.TaskRegistry method)
periodic_task() (in module celery.task)
PeriodicTask (class in celery.task.base)
persistence (celery.beat.PersistentScheduler attribute)
Persistent (class in celery.worker.state)
PERSISTENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute)
PersistentScheduler (class in celery.beat)
pid (celery.concurrency.processes.pool.Pool.Process attribute)
(celery.concurrency.processes.TaskPool.Pool.Process attribute)
pidbox_node (celery.worker.consumer.Consumer attribute)
PIDFile (class in celery.platforms)
ping
control
ping() (celery.task.control.Control method)
(celery.task.control.Inspect method)
pluralize() (in module celery.bin.celeryctl)
Polaroid (class in celery.events.snapshot)
poll() (celery.backends.amqp.AMQPBackend method)
pool (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
(celery.worker.consumer.Consumer attribute)
Pool (class in celery.concurrency.processes.pool)
Pool.Process (class in celery.concurrency.processes.pool)
Pool.ResultHandler (class in celery.concurrency.processes.pool)
Pool.SoftTimeLimitExceeded
Pool.Supervisor (class in celery.concurrency.processes.pool)
Pool.TaskHandler (class in celery.concurrency.processes.pool)
Pool.TimeoutHandler (class in celery.concurrency.processes.pool)
pop() (celery.datastructures.LocalCache method)
(celery.registry.TaskRegistry method)
pop_value() (celery.datastructures.LimitedSet method)
port (celery.backends.redis.RedisBackend attribute)
post_async() (celery.task.http.URL method)
PRECEDENCE (in module celery.states)
precedence() (in module celery.states)
PREFETCH_COUNT_MAX (in module celery.worker.consumer)
preload_options (celery.bin.base.Command attribute)
prepare() (in module celery.routes)
prepare_config() (celery.app.App method)
prepare_exception() (celery.backends.base.BaseBackend method)
prepare_expires() (celery.backends.base.BaseBackend method)
prepare_value() (celery.backends.base.BaseBackend method)
prettify() (celery.bin.celeryctl.Command method)
prettify_dict_ok_error() (celery.bin.celeryctl.Command method)
prettify_list() (celery.bin.celeryctl.Command method)
prev (celery.worker.consumer.QoS attribute)
priority (celery.app.task.BaseTask attribute)
(Task attribute)
priority_timer (celery.worker.consumer.Consumer attribute)
process() (celery.events.EventReceiver method)
process_cleanup() (celery.backends.base.BaseBackend method)
(celery.backends.cassandra.CassandraBackend method)
(celery.backends.mongodb.MongoBackend method)
(celery.backends.redis.RedisBackend method)
(celery.backends.tyrant.TyrantBackend method)
process_cmdline_config() (celery.bin.base.Command method)
process_initializer() (in module celery.worker)
process_long_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method)
process_short_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method)
process_task() (celery.apps.worker.Worker.WorkController method)
(celery.worker.WorkController method)
processes (celery.worker.autoscale.Autoscaler attribute)
promise (class in celery.utils)
prompt (celery.bin.camqadm.AMQShell attribute)
prompt_fmt (celery.bin.camqadm.AMQShell attribute)
PROPAGATE_STATES
state
publish() (celery.backends.amqp.AMQPBackend.Exchange method)
(celery.backends.amqp.AMQPBackend.Producer method)
publisher (celery.beat.Scheduler attribute)
purge (class in celery.bin.celeryctl)
purge() (celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Queue method)
purge_messages() (celery.apps.worker.Worker method)
put() (celery.worker.buckets.TaskBucket method)
(celery.worker.buckets.TokenBucketQueue method)
put_nowait() (celery.worker.buckets.TaskBucket method)
(celery.worker.buckets.TokenBucketQueue method)

Q

QoS (class in celery.worker.consumer)
qos() (celery.backends.amqp.AMQPBackend.Consumer method)
qsize() (celery.worker.buckets.TaskBucket method)
(celery.worker.buckets.TokenBucketQueue method)
qty (celery.worker.autoscale.Autoscaler attribute)
queue (celery.app.task.BaseTask attribute)
(Task attribute)
(celery.concurrency.base.BasePool.Timer attribute)
(celery.concurrency.base.BasePool.Timer.Schedule attribute)
(celery.concurrency.evg.Schedule attribute)
(celery.concurrency.evg.TaskPool.Timer.Schedule attribute)
(celery.concurrency.evg.Timer.Schedule attribute)
(celery.concurrency.evlet.Schedule attribute)
(celery.concurrency.evlet.TaskPool.Timer.Schedule attribute)
(celery.concurrency.evlet.Timer.Schedule attribute)
(celery.utils.timer2.Schedule attribute)
(celery.utils.timer2.Timer attribute)
(celery.utils.timer2.Timer.Schedule attribute)
queue_arguments (celery.backends.amqp.AMQPBackend.Queue attribute)
queue_bind() (celery.backends.amqp.AMQPBackend.Queue method)
queue_declare() (celery.backends.amqp.AMQPBackend.Queue method)
QueueNotFound
queues (celery.app.amqp.AMQP attribute)
(celery.backends.amqp.AMQPBackend.Consumer attribute)
Queues (class in celery.app.amqp)
Queues() (celery.app.amqp.AMQP method)
quote() (in module celery.bin.celeryd_multi)

R

rate() (in module celery.utils.timeutils)
rate_limit
control
rate_limit (celery.app.task.BaseTask attribute)
(Task attribute)
rate_limit() (celery.task.control.Control method)
RateLimitExceeded
Rdb (class in celery.contrib.rdb)
read_configuration() (celery.loaders.app.AppLoader method)
(celery.loaders.default.Loader method)
read_pid() (celery.platforms.PIDFile method)
readline() (celery.events.cursesmon.CursesMonitor method)
ready (celery.events.state.Task attribute)
ready() (celery.result.BaseAsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
ready_queue (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
(celery.worker.consumer.Consumer attribute)
(celery.worker.mediator.Mediator attribute)
READY_STATES
state
READY_STATES (celery.backends.base.BaseBackend attribute)
receive() (celery.backends.amqp.AMQPBackend.Consumer method)
receive_message() (celery.worker.consumer.Consumer method)
Receiver() (celery.events.Events method)
receivers (celery.utils.dispatch.Signal attribute)
(celery.utils.dispatch.signal.Signal attribute)
recover() (celery.backends.amqp.AMQPBackend.Consumer method)
red() (celery.utils.term.colored method)
redirect_stdouts_to_logger() (celery.apps.worker.Worker method)
(celery.log.Logging method)
redis (celery.backends.redis.RedisBackend attribute)
RedisBackend (class in celery.backends.redis)
refresh() (celery.worker.buckets.TaskBucket method)
register() (celery.registry.TaskRegistry method)
register_callback() (celery.backends.amqp.AMQPBackend.Consumer method)
registered_tasks() (celery.task.control.Inspect method)
regular() (celery.registry.TaskRegistry method)
relative (celery.schedules.schedule attribute)
(celery.task.base.PeriodicTask attribute)
release() (celery.backends.amqp.AMQPBackend.Producer method)
(celery.platforms.PIDFile method)
reload_task_result() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
reload_taskset_result() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
remaining() (in module celery.utils.timeutils)
remaining_estimate() (celery.schedules.crontab method)
(celery.schedules.schedule method)
(celery.task.base.PeriodicTask method)
RemoteExecuteError
remove() (celery.platforms.PIDFile method)
(celery.result.ResultSet method)
remove_if_stale() (celery.platforms.PIDFile method)
repair_uuid() (in module celery.backends.amqp)
reply_exchange (celery.task.control.Control.Mailbox attribute)
reply_exchange_fmt (celery.task.control.Control.Mailbox attribute)
repr_result() (celery.worker.job.TaskRequest method)
reprcall() (in module celery.utils)
request (celery.app.task.BaseTask attribute)
reserve() (celery.beat.Scheduler method)
reserved() (celery.task.control.Inspect method)
reserved_requests (in module celery.worker.state)
reset() (celery.platforms.Signals method)
(celery.utils.term.colored method)
reset_connection() (celery.worker.consumer.Consumer method)
reset_pidbox_node() (celery.worker.consumer.Consumer method)
resetscreen() (celery.events.cursesmon.CursesMonitor method)
respond() (celery.bin.camqadm.AMQShell method)
restart() (celery.bin.celeryd_multi.MultiTool method)
restart_heartbeat() (celery.worker.consumer.Consumer method)
restore() (celery.result.TaskSetResult class method)
(celery.utils.serialization.UnpickleableExceptionWrapper method)
restore_taskset() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
result (celery.db.models.Task attribute)
(celery.db.models.TaskSet attribute)
(celery.result.BaseAsyncResult attribute)
(celery.result.EagerResult attribute)
(class in celery.bin.celeryctl)
results (celery.result.ResultSet attribute)
(celery.result.TaskSetResult attribute)
ResultSession() (celery.backends.database.DatabaseBackend method)
(in module celery.db.session)
ResultSet (class in celery.result)
retcode (celery.bin.celeryd_multi.MultiTool attribute)
retries (celery.worker.job.TaskRequest attribute)
RETRY
state
retry (celery.app.amqp.TaskPublisher attribute)
retry() (celery.app.task.BaseTask class method)
(celery.task.base.BaseTask class method)
retry_msg (celery.worker.job.TaskRequest attribute)
retry_policy (celery.app.amqp.TaskPublisher attribute)
RetryTaskError
reverse() (celery.utils.term.colored method)
revive() (celery.backends.amqp.AMQPBackend method)
(celery.backends.amqp.AMQPBackend.Consumer method)
(celery.backends.amqp.AMQPBackend.Producer method)
revoke
control
revoke() (celery.result.BaseAsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
(celery.task.control.Control method)
REVOKE_EXPIRES (in module celery.worker.state)
revoke_selection() (celery.events.cursesmon.CursesMonitor method)
REVOKED
state
revoked (in module celery.worker.state)
revoked() (celery.task.control.Inspect method)
(celery.worker.job.TaskRequest method)
REVOKES_MAX (in module celery.worker.state)
route() (celery.routes.Router method)
route_for_task() (celery.routes.MapRoute method)
Router (class in celery.routes)
Router() (celery.app.amqp.AMQP method)
routing_key (celery.app.task.BaseTask attribute)
(Task attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
(celery.backends.amqp.AMQPBackend.Queue attribute), [1]
RUN (celery.apps.worker.Worker.WorkController attribute)
(celery.concurrency.base.BasePool attribute)
(celery.worker.WorkController attribute)
run() (celery.app.task.BaseTask method)
(celery.apps.beat.Beat method)
(celery.apps.worker.Worker method)
(celery.bin.base.Command method)
(celery.bin.camqadm.AMQPAdmin method)
(celery.bin.camqadm.AMQPAdminCommand method)
(celery.bin.celerybeat.BeatCommand method)
(celery.bin.celeryctl.Command method)
(celery.bin.celeryctl.apply method)
(celery.bin.celeryctl.help method)
(celery.bin.celeryctl.inspect method)
(celery.bin.celeryctl.list_ method)
(celery.bin.celeryctl.purge method)
(celery.bin.celeryctl.result method)
(celery.bin.celeryctl.status method)
(celery.bin.celeryd.WorkerCommand method)
(celery.bin.celeryev.EvCommand method)
(celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.processes.TaskPool.Pool.Process method)
(celery.concurrency.processes.pool.Pool.Process method)
(celery.contrib.batches.Batches method)
(celery.events.cursesmon.DisplayThread method)
(celery.task.base.BaseTask method)
(celery.task.chords.Chord method)
(celery.task.chords.chord.Chord method)
(celery.task.http.HttpDispatchTask method)
(celery.utils.timer2.Timer method)
(celery.worker.autoscale.Autoscaler method)
(celery.worker.mediator.Mediator method)
run_evcam() (celery.bin.celeryev.EvCommand method)
run_evdump() (celery.bin.celeryev.EvCommand method)
run_every (celery.task.base.PeriodicTask attribute)
run_evtop() (celery.bin.celeryev.EvCommand method)
run_from_argv() (celery.bin.celeryctl.Command method)
run_worker() (celery.apps.worker.Worker method)
running (celery.concurrency.base.BasePool.Timer attribute)
(celery.utils.timer2.Timer attribute)

S

safe_add_str() (celery.events.cursesmon.CursesMonitor method)
safe_apply_callback() (celery.concurrency.base.BasePool method)
safe_ref() (in module celery.utils.dispatch.saferef)
safe_repr() (in module celery.utils.encoding)
safe_str() (in module celery.utils.encoding)
save() (celery.result.TaskSetResult method)
(celery.worker.state.Persistent method)
save_taskset() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
say() (celery.bin.camqadm.AMQPAdmin method)
(celery.bin.camqadm.AMQShell method)
(celery.bin.celeryctl.inspect method)
(in module celery.bin.camqadm)
(in module celery.bin.celeryd_multi)
scale() (celery.worker.autoscale.Autoscaler method)
scale_down() (celery.worker.autoscale.Autoscaler method)
scale_up() (celery.worker.autoscale.Autoscaler method)
schedule (celery.beat.ScheduleEntry attribute)
(celery.beat.Scheduler attribute)
Schedule (class in celery.concurrency.evg)
(class in celery.concurrency.evlet)
schedule (class in celery.schedules)
Schedule (class in celery.utils.timer2)
scheduled() (celery.task.control.Inspect method)
ScheduleEntry (class in celery.beat)
scheduler (celery.apps.beat.Beat.Service attribute)
(celery.beat.Service attribute)
Scheduler (class in celery.beat)
scheduler_cls (celery.apps.beat.Beat.Service attribute)
(celery.beat.Service attribute)
SchedulingError
screen_delay (celery.events.cursesmon.CursesMonitor attribute)
screen_height (celery.events.cursesmon.CursesMonitor attribute)
screen_width (celery.events.cursesmon.CursesMonitor attribute)
select_subset() (celery.app.amqp.Queues 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)
send() (celery.events.EventDispatcher method)
(celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
(celery.utils.mail.Mailer method)
send_error_email() (celery.worker.job.TaskRequest method)
send_error_emails (celery.app.task.BaseTask attribute)
(Task attribute)
send_event() (celery.worker.job.TaskRequest method)
send_events (celery.apps.worker.Worker.WorkController attribute)
(celery.worker.WorkController attribute)
(celery.worker.consumer.Consumer attribute)
send_robust() (celery.utils.dispatch.Signal method)
(celery.utils.dispatch.signal.Signal method)
send_task() (celery.app.App method)
(celery.beat.Scheduler method)
SendmailWarning
serializer (celery.app.task.BaseTask attribute)
(Task attribute)
(celery.backends.amqp.AMQPBackend.Producer attribute)
SERVER_EMAIL
setting
servers (celery.backends.cassandra.CassandraBackend attribute), [1]
Service (class in celery.beat)
set() (celery.backends.base.KeyValueStoreBackend method)
(celery.backends.cache.CacheBackend method)
(celery.backends.cache.DummyClient method)
(celery.backends.redis.RedisBackend method)
(celery.backends.tyrant.TyrantBackend method)
(celery.worker.consumer.QoS method)
set_effective_user() (in module celery.platforms)
set_mp_process_title() (in module celery.platforms)
set_process_status() (celery.apps.worker.Worker method)
(celery.bin.celeryev.EvCommand method)
set_process_title() (celery.apps.beat.Beat method)
(in module celery.platforms)
set_schedule() (celery.beat.Scheduler method)
set_trace() (in module celery.contrib.rdb)
setdefault() (celery.datastructures.ConfigurationView method)
(celery.datastructures.DictAttribute method)
setegid() (in module celery.platforms)
seteuid() (in module celery.platforms)
setgid() (in module celery.platforms)
setting
ADMINS
BROKER_CONNECTION_MAX_RETRIES
BROKER_CONNECTION_RETRY
BROKER_CONNECTION_TIMEOUT
BROKER_HOST
BROKER_PASSWORD
BROKER_POOL_LIMIT
BROKER_PORT
BROKER_TRANSPORT
BROKER_TRANSPORT_OPTIONS
BROKER_USER
BROKER_USE_SSL
BROKER_VHOST
CELERYBEAT_LOG_FILE
CELERYBEAT_LOG_LEVEL
CELERYBEAT_MAX_LOOP_INTERVAL
CELERYBEAT_SCHEDULE
CELERYBEAT_SCHEDULER
CELERYBEAT_SCHEDULE_FILENAME
CELERYD_AUTOSCALER
CELERYD_CONCURRENCY
CELERYD_CONSUMER
CELERYD_ETA_SCHEDULER
CELERYD_ETA_SCHEDULER_PRECISION
CELERYD_HIJACK_ROOT_LOGGER
CELERYD_LOG_COLOR
CELERYD_LOG_FILE
CELERYD_LOG_FORMAT
CELERYD_LOG_LEVEL
CELERYD_MAX_TASKS_PER_CHILD
CELERYD_MEDIATOR
CELERYD_POOL
CELERYD_PREFETCH_MULTIPLIER
CELERYD_STATE_DB
CELERYD_TASK_LOG_FORMAT
CELERYD_TASK_SOFT_TIME_LIMIT
CELERYD_TASK_TIME_LIMIT
CELERYMON_LOG_FILE
CELERYMON_LOG_FORMAT
CELERYMON_LOG_LEVEL
CELERY_ACKS_LATE
CELERY_ALWAYS_EAGER
CELERY_AMQP_TASK_RESULT_CONNECTION_MAX
CELERY_AMQP_TASK_RESULT_EXPIRES
CELERY_BROADCAST_EXCHANGE
CELERY_BROADCAST_EXCHANGE_TYPE
CELERY_BROADCAST_QUEUE
CELERY_CACHE_BACKEND
CELERY_CACHE_BACKEND_OPTIONS
CELERY_CREATE_MISSING_QUEUES
CELERY_DEFAULT_DELIVERY_MODE
CELERY_DEFAULT_EXCHANGE
CELERY_DEFAULT_EXCHANGE_TYPE
CELERY_DEFAULT_QUEUE
CELERY_DEFAULT_RATE_LIMIT
CELERY_DEFAULT_ROUTING_KEY
CELERY_DISABLE_RATE_LIMITS
CELERY_EAGER_PROPAGATES_EXCEPTIONS
CELERY_EVENT_SERIALIZER
CELERY_IGNORE_RESULT
CELERY_IMPORTS
CELERY_MAX_CACHED_RESULTS
CELERY_MESSAGE_COMPRESSION
CELERY_MONGODB_BACKEND_SETTINGS
CELERY_QUEUES
CELERY_REDIRECT_STDOUTS
CELERY_REDIRECT_STDOUTS_LEVEL
CELERY_REDIS_DB
CELERY_REDIS_HOST
CELERY_REDIS_PASSWORD
CELERY_REDIS_PORT
CELERY_RESULT_BACKEND
CELERY_RESULT_DBURI
CELERY_RESULT_ENGINE_OPTIONS
CELERY_RESULT_EXCHANGE
CELERY_RESULT_EXCHANGE_TYPE
CELERY_RESULT_PERSISTENT
CELERY_RESULT_SERIALIZER
CELERY_ROUTES
CELERY_SEND_EVENTS
CELERY_SEND_TASK_ERROR_EMAILS
CELERY_SEND_TASK_SENT_EVENT
CELERY_STORE_ERRORS_EVEN_IF_IGNORED
CELERY_TASK_ERROR_WHITELIST
CELERY_TASK_PUBLISH_RETRY
CELERY_TASK_PUBLISH_RETRY_POLICY
CELERY_TASK_RESULT_EXPIRES
CELERY_TASK_SERIALIZER
CELERY_TRACK_STARTED
EMAIL_HOST
EMAIL_HOST_PASSWORD
EMAIL_HOST_USER
EMAIL_PORT
EMAIL_TIMEOUT
EMAIL_USE_SSL
SERVER_EMAIL
TT_HOST
TT_PORT
setuid() (in module celery.platforms)
setup_app_from_commandline() (celery.bin.base.Command method)
setup_loader() (in module celery.loaders)
setup_logger() (celery.log.Logging method)
setup_logging
signal
setup_logging() (celery.apps.beat.Beat method)
setup_logging_subsystem() (celery.log.Logging method)
setup_results() (in module celery.db.session)
setup_schedule() (celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
setup_settings() (celery.loaders.default.Loader method)
setup_task_logger() (celery.log.Logging method)
shortinfo() (celery.worker.job.TaskRequest method)
should_sync() (celery.beat.Scheduler method)
show() (celery.bin.celeryd_multi.MultiTool method)
shrink() (celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.TaskPool method)
(celery.concurrency.processes.TaskPool.Pool method)
shutdown
control
shutdown_nodes() (celery.bin.celeryd_multi.MultiTool method)
shutter() (celery.events.snapshot.Polaroid method)
shutter_signal (celery.events.snapshot.Polaroid attribute)
signal
after_setup_logger
after_setup_task_logger
beat_embedded_init
beat_init
eventlet_pool_apply
eventlet_pool_postshutdown
eventlet_pool_preshutdown
eventlet_pool_started
setup_logging
task_failure
task_postrun
task_prerun
task_sent
worker_init
worker_process_init
worker_ready
worker_shutdown
Signal (class in celery.utils.dispatch)
(class in celery.utils.dispatch.signal)
signal_node() (celery.bin.celeryd_multi.MultiTool method)
signal_safe (celery.concurrency.base.BasePool attribute)
(celery.concurrency.evg.TaskPool attribute)
(celery.concurrency.evlet.TaskPool attribute)
Signals (class in celery.platforms)
signum() (celery.platforms.Signals method)
SilenceRepeated (class in celery.log)
SimpleRequest (class in celery.contrib.batches)
soft_time_limit (celery.app.task.BaseTask attribute)
(Task attribute)
SoftTimeLimitExceeded
SOFTWARE_INFO (in module celery.worker.state)
Spec (class in celery.bin.camqadm)
splash() (celery.bin.celeryd_multi.MultiTool method)
start() (celery.apps.beat.Beat.Service method)
(celery.apps.worker.Worker.WorkController method)
(celery.beat.Service method)
(celery.bin.celeryd_multi.MultiTool method)
(celery.concurrency.base.BasePool method)
(celery.concurrency.evg.TaskPool.Timer method)
(celery.concurrency.evg.Timer method)
(celery.concurrency.evlet.TaskPool.Timer method)
(celery.concurrency.evlet.Timer method)
(celery.concurrency.processes.TaskPool.Pool.Process method)
(celery.concurrency.processes.pool.Pool.Process method)
(celery.worker.WorkController method)
(celery.worker.consumer.Consumer method)
(celery.worker.heartbeat.Heart method)
start_scheduler() (celery.apps.beat.Beat method)
STARTED
state
startup_info() (celery.apps.beat.Beat method)
(celery.apps.worker.Worker method)
state
ALL_STATES
EXCEPTION_STATES
FAILURE
PENDING
PROPAGATE_STATES
READY_STATES
RETRY
REVOKED
STARTED
SUCCESS
UNREADY_STATES
state (celery.result.BaseAsyncResult attribute)
(celery.result.EagerResult attribute)
State (class in celery.events.state)
state (class in celery.states)
State() (celery.events.Events method)
stats() (celery.task.control.Inspect method)
status (celery.db.models.Task attribute)
(celery.result.BaseAsyncResult attribute)
(celery.result.EagerResult attribute)
(class in celery.bin.celeryctl)
stop() (celery.apps.beat.Beat.Service method)
(celery.apps.worker.Worker.WorkController method)
(celery.beat.Service method)
(celery.bin.celeryd_multi.MultiTool method)
(celery.concurrency.base.BasePool method)
(celery.concurrency.base.BasePool.Timer method)
(celery.concurrency.evg.TaskPool.Timer method)
(celery.concurrency.evg.Timer method)
(celery.concurrency.evlet.TaskPool.Timer method)
(celery.concurrency.evlet.Timer method)
(celery.utils.timer2.Timer method)
(celery.worker.WorkController method)
(celery.worker.autoscale.Autoscaler method)
(celery.worker.consumer.Consumer method)
(celery.worker.heartbeat.Heart method)
(celery.worker.mediator.Mediator method)
stop_consumers() (celery.worker.consumer.Consumer method)
storage (celery.worker.state.Persistent attribute)
store_errors_even_if_ignored (celery.app.task.BaseTask attribute)
(Task attribute)
store_result() (celery.backends.base.BaseBackend method)
(celery.backends.base.BaseDictBackend method)
(celery.backends.base.DisabledBackend method)
str_args_to_python() (celery.bin.camqadm.Spec method)
str_to_bool() (in module celery.app.defaults)
strargv() (in module celery.platforms)
subclass_exception() (in module celery.utils.serialization)
subpolling_interval (celery.backends.base.BaseBackend attribute)
(celery.backends.database.DatabaseBackend attribute)
subtask (class in celery.task.sets)
subtask() (celery.app.task.BaseTask class method)
(celery.task.base.BaseTask class method)
subtasks (celery.result.ResultSet attribute)
SUCCESS
state
success_msg (celery.worker.job.TaskRequest attribute)
successful() (celery.result.BaseAsyncResult method)
(celery.result.EagerResult method)
(celery.result.ResultSet method)
supported() (celery.platforms.Signals method)
supports_args (celery.bin.base.Command attribute)
(celery.bin.celerybeat.BeatCommand attribute)
(celery.bin.celeryd.WorkerCommand attribute)
(celery.bin.celeryev.EvCommand attribute)
supports_color() (celery.log.Logging method)
sync() (celery.apps.beat.Beat.Service method)
(celery.beat.PersistentScheduler method)
(celery.beat.Scheduler method)
(celery.beat.Service method)
(celery.worker.state.Persistent method)
sync_every (celery.beat.Scheduler attribute)
SystemTerminate

T

task (celery.task.sets.TaskSet attribute)
(celery.worker.job.TaskRequest attribute)
Task (class in celery.db.models)
(class in celery.events.state)
(class in celery.task)
task() (celery.app.App method)
(in module celery.task)
task_accepted() (in module celery.worker.state)
task_consumer (celery.worker.consumer.Consumer attribute)
task_count (celery.events.state.State attribute)
TASK_ERROR_EMAIL_BODY (in module celery.worker.job)
task_event() (celery.events.state.State method)
task_failure
signal
task_id (celery.db.models.Task attribute)
(celery.result.BaseAsyncResult attribute)
(celery.worker.job.TaskRequest attribute)
task_keyprefix (celery.backends.base.KeyValueStoreBackend attribute)
task_name (celery.task.sets.TaskSet attribute)
task_postrun
signal
task_prerun
signal
task_ready() (in module celery.worker.state)
task_reserved() (in module celery.worker.state)
task_sent
signal
task_types() (celery.events.state.State method)
TaskBucket (class in celery.worker.buckets)
TaskConsumer() (celery.app.amqp.AMQP method)
tasklist() (celery.apps.worker.Worker method)
TaskPool (class in celery.concurrency.evg)
(class in celery.concurrency.evlet)
(class in celery.concurrency.processes)
(class in celery.concurrency.solo)
(class in celery.concurrency.threads)
TaskPool.Pool (class in celery.concurrency.processes)
TaskPool.Pool.Process (class in celery.concurrency.processes)
TaskPool.Pool.ResultHandler (class in celery.concurrency.processes)
TaskPool.Pool.SoftTimeLimitExceeded
TaskPool.Pool.Supervisor (class in celery.concurrency.processes)
TaskPool.Pool.TaskHandler (class in celery.concurrency.processes)
TaskPool.Pool.TimeoutHandler (class in celery.concurrency.processes)
TaskPool.Timer (class in celery.concurrency.evg)
(class in celery.concurrency.evlet)
TaskPool.Timer.Schedule (class in celery.concurrency.evg)
(class in celery.concurrency.evlet)
TaskPublisher (class in celery.app.amqp)
TaskPublisher() (celery.app.amqp.AMQP method)
TaskRegistry (class in celery.registry)
TaskRegistry.NotRegistered
TaskRequest (class in celery.worker.job)
TaskRevokedError
tasks (celery.events.cursesmon.CursesMonitor attribute)
(celery.task.sets.TaskSet attribute)
(in module celery.registry)
tasks_by_timestamp() (celery.events.state.State method)
tasks_by_type() (celery.events.state.State method)
tasks_by_worker() (celery.events.state.State method)
TaskSet (class in celery.db.models)
(class in celery.task.sets)
TaskSet() (celery.app.App method)
taskset_id (celery.db.models.TaskSet attribute)
(celery.result.TaskSetResult attribute)
(celery.worker.job.TaskRequest attribute)
taskset_keyprefix (celery.backends.base.KeyValueStoreBackend attribute)
TaskSetResult (class in celery.result)
TaskSetResult() (celery.app.App method)
TaskTrace (class in celery.execute.trace)
TaskType (class in celery.app.task)
(class in celery.task.base)
TERMINATE (celery.apps.worker.Worker.WorkController attribute)
(celery.concurrency.base.BasePool attribute)
(celery.worker.WorkController attribute)
terminate() (celery.apps.worker.Worker.WorkController method)
(celery.concurrency.base.BasePool method)
(celery.concurrency.processes.TaskPool.Pool method)
(celery.concurrency.processes.TaskPool.Pool.Process method)
(celery.concurrency.processes.pool.Pool method)
(celery.concurrency.processes.pool.Pool.Process method)
(celery.worker.WorkController method)
(celery.worker.job.TaskRequest method)
terminate_job() (celery.concurrency.base.BasePool method)
(celery.concurrency.processes.TaskPool method)
textindent() (in module celery.utils)
thaw() (State method)
tick() (celery.beat.Scheduler method)
time_limit (celery.app.task.BaseTask attribute)
(Task attribute)
time_limit() (celery.task.control.Control method)
time_start (celery.worker.job.TaskRequest attribute)
timedelta_seconds() (celery.task.base.PeriodicTask method)
(in module celery.utils.timeutils)
TimedFunctionFailed
TimeLimitExceeded
timeout (celery.task.http.HttpDispatch attribute)
TimeoutError
timer (celery.events.snapshot.Polaroid attribute)
Timer (class in celery.concurrency.evg)
(class in celery.concurrency.evlet)
(class in celery.utils.timer2)
Timer.Entry (class in celery.utils.timer2)
Timer.Schedule (class in celery.concurrency.evg)
(class in celery.concurrency.evlet)
(class in celery.utils.timer2)
timestamp (celery.datastructures.TokenBucket attribute)
to_dict() (celery.db.models.Task method)
(celery.db.models.TaskSet method)
to_python() (celery.app.defaults.Option method)
to_timestamp() (in module celery.utils.timer2)
TokenBucket (class in celery.datastructures)
TokenBucketQueue (class in celery.worker.buckets)
TokenBucketQueue.RateLimitExceeded
total (celery.result.ResultSet attribute)
(celery.task.sets.TaskSet attribute)
total_count (in module celery.worker.state)
total_run_count (celery.beat.ScheduleEntry attribute)
trace() (celery.execute.trace.TraceInfo class method)
traceback (celery.datastructures.ExceptionInfo attribute)
(celery.db.models.Task attribute)
(celery.result.BaseAsyncResult attribute)
(celery.result.EagerResult attribute)
TraceInfo (class in celery.execute.trace)
track_started (celery.app.task.BaseTask attribute)
(Task attribute)
TRANSIENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute)
truncate_text() (in module celery.utils)
TT_HOST
setting
TT_PORT
setting
type (celery.app.task.BaseTask attribute)
(celery.backends.amqp.AMQPBackend.Exchange attribute), [1]
(celery.task.control.Control.Mailbox attribute)
(celery.task.sets.subtask attribute)
typemap (celery.app.defaults.Option attribute)
tyrant_host (celery.backends.tyrant.TyrantBackend attribute), [1]
tyrant_port (celery.backends.tyrant.TyrantBackend attribute), [1]
TyrantBackend (class in celery.backends.tyrant)

U

unbind() (celery.backends.amqp.AMQPBackend.Queue method)
underline() (celery.utils.term.colored method)
UNKNOWN_TASK_ERROR (in module celery.worker.consumer)
UnknownStatusError
UnpickleableExceptionWrapper
UNREADY_STATES
state
UNREADY_STATES (celery.backends.base.BaseBackend attribute)
unregister() (celery.registry.TaskRegistry method)
unwanted_base_classes (in module celery.utils.serialization)
update() (celery.beat.ScheduleEntry method)
(celery.datastructures.ConfigurationView method)
(celery.datastructures.LimitedSet method)
(celery.events.state.Task method)
(celery.platforms.Signals method)
(celery.result.ResultSet method)
(celery.worker.autoscale.Autoscaler method)
(celery.worker.consumer.QoS method)
update_bucket_for_type() (celery.worker.buckets.TaskBucket method)
update_from_dict() (celery.beat.Scheduler method)
update_state() (celery.app.task.BaseTask method)
(celery.task.base.BaseTask method)
url (celery.task.http.HttpDispatchTask attribute), [1]
URL (class in celery.task.http)
usage() (celery.bin.base.Command method)
(celery.bin.celeryctl.Command method)
(celery.bin.celeryctl.help method)
(celery.bin.celeryctl.inspect method)
(celery.bin.celeryd_multi.MultiTool method)
user_agent (celery.task.http.HttpDispatch attribute)
utf8dict() (in module celery.task.http)

V

values() (celery.datastructures.ConfigurationView method)
version (celery.bin.base.Command attribute)
(celery.bin.celeryctl.Command attribute)

W

wait() (celery.result.BaseAsyncResult method)
(celery.worker.buckets.FastQueue method)
(celery.worker.buckets.TokenBucketQueue method)
wait_for() (celery.backends.amqp.AMQPBackend method)
(celery.backends.base.BaseBackend method)
(celery.backends.base.DisabledBackend method)
waitexec() (celery.bin.celeryd_multi.MultiTool method)
waiting() (celery.result.ResultSet method)
wakeup_workers() (celery.events.EventReceiver method)
WANTED_DELIVERY_INFO (in module celery.worker.job)
wanted_module_item() (celery.loaders.default.Loader method)
weak_func (celery.utils.dispatch.saferef.BoundMethodWeakref attribute)
weak_self (celery.utils.dispatch.saferef.BoundMethodWeakref attribute)
weekday() (in module celery.utils.timeutils)
when_bound() (celery.backends.amqp.AMQPBackend.Queue method)
white() (celery.utils.term.colored method)
win (celery.events.cursesmon.CursesMonitor attribute)
windows_main() (in module celery.bin.celeryd)
with_default_connection() (celery.app.App method)
with_defaults() (celery.app.amqp.Queues class method)
with_detacher_default_options() (celery.bin.celeryd_multi.MultiTool method)
WorkController (class in celery.worker)
Worker (class in celery.apps.worker)
(class in celery.events.state)
Worker() (celery.app.App method)
Worker.WorkController (class in celery.apps.worker)
worker_event() (celery.events.state.State method)
worker_init
signal
worker_init() (celery.apps.worker.Worker method)
worker_initialized (celery.loaders.base.BaseLoader attribute)
worker_main() (celery.app.App method)
worker_pid (celery.worker.job.TaskRequest attribute)
worker_process_init
signal
worker_ready
signal
worker_shutdown
signal
WORKER_SIGIGNORE (in module celery.worker)
WORKER_SIGRESET (in module celery.worker)
WorkerCommand (class in celery.bin.celeryd)
WorkerLostError
workers (celery.events.cursesmon.CursesMonitor attribute)
WorkerTaskTrace (class in celery.worker.job)
write() (celery.log.LoggingProxy method)
write_pid() (celery.platforms.PIDFile method)
writelines() (celery.log.LoggingProxy method)

Y

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