Index

Symbols

--autoreload celery-worker command line option --autoscale celery-worker command line option --config command line option --detach celery-beat command line option celery-events command line option --executable command line option --gid command line option --heartbeat-interval celery-worker command line option --loader command line option --max-interval celery-beat command line option --maxtasksperchild celery-worker command line option --no-execv celery-worker command line option --pidfile celery-worker command line option command line option --purge celery-worker command line option --scheduler celery-worker command line option --soft-time-limit celery-worker command line option --time-limit celery-worker command line option --uid command line option --umask command line option --without-gossip celery-worker command line option --without-heartbeat celery-worker command line option --without-mingle celery-worker command line option

--workdir command line option -A, --app command line option -B, --beat celery-worker command line option -b, --broker command line option -c, --camera celery-events command line option -c, --concurrency celery-worker command line option -d, --dump celery-events command line option -E, --events celery-worker command line option -F, --freq, --frequency celery-events command line option -f, --logfile celery-beat command line option celery-worker command line option command line option -I, --include celery-worker command line option -l, --loglevel celery-beat command line option celery-events command line option celery-worker command line option -n, --hostname celery-worker command line option -O celery-worker command line option -P, --pool celery-worker command line option -Q, --queues celery-worker command line option -r, --maxrate celery-events command line option -s, --schedule celery-beat command line option celery-worker command line option -S, --scheduler celery-beat command line option -S, --statedb celery-worker command line option

_

__call__() (celery.signature method)

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) (Task attribute) accept (celery.app.control.Control.Mailbox attribute) (celery.backends.amqp.AMQPBackend.Consumer attribute) accept_magic_kwargs (celery.app.task.Task attribute) ack acknowledge() (celery.worker.job.Request method) acknowledged (celery.worker.job.Request attribute) acks_late (celery.app.task.Task attribute) (Task attribute) acquire() (celery.platforms.Pidfile method) ACTIONS (celery.bin.base.Option attribute) active (celery.concurrency.base.BasePool attribute) (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) active() (celery.app.control.Inspect method) active_queues control active_queues() (celery.app.control.Inspect method) active_requests (in module celery.worker.state) add() (celery.app.amqp.Queues method) (celery.beat.Scheduler method) (celery.bin.base.Extensions method) (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) (hub method) add_append_opt() (celery.bin.base.Command method) add_cert() (celery.security.certificate.CertStore method) add_compat() (celery.app.amqp.Queues method) add_consumer control add_consumer() (celery.app.control.Control method) add_defaults() (celery.Celery method) (celery.datastructures.ConfigurationView method) add_events() (celery.worker.autoreload.KQueueMonitor method) add_queue() (celery.backends.amqp.AMQPBackend.Consumer method) add_queue_from_dict() (celery.backends.amqp.AMQPBackend.Consumer method) add_reader() (hub method) add_task_queue() (celery.worker.consumer.Consumer method) add_writer() (hub method) adjust_timestamp() (in module celery.utils.timeutils) ADMINS setting 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) alert() (celery.events.cursesmon.CursesMonitor method) alert_remote_control_reply() (celery.events.cursesmon.CursesMonitor method) alias (celery.bootsteps.Blueprint attribute) (celery.bootsteps.Step attribute) alive (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) alive_workers() (celery.events.state.State method) ALL_STATES state already_setup (celery.app.log.Logging attribute) AlreadyRegistered alt (celery.app.defaults.Option attribute) ALWAYS_TYPED_ACTIONS (celery.bin.base.Option attribute) AlwaysEagerIgnored amqp (celery.bin.amqp.AMQShell attribute), [1] (celery.Celery attribute) AMQP (class in celery.app.amqp) amqp (class in celery.bin.amqp) AMQPAdmin (class in celery.bin.amqp) AMQPBackend (class in celery.backends.amqp) AMQPBackend.BacklogLimitExceeded AMQPBackend.Consumer (class in celery.backends.amqp)

AMQPBackend.Consumer.ContentDisallowed AMQPBackend.Exchange (class in celery.backends.amqp) AMQPBackend.Producer (class in celery.backends.amqp) AMQShell (class in celery.bin.amqp) annotate() (celery.app.annotations.MapAnnotation method) annotate_any() (celery.app.annotations.MapAnnotation method) app, [1] (celery.app.control.Inspect attribute) (celery.apps.beat.Beat attribute) (celery.events.EventDispatcher attribute) (celery.events.EventReceiver attribute) (celery.result.AsyncResult attribute) (celery.result.ResultSet attribute) (celery.schedules.crontab attribute) (celery.schedules.schedule attribute) (celery.worker.WorkController attribute) (celery.worker.job.Request attribute) app_or_default() (in module celery.app) AppLoader (class in celery.loaders.app) apply apply() (celery.app.task.Task method) (celery.bootsteps.Blueprint method) (celery.signature method) apply_async() (celery.app.task.Task method) (celery.beat.Scheduler method) (celery.concurrency.base.BasePool method) (celery.signature method) apply_buffer() (celery.contrib.batches.Batches method) apply_chord() (celery.backends.base.BaseBackend method) apply_eta_task() (celery.worker.consumer.Consumer method) apply_target() (in module celery.concurrency.base) appstr() (in module celery.app.utils) args (celery.beat.ScheduleEntry attribute) (celery.bin.base.Command attribute) (celery.bin.graph.graph attribute) (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) (celery.worker.job.Request attribute) arguments (celery.backends.amqp.AMQPBackend.Exchange attribute) as_dict() (celery.datastructures.LimitedSet method) (celery.events.state.State.Task method) (celery.events.state.Task method) as_tuple() (celery.result.AsyncResult method) (celery.result.GroupResult method) as_uri() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.DisabledBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cassandra.CassandraBackend method) (celery.backends.mongodb.MongoBackend method) (celery.backends.rpc.RPCBackend method) ask() (celery.bin.base.Command method) 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) AttributeDict (class in celery.datastructures) AttributeDictMixin (class in celery.datastructures) attrs (celery.backends.amqp.AMQPBackend.Exchange attribute) ATTRS (celery.bin.base.Option attribute) auto_declare (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.backends.rpc.RPCBackend.Consumer attribute) auto_delete (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] autodiscover_tasks() (celery.Celery method) (celery.loaders.base.BaseLoader method) autoregister (celery.app.task.Task attribute) autoreloader Autoreloader (class in celery.worker.autoreload) autoscale() (celery.app.control.Control method) autoscaler Autoscaler (class in celery.worker.autoscale) available (celery.utils.sysinfo.df attribute) AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY

B

backend (celery.app.task.Task attribute) (Task attribute) (celery.Celery attribute) (celery.result.AsyncResult attribute) (celery.result.ResultSet attribute) background (celery.events.cursesmon.CursesMonitor attribute) BacklogLimitExceeded BaseBackend (class in celery.backends.base) BaseBackend.TimeoutError BaseLoader (class in celery.loaders.base) BaseMonitor (class in celery.worker.autoreload) BasePool (class in celery.concurrency.base) BasePool.Timer (class in celery.concurrency.base) BasePool.Timer.Entry (class in celery.concurrency.base) Batches (class in celery.contrib.batches) Beat (celery.Celery attribute) (class in celery.apps.beat) beat (class in celery.bin.beat) Beat (class in celery.worker.components) Beat.Service (class in celery.apps.beat) beat_embedded_init signal beat_init signal before_task_publish signal bgThread (class in celery.utils.threads) billiard bind() (queue method) bind_to() (celery.backends.amqp.AMQPBackend.Exchange method) binding (celery.backends.rpc.RPCBackend attribute) binding() (celery.backends.amqp.AMQPBackend.Exchange method) black() (celery.utils.term.colored method) blink() (celery.utils.term.colored method) BlockingPool (celery.concurrency.prefork.TaskPool attribute) blue() (celery.utils.term.colored method) blueprint, [1] (celery.worker.WorkController attribute) Blueprint (class in celery.bootsteps) body (celery.utils.mail.ErrorMail attribute) body() (celery.utils.threads.bgThread method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoscale.Autoscaler method)

bold() (celery.utils.term.colored method) bootsteps() (celery.bin.graph.graph method) bright() (celery.utils.term.colored method) broadcast() (celery.app.control.Control method) BROKER_BACKEND (celery.app.utils.Settings attribute) 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_TRANSPORT setting BROKER_TRANSPORT (celery.app.utils.Settings attribute) BROKER_TRANSPORT_OPTIONS setting BROKER_URL setting BROKER_URL (celery.app.utils.Settings attribute) BROKER_USE_SSL setting bucket (celery.backends.couchbase.CouchBaseBackend attribute) bucket_for_task() (celery.worker.consumer.Consumer method) (consumer method) bugreport() (celery.Celery method) (in module celery.app.utils) build_graph() (celery.result.AsyncResult method) build_tracer() (in module celery.app.trace) builtin_modules (celery.loaders.base.BaseLoader attribute) builtins (celery.bin.amqp.AMQShell attribute)

C

C_FAKEFORK, [1], [2], [3] C_IMPDEBUG 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_repeatedly() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) call_task() (celery.worker.consumer.Gossip method) callbacks (celery.backends.amqp.AMQPBackend.Consumer attribute) calling can_cache_declaration (celery.backends.amqp.AMQPBackend.Exchange attribute) cancel() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.base.BasePool.Timer.Entry method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.events.snapshot.Polaroid method) (celery.utils.timer2.Entry method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Entry method) cancel_by_queue() (celery.backends.amqp.AMQPBackend.Consumer method) cancel_consumer control cancel_consumer() (celery.app.control.Control method) cancel_task_queue() (celery.worker.consumer.Consumer method) (consumer method) cancelled (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) capacity (celery.utils.sysinfo.df attribute) capture() (celery.events.EventReceiver method) (celery.events.snapshot.Polaroid method) carp() (celery.bin.multi.MultiTool method) CASSANDRA_COLUMN_FAMILY setting CASSANDRA_DETAILED_MODE setting CASSANDRA_KEYSPACE setting CASSANDRA_READ_CONSISTENCY setting CASSANDRA_SERVERS setting CASSANDRA_WRITE_CONSISTENCY setting CassandraBackend (class in celery.backends.cassandra) cast() (celery.app.control.Control.Mailbox method) CDeprecationWarning Celery (class in celery) celery (module) celery-beat command line option --detach --max-interval -S, --scheduler -f, --logfile -l, --loglevel -s, --schedule celery-events command line option --detach -F, --freq, --frequency -c, --camera -d, --dump -l, --loglevel -r, --maxrate celery-worker command line option --autoreload --autoscale --heartbeat-interval --maxtasksperchild --no-execv --pidfile --purge --scheduler --soft-time-limit --time-limit --without-gossip --without-heartbeat --without-mingle -B, --beat -E, --events -I, --include -O -P, --pool -Q, --queues -S, --statedb -c, --concurrency -f, --logfile -l, --loglevel -n, --hostname -s, --schedule celery._state (module) celery.app (module) celery.app.amqp (module) celery.app.annotations (module) celery.app.builtins (module) celery.app.control (module) celery.app.defaults (module) celery.app.log (module) celery.app.registry (module) celery.app.routes (module) celery.app.task (module) celery.app.trace (module) celery.app.utils (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.couchbase (module) celery.backends.database (module) celery.backends.database.models (module) celery.backends.database.session (module) celery.backends.mongodb (module) celery.backends.redis (module) celery.backends.rpc (module) celery.beat (module) celery.bin.amqp (module) celery.bin.base (module) celery.bin.beat (module) celery.bin.celery (module) celery.bin.events (module) celery.bin.graph (module) celery.bin.multi (module) celery.bin.worker (module) celery.bootsteps (module) celery.concurrency (module) celery.concurrency.base (module) celery.concurrency.eventlet (module) celery.concurrency.gevent (module) celery.concurrency.prefork (module) celery.concurrency.solo (module) celery.concurrency.threads (module) celery.contrib.abortable (module) celery.contrib.batches (module) celery.contrib.methods (module) celery.contrib.migrate (module) celery.contrib.rdb (module) celery.contrib.sphinx (module) celery.datastructures (module) celery.events (module) celery.events.cursesmon (module) celery.events.dumper (module) celery.events.snapshot (module) celery.events.state (module) celery.exceptions (module) celery.loaders (module) celery.loaders.app (module) celery.loaders.base (module) celery.loaders.default (module) celery.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.task.base (module) celery.task.http (module), [1] celery.utils (module) celery.utils.compat (module) celery.utils.debug (module) celery.utils.dispatch (module) celery.utils.dispatch.saferef (module) celery.utils.dispatch.signal (module) celery.utils.functional (module) celery.utils.imports (module) celery.utils.iso8601 (module) celery.utils.log (module) celery.utils.mail (module) celery.utils.objects (module) celery.utils.serialization (module) celery.utils.sysinfo (module) celery.utils.term (module) celery.utils.text (module) celery.utils.threads (module) celery.utils.timer2 (module) celery.utils.timeutils (module) celery.worker (module) celery.worker.autoreload (module) celery.worker.autoscale (module) celery.worker.components (module) celery.worker.consumer (module) celery.worker.control (module) celery.worker.heartbeat (module) celery.worker.job (module) celery.worker.loops (module) celery.worker.pidbox (module) celery.worker.state (module) celery.worker.strategy (module) CELERY_ACCEPT_CONTENT setting CELERY_ACKS_LATE setting CELERY_ALWAYS_EAGER setting CELERY_ANNOTATIONS setting CELERY_BENCH CELERY_BROADCAST_EXCHANGE setting CELERY_BROADCAST_EXCHANGE_TYPE setting CELERY_BROADCAST_QUEUE setting CELERY_BROKER_URL CELERY_CACHE_BACKEND setting CELERY_CACHE_BACKEND_OPTIONS setting CELERY_CHDIR CELERY_CHORD_PROPAGATES setting CELERY_CONFIG_MODULE, [1], [2] CELERY_COUCHBASE_BACKEND_SETTINGS setting CELERY_CREATE_DIRS 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_ENABLE_REMOTE_CONTROL setting CELERY_ENABLE_UTC setting CELERY_EVENT_QUEUE_EXPIRES setting CELERY_EVENT_QUEUE_TTL setting CELERY_EVENT_SERIALIZER setting CELERY_IGNORE_RESULT setting CELERY_IMPORTS setting CELERY_INCLUDE setting CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_MAX_CACHED_RESULTS setting CELERY_MESSAGE_COMPRESSION setting CELERY_MONGODB_BACKEND_SETTINGS setting CELERY_QUEUE_HA_POLICY setting CELERY_QUEUES setting CELERY_RDB_HOST CELERY_RDB_PORT CELERY_RDBSIG CELERY_REDIRECT_STDOUTS setting CELERY_REDIRECT_STDOUTS_LEVEL setting CELERY_REDIS_MAX_CONNECTIONS setting CELERY_RESULT_BACKEND setting CELERY_RESULT_BACKEND (celery.app.utils.Settings attribute) CELERY_RESULT_DB_SHORT_LIVED_SESSIONS setting CELERY_RESULT_DB_TABLENAMES 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_SECURITY_CERT_STORE setting CELERY_SECURITY_CERTIFICATE setting CELERY_SECURITY_KEY 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_PUBLISH_RETRY setting CELERY_TASK_PUBLISH_RETRY_POLICY setting CELERY_TASK_RESULT_EXPIRES setting CELERY_TASK_SERIALIZER setting CELERY_TIMEZONE setting CELERY_TIMEZONE (celery.app.utils.Settings attribute) CELERY_TRACE_APP, [1], [2] CELERY_TRACK_STARTED setting CELERY_WORKER_DIRECT setting CELERYBEAT_MAX_LOOP_INTERVAL setting CELERYBEAT_SCHEDULE setting CELERYBEAT_SCHEDULE_FILENAME setting CELERYBEAT_SCHEDULER setting CELERYBEAT_SYNC_EVERY setting CeleryCommand (class in celery.bin.celery) celeryd_after_setup signal CELERYD_AUTORELOADER setting CELERYD_AUTOSCALER setting CELERYD_CONCURRENCY setting CELERYD_CONSUMER setting CELERYD_FSNOTIFY, [1] CELERYD_HIJACK_ROOT_LOGGER setting celeryd_init signal CELERYD_LOG_COLOR setting CELERYD_LOG_FORMAT setting CELERYD_MAX_TASKS_PER_CHILD setting CELERYD_POOL setting CELERYD_POOL_RESTARTS 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 CELERYD_TIMER setting CELERYD_TIMER_PRECISION setting CELERYD_WORKER_LOST_WAIT setting CELERYMON_LOG_FORMAT setting Certificate (class in celery.security.certificate) CertStore (class in celery.security.certificate) chain (class in celery) chan (celery.bin.amqp.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) check_args() (celery.bin.base.Command method) CHECK_METHODS (celery.bin.base.Option attribute) check_value() (celery.bin.base.Option method) children (celery.result.AsyncResult attribute) (celery.result.GroupResult attribute) chord (class in celery) chord_error_from_stack() (celery.backends.base.BaseBackend method) chord_keyprefix (celery.backends.base.KeyValueStoreBackend attribute) ChordError chunks() (celery.app.task.Task method) (in module celery.utils.functional) cipater claim_steps() (celery.bootsteps.Blueprint method) cleanup() (celery.backends.base.BaseBackend method) (celery.backends.database.DatabaseBackend method) (celery.backends.mongodb.MongoBackend method) (celery.events.snapshot.Polaroid method) (celery.utils.threads.LocalManager method) cleanup_signal (celery.events.snapshot.Polaroid attribute) clear() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.eventlet.TaskPool.Timer.Schedule method) (celery.concurrency.gevent.TaskPool.Timer.Schedule method) (celery.datastructures.ConfigurationView method) (celery.datastructures.LimitedSet method) (celery.events.state.State method) (celery.result.ResultSet method) (celery.utils.timer2.Timer method) clear_after (celery.events.snapshot.Polaroid attribute) clear_tasks() (celery.events.state.State method) client (celery.backends.cache.CacheBackend attribute) (celery.backends.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.signature method) CLOSE (celery.concurrency.base.BasePool attribute) close() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.Celery method) (celery.backends.amqp.AMQPBackend.Producer method) (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) (celery.bootsteps.Blueprint method) (celery.bootsteps.StartStopStep method) (celery.concurrency.base.BasePool method) (celery.events.EventDispatcher method) (celery.platforms.DaemonContext method) (celery.utils.log.LoggingProxy method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.components.Pool method) (celery.worker.state.Persistent method) close_open_fds() (in module celery.platforms) closed (celery.utils.log.LoggingProxy attribute) cmdline_config_parser() (celery.loaders.base.BaseLoader method) coerce() (celery.bin.amqp.Spec method) collect() (celery.result.AsyncResult method) collection (celery.backends.mongodb.MongoBackend attribute) colored (celery.bin.base.Command attribute) (celery.bin.multi.MultiTool attribute) (class in celery.utils.term) colored() (celery.app.log.Logging method) ColorFormatter (class in celery.utils.log) COLORS (celery.utils.log.ColorFormatter attribute) colors (celery.utils.log.ColorFormatter attribute) column_family (celery.backends.cassandra.CassandraBackend attribute) Command (class in celery.bin.base) command line option --config --executable --gid --loader --pidfile --uid --umask --workdir -A, --app -b, --broker -f, --logfile Command.Error Command.UsageError commands (celery.bin.celery.CeleryCommand attribute) compatible_transport() (celery.worker.consumer.Gossip method) (celery.worker.consumer.Mingle method) compatible_transports (celery.worker.consumer.Gossip attribute) (celery.worker.consumer.Mingle attribute) completed_count() (celery.result.ResultSet method) completenames() (celery.bin.amqp.AMQShell method) compress() (celery.worker.state.Persistent method) compression (celery.backends.amqp.AMQPBackend.Producer attribute) (Task attribute) conditional (celery.bootsteps.Step attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.components.Beat attribute) (celery.worker.consumer.Agent attribute) conf (celery.Celery attribute) (celery.loaders.base.BaseLoader attribute) conf() (celery.app.control.Inspect method) config_from_object() (celery.Celery method) (celery.loaders.base.BaseLoader method) ConfigurationView (class in celery.datastructures) configured (celery.loaders.base.BaseLoader attribute) conn (celery.bin.amqp.AMQShell attribute) conncache (celery.backends.couchbase.CouchBaseBackend attribute) connect() (celery.bin.amqp.AMQPAdmin method) (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) (celery.worker.consumer.Consumer method) connect_on_app_finalize() (in module celery._state) connect_with() (celery.bootsteps.Blueprint method) connection Connection (celery.app.amqp.AMQP attribute) connection (celery.app.control.Control.Mailbox attribute) (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.backends.couchbase.CouchBaseBackend attribute) (celery.beat.Scheduler attribute) (celery.events.EventReceiver attribute) Connection (class in celery.worker.consumer) connection() (celery.Celery method) connection_errors (celery.worker.job.Request attribute) connection_or_acquire() (celery.Celery method) ConnectionPool (celery.backends.redis.RedisBackend attribute) CONST_ACTIONS (celery.bin.base.Option attribute) consume() (celery.backends.amqp.AMQPBackend method) (celery.backends.amqp.AMQPBackend.Consumer method) consume_from (celery.app.amqp.Queues attribute) Consumer (celery.app.amqp.AMQP attribute) consumer (celery.worker.pidbox.Pidbox attribute) Consumer (class in celery.worker.components) (class in celery.worker.consumer) Consumer.Blueprint (class in celery.worker.consumer) consumers (celery.bootsteps.ConsumerStep attribute) ConsumerStep (class in celery.bootsteps) consuming_from() (celery.backends.amqp.AMQPBackend.Consumer method) context control active_queues add_consumer cancel_consumer disable_events enable_events ping pool_restart rate_limit revoke shutdown control (celery.Celery attribute) Control (class in celery.app.control) (class in celery.worker.consumer) Control.Mailbox (class in celery.app.control) controller convert_value() (celery.bin.base.Option method) correlation_id (celery.worker.job.Request attribute) CouchBaseBackend (class in celery.backends.couchbase) count (celery.contrib.migrate.State attribute) counter (celery.bin.amqp.AMQShell attribute) CPendingDeprecationWarning create() (celery.bootsteps.Step method) (celery.worker.autoreload.WorkerComponent 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.Queues method) (celery.worker.components.StateDB method) (celery.worker.components.Timer method) (celery.worker.consumer.Agent method) create_exception_cls() (in module celery.utils.serialization) create_notifier() (celery.worker.autoreload.InotifyMonitor method) create_parser() (celery.bin.base.Command method) create_pidlock() (in module celery.platforms) create_session() (celery.backends.database.session.SessionManager method) create_task_handler() (celery.worker.consumer.Consumer method) crontab (class in celery.schedules) crontab_parser (class in celery.schedules) crontab_parser.ParseException cry() (in module celery.utils) current_app (in module celery) current_task (celery.Celery attribute) (in module celery) current_task_children() (celery.backends.base.BaseBackend method) CursesMonitor (class in celery.events.cursesmon) cwd_in_path() (in module celery.utils.imports) cyan() (celery.utils.term.colored method)

D

daemon_options() (in module celery.bin.base) DaemonContext (class in celery.platforms) data (celery.worker.control.Panel attribute) database (celery.backends.mongodb.MongoBackend attribute) database_name (celery.backends.mongodb.MongoBackend attribute) DatabaseBackend (class in celery.backends.database) date_done (celery.backends.database.models.Task attribute) (celery.backends.database.models.TaskSet attribute) day_of_month (celery.schedules.crontab attribute) day_of_week (celery.schedules.crontab attribute) db (celery.backends.redis.RedisBackend attribute) (celery.worker.state.Persistent attribute) debugger() (in module celery.contrib.rdb) declare() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Producer method) (queue method) decode() (celery.backends.base.BaseBackend method) decode_result() (celery.backends.base.BaseBackend method) decompress() (celery.worker.state.Persistent method) dedent() (in module celery.utils.text) dedent_initial() (in module celery.utils.text) default() (celery.bin.amqp.AMQShell method) (in module celery.worker.strategy) default_app (in module celery.app) default_dispatcher() (celery.events.Events method) default_exchange (celery.app.amqp.AMQP attribute) default_loader (in module celery.app) default_nodename() (in module celery.worker) default_queue (celery.app.amqp.AMQP attribute) default_retry_delay (celery.app.task.Task attribute) (Task attribute) default_socket_timeout() (in module celery.utils.threads) default_steps (celery.bootsteps.Blueprint attribute) (celery.worker.WorkController.Blueprint attribute) (celery.worker.consumer.Consumer.Blueprint attribute) defaults (celery.datastructures.ConfigurationView attribute) delay() (celery.app.task.Task method) (celery.signature method) delete() (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.couchbase.CouchBaseBackend method) (celery.backends.redis.RedisBackend method) (celery.result.GroupResult method) (exchange method) (queue method) delete_group() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) deleter() (celery.utils.cached_property method) delivery_info (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.Request attribute)

delivery_mode (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] delta_resolution() (in module celery.utils.timeutils) deprecate_by (celery.app.defaults.Option attribute) deprecated() (in module celery.utils) description (celery.bin.base.Command attribute) deselect() (celery.app.amqp.Queues method) deserialize() (celery.security.serialization.SecureSerializer method) destination_for() (celery.backends.amqp.AMQPBackend method) (celery.backends.rpc.RPCBackend method) detached() (in module celery.platforms) detailed_mode (celery.backends.cassandra.CassandraBackend attribute) df (class in celery.utils.sysinfo) DictAttribute (class in celery.datastructures) dictfilter() (in module celery.utils.functional) did_start_ok() (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) die() (celery.bin.base.Command method) disable() (celery.events.EventDispatcher method) disable_events control disable_events() (celery.app.control.Control method) disable_trace() (in module celery.app) DISABLED_TRANSPORTS (celery.events.EventDispatcher attribute) DisabledBackend (class in celery.backends.base) discard() (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) discard_all() (celery.app.control.Control method) disconnect() (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) dispatch() (celery.bin.amqp.AMQShell method) (celery.task.http.HttpDispatch method) Dispatcher (celery.events.Events attribute) dispatcher (celery.task.http.URL attribute) display_command_help() (celery.bin.amqp.AMQShell method) display_height (celery.events.cursesmon.CursesMonitor attribute) display_task_row() (celery.events.cursesmon.CursesMonitor method) display_width (celery.events.cursesmon.CursesMonitor attribute) DJANGO_SETTINGS_MODULE, [1], [2], [3], [4] do_exit() (celery.bin.amqp.AMQShell method) do_help() (celery.bin.amqp.AMQShell method) doc (celery.bin.base.Command attribute) (celery.bin.beat.beat attribute) (celery.bin.events.events attribute) (celery.bin.worker.worker attribute) DOWN (celery.bin.multi.MultiTool attribute) drain_events() (celery.backends.amqp.AMQPBackend method) draw() (celery.events.cursesmon.CursesMonitor method) dst() (celery.utils.timeutils.LocalTimezone method) dump_body() (in module celery.worker.consumer) Dumper (class in celery.events.dumper) DuplicateNodenameWarning durable (celery.backends.amqp.AMQPBackend.Exchange attribute), [1]

E

eager_trace_task() (in module celery.app.trace) EagerResult (class in celery.result) early_version() (celery.bin.base.Command method) election() (celery.app.control.Control method) (celery.worker.consumer.Gossip method) EMAIL_HOST setting EMAIL_HOST_PASSWORD setting EMAIL_HOST_USER setting EMAIL_PORT setting EMAIL_SIGNATURE_SEP (celery.utils.mail.ErrorMail attribute) EMAIL_TIMEOUT setting EMAIL_USE_SSL setting EMAIL_USE_TLS setting embed() (celery.utils.term.colored method) EmbeddedService() (in module celery.beat) empty() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) enable() (celery.events.EventDispatcher method) enable_config_from_cmdline (celery.bin.base.Command attribute) (celery.bin.beat.beat attribute) (celery.bin.celery.CeleryCommand attribute) (celery.bin.worker.worker attribute) enable_events control enable_events() (celery.app.control.Control method) enable_trace() (in module celery.app) enabled (celery.bootsteps.Step attribute) encode() (celery.backends.base.BaseBackend method) encode_result() (celery.backends.base.BaseBackend method) ensure() (celery.backends.redis.RedisBackend method) ensure_2lines() (in module celery.utils.text) ensure_process_aware_logger() (in module celery.utils.log) ensure_started() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.utils.timer2.Timer method) enter() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) enter_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) Entry (celery.beat.Scheduler attribute) (class in celery.utils.timer2) environment variable AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY CELERYD_FSNOTIFY, [1] CELERY_BENCH CELERY_BROKER_URL CELERY_CHDIR CELERY_CONFIG_MODULE, [1], [2] CELERY_CREATE_DIRS CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_RDBSIG CELERY_RDB_HOST, [1] CELERY_RDB_PORT, [1] CELERY_TRACE_APP, [1], [2] C_FAKEFORK, [1], [2], [3] C_IMPDEBUG DJANGO_SETTINGS_MODULE, [1], [2], [3], [4] IRON_PROJECT_ID IRON_TOKEN MP_LOG, [1] NOSE_VERBOSE USE_FAST_LOCALS epilog (celery.bin.base.Command attribute) Error error() (celery.bin.base.Command method) (celery.bin.multi.MultiTool method) error_msg (celery.worker.job.Request attribute) ErrorMail (class in celery.utils.mail) (Task attribute) eta (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) (celery.worker.job.Request attribute) evaluate() (celery.utils.functional.lazy method) (celery.utils.functional.mlazy method)

evaluated (celery.utils.functional.mlazy attribute), [1] evcam() (in module celery.events.snapshot) evdump() (in module celery.events.dumper) event task-failed task-received task-retried task-revoked task-sent task-started task-succeeded worker-heartbeat worker-offline worker-online event (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) event() (celery.events.state.State method) (celery.events.state.State.Task method) (celery.events.state.Task method) Event() (in module celery.events) event_count (celery.events.state.State attribute) event_dispatcher event_from_message() (celery.events.EventReceiver method) EventDispatcher (class in celery.events) eventer (celery.worker.job.Request attribute) eventlet_pool_apply signal eventlet_pool_postshutdown signal eventlet_pool_preshutdown signal eventlet_pool_started signal EventReceiver (class in celery.events) events (celery.Celery attribute) (class in celery.bin.events) Events (class in celery.events) (class in celery.worker.consumer) Evloop (class in celery.worker.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.datastructures.ExceptionInfo attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task 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.control.Control.Mailbox attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) exchange_fmt (celery.app.control.Control.Mailbox attribute) execute() (celery.bin.celery.CeleryCommand method) (celery.worker.job.Request method) execute_from_commandline() (celery.bin.base.Command method) (celery.bin.celery.CeleryCommand method) (celery.bin.multi.MultiTool method) execute_using_pool() (celery.worker.job.Request method) executing exit_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) expand() (celery.bin.multi.MultiTool method) expand_destination() (celery.app.routes.Router method) expanduser() (celery.bin.base.Command method) expire() (celery.backends.base.KeyValueStoreBackend 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.job.Request attribute) ext_fmt (celery.bin.celery.CeleryCommand attribute) extend_buffer() (celery.events.EventDispatcher method) extend_with_default_kwargs() (celery.worker.job.Request method) Extensions (class in celery.bin.base) extra_info() (celery.apps.worker.Worker method)

F

fail_from_current_stack() (celery.backends.base.BaseBackend method) 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) fallback_chord_unlock() (celery.backends.base.BaseBackend method) fd_by_path() (in module celery.platforms) ffwd (class in celery.utils.timeutils) file_hash() (in module celery.worker.autoreload) fill_paragraphs() (in module celery.utils.text) filter_hidden_settings() (in module celery.app.utils) filter_types() (celery.app.registry.TaskRegistry method) filtered (celery.contrib.migrate.State attribute) finalize() (celery.Celery method) find() (in module celery.app.defaults) find_app() (celery.bin.base.Command method) (in module celery.app.utils) find_changes() (celery.worker.autoreload.StatMonitor method) 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.datastructures.ConfigurationView method) (in module celery.utils.functional) firstmethod() (in module celery.utils.functional) FixupWarning flatten() (in module celery.app.defaults) flatten_links() (celery.signature method) flatten_reply() (in module celery.app.control) flow() (celery.backends.amqp.AMQPBackend.Consumer method) flush() (celery.concurrency.base.BasePool method) (celery.contrib.batches.Batches method) (celery.events.EventDispatcher method) (celery.utils.log.LoggingProxy method)

flush_every (celery.contrib.batches.Batches attribute) flush_interval (celery.contrib.batches.Batches attribute) flush_routes() (celery.app.amqp.AMQP method) 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.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) format() (celery.app.amqp.Queues method) (celery.app.log.TaskFormatter method) (celery.utils.log.ColorFormatter method) format_arg() (celery.bin.amqp.Spec method) format_body() (celery.utils.mail.ErrorMail method) format_description() (celery.bin.base.HelpFormatter method) format_epilog() (celery.bin.base.HelpFormatter method) format_response() (celery.bin.amqp.Spec method) format_row() (celery.events.cursesmon.CursesMonitor method) format_signature() (celery.bin.amqp.Spec method) format_subject() (celery.utils.mail.ErrorMail method) format_task_event() (celery.events.dumper.Dumper method) formatException() (celery.utils.log.ColorFormatter method) freeze() (celery.signature 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_request() (celery.contrib.batches.SimpleRequest class method) FSCertStore (class in celery.security.certificate) fun (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute)

G

gen_task_name() (in module celery.utils) get() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.couchbase.CouchBaseBackend method) (celery.backends.redis.RedisBackend method) (celery.bin.multi.MultiTool method) (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) get_amqp_api_command() (celery.bin.amqp.AMQShell method) get_async() (celery.task.http.URL method) get_backend_by_url() (in module celery.backends) get_backend_cls() (in module celery.backends) get_by_parts() (celery.app.utils.Settings method) get_children() (celery.backends.base.BaseBackend method) get_cls_by_name() (celery.bin.base.Command method) get_command_info() (celery.bin.celery.CeleryCommand class method) get_consumers() (celery.bootsteps.ConsumerStep method) (celery.events.EventReceiver method) (celery.worker.consumer.Gossip method) get_current_app() (in module celery._state) get_current_task() (in module celery._state) get_current_worker_task() (in module celery._state) get_default_logger() (celery.app.log.Logging method) get_engine() (celery.backends.database.session.SessionManager method) get_errno_name() (in module celery.platforms) get_fdmax() (in module celery.platforms) get_group_meta() (celery.backends.base.BaseBackend method) 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_key_for_chord() (celery.backends.base.KeyValueStoreBackend method) get_key_for_group() (celery.backends.base.KeyValueStoreBackend method) get_key_for_task() (celery.backends.base.KeyValueStoreBackend method) get_leaf() (celery.result.AsyncResult method) get_loader_cls() (in module celery.loaders) get_logger() (in module celery.utils.log) get_many() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.DisabledBackend method) (celery.backends.base.KeyValueStoreBackend method)

get_multiprocessing_logger() (in module celery.utils.log) get_names() (celery.bin.amqp.AMQShell method) get_opt_string() (celery.bin.base.Option method) get_options() (celery.bin.base.Command method) (celery.bin.beat.beat method) (celery.bin.events.events method) (celery.bin.worker.worker method) get_or_create_task() (celery.events.state.State method) get_or_create_worker() (celery.events.state.State method) get_pickleable_etype() (in module celery.utils.serialization) get_pickleable_exception() (in module celery.utils.serialization) get_pickled_exception() (in module celery.utils.serialization) get_queue() (celery.app.control.Control.Mailbox method) get_reply_queue() (celery.app.control.Control.Mailbox method) get_result() (celery.backends.base.BaseBackend 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_serial_number() (celery.security.certificate.Certificate method) get_state() (celery.backends.base.DisabledBackend method) get_status() (celery.backends.base.BaseBackend method) (celery.backends.base.DisabledBackend method) get_task_logger() (in module celery.utils.log) get_task_meta() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) get_traceback() (celery.backends.base.BaseBackend method) (celery.backends.base.DisabledBackend method) getpids() (celery.bin.multi.MultiTool method) gossip Gossip (class in celery.worker.consumer) gPidbox (class in celery.worker.pidbox) graph (celery.result.AsyncResult attribute) (class in celery.bin.graph) GraphFormatter (celery.bootsteps.Blueprint attribute) green() (celery.utils.term.colored method) greet (celery.events.cursesmon.CursesMonitor attribute) group (class in celery) group_keyprefix (celery.backends.base.KeyValueStoreBackend attribute) GroupResult (celery.Celery attribute) (class in celery.result) grow() (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method)

H

handle_argv() (celery.bin.base.Command method) (celery.bin.celery.CeleryCommand method) handle_error_state() (celery.app.trace.TraceInfo method) handle_event() (celery.worker.autoreload.KQueueMonitor method) handle_failure() (celery.app.trace.TraceInfo method) handle_keypress() (celery.events.cursesmon.CursesMonitor method) handle_retry() (celery.app.trace.TraceInfo method) has_expired() (celery.security.certificate.Certificate method) heap_multiplier (celery.events.state.State attribute) heart Heart (class in celery.worker.consumer) (class in celery.worker.heartbeat) heartbeat_expires (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) heartbeat_expires() (in module celery.events.state) heartbeat_max (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) heartbeats (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) hello() (celery.app.control.Inspect method) help (celery.events.cursesmon.CursesMonitor attribute)

help() (celery.bin.multi.MultiTool method) help_title (celery.events.cursesmon.CursesMonitor attribute) HelpFormatter (class in celery.bin.base) host (celery.backends.couchbase.CouchBaseBackend attribute) (celery.backends.mongodb.MongoBackend attribute) (celery.backends.redis.RedisBackend attribute) host_format() (celery.bin.base.Command method) hostname, [1] (celery.contrib.batches.SimpleRequest attribute) (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) (celery.worker.job.Request attribute) hour (celery.schedules.crontab attribute) http_headers (celery.task.http.HttpDispatch attribute) HttpDispatch (class in celery.task.http) hub, [1] Hub (class in celery.worker.components) human_seconds (celery.schedules.schedule attribute) human_state() (celery.bootsteps.Blueprint method) humanize() (celery.app.utils.Settings method) (celery.exceptions.Retry method) humanize_seconds() (in module celery.utils.timeutils)

I

iblue() (celery.utils.term.colored method) icyan() (celery.utils.term.colored method) id (celery.backends.database.models.Task attribute) (celery.backends.database.models.TaskSet attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) (celery.result.AsyncResult attribute) (celery.result.GroupResult attribute) (celery.worker.job.Request attribute) idempotent identchars (celery.bin.amqp.AMQShell attribute) Ignore ignore_errno() (in module celery.platforms) ignore_result (celery.app.task.Task attribute) (Task attribute) ignored_msg (celery.worker.job.Request attribute) igreen() (celery.utils.term.colored method) imagenta() (celery.utils.term.colored method) implements_incr (celery.backends.base.KeyValueStoreBackend attribute) (celery.backends.cache.CacheBackend attribute) (celery.backends.redis.RedisBackend attribute) import_default_modules() (celery.loaders.base.BaseLoader method) import_from_cwd() (celery.loaders.base.BaseLoader method) (in module celery.utils.imports) import_module() (celery.loaders.base.BaseLoader method) import_modules signal import_task_module() (celery.loaders.base.BaseLoader method) ImproperlyConfigured in_shutdown (celery.worker.consumer.Consumer attribute) in_sighandler() (in module celery.utils.log) inc_counter (celery.bin.amqp.AMQShell attribute) 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) incr() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.redis.RedisBackend method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) indent() (in module celery.utils.text) info (celery.beat.PersistentScheduler attribute) (celery.beat.Scheduler attribute) (celery.concurrency.base.BasePool attribute) (celery.result.AsyncResult attribute) info() (celery.bin.multi.MultiTool method) (celery.bootsteps.Blueprint method) (celery.bootsteps.Step method) (celery.events.state.State.Task method) (celery.events.state.Task method) (celery.worker.WorkController method) (celery.worker.autoscale.Autoscaler method) (celery.worker.components.Pool method) (celery.worker.consumer.Connection method) (celery.worker.consumer.Tasks method) (celery.worker.job.Request method) info_str (celery.events.cursesmon.CursesMonitor attribute)

init_callback (celery.worker.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) InotifyMonitor (class in celery.worker.autoreload) inspect (celery.app.control.Control attribute) Inspect (class in celery.app.control) install() (celery.events.snapshot.Polaroid method) install_default_entries() (celery.beat.Scheduler method) install_platform_tweaks() (celery.apps.worker.Worker method) install_sync_handler() (celery.apps.beat.Beat method) instantiate() (celery.bootsteps.Step method) (in module celery.utils.imports) internal (celery.datastructures.ExceptionInfo attribute) internal_error_msg (celery.worker.job.Request attribute) InvalidResponseError InvalidTaskError ired() (celery.utils.term.colored method) IRON_PROJECT_ID IRON_TOKEN is_aborted() (celery.contrib.abortable.AbortableAsyncResult method) (celery.contrib.abortable.AbortableTask method) is_cached() (celery.backends.base.BaseBackend method) is_due() (celery.beat.ScheduleEntry method) (celery.schedules.crontab method) (celery.schedules.schedule method) is_green (celery.concurrency.base.BasePool attribute) (celery.concurrency.eventlet.TaskPool attribute) (celery.concurrency.gevent.TaskPool attribute) is_iterable() (in module celery.utils) is_list() (in module celery.utils.functional) is_locked() (celery.platforms.Pidfile method) is_naive() (in module celery.utils.timeutils) isatty() (celery.utils.log.LoggingProxy method) (in module celery.utils) items() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) iter_native() (celery.result.ResultSet method) iterate() (celery.result.ResultSet method) itercapture() (celery.events.EventReceiver method) itercerts() (celery.security.certificate.CertStore method) iterdeps() (celery.result.AsyncResult method) iteritems() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) iterkeys() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) itertasks() (celery.events.state.State method) itervalues() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) iwhite() (celery.utils.term.colored method) iyellow() (celery.utils.term.colored method)

J

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

join_native() (celery.result.ResultSet method) jsonify() (in module celery.utils)

K

key_t() (celery.backends.base.KeyValueStoreBackend method) keyalias (celery.events.cursesmon.CursesMonitor attribute) keymap (celery.events.cursesmon.CursesMonitor attribute) keys() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) keyspace (celery.backends.cassandra.CassandraBackend attribute) KeyValueStoreBackend (class in celery.backends.base) kill() (celery.bin.multi.MultiTool method)

known_suffixes (celery.beat.PersistentScheduler attribute) kombu KQueueMonitor (class in celery.worker.autoreload) kwargs (celery.beat.ScheduleEntry attribute) (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) (celery.worker.job.Request attribute)

L

label (celery.bootsteps.Step attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.components.Beat attribute) (celery.worker.components.Queues attribute) (celery.worker.consumer.Evloop attribute) (celery.worker.consumer.Gossip attribute) (celery.worker.consumer.Mingle attribute) last (celery.bootsteps.Step attribute) (celery.worker.components.Consumer attribute) (celery.worker.consumer.Evloop attribute) last_run_at (celery.beat.ScheduleEntry attribute) lazy (class in celery.utils.functional) leaf (celery.bin.base.Command attribute) limit (celery.events.cursesmon.CursesMonitor attribute) LimitedSet (class in celery.datastructures) link() (celery.signature method) link_error() (celery.signature method) list_commands() (celery.bin.celery.CeleryCommand class method) load() (celery.bin.base.Extensions method) load_average() (in module celery.utils.sysinfo) load_extension_commands() (celery.bin.celery.CeleryCommand method)

load_step() (celery.bootsteps.Blueprint method) loadavg (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) loader (celery.Celery attribute) Loader (class in celery.loaders.default) Local (class in celery.utils.threads) localize() (in module celery.utils.timeutils) LocalManager (class in celery.utils.threads) LocalStack (in module celery.utils.threads) LocalTimezone (class in celery.utils.timeutils) LockFailed log (celery.Celery attribute) logger (celery.beat.Scheduler attribute) Logging (class in celery.app.log) LoggingProxy (class in celery.utils.log) loglevel (celery.utils.log.LoggingProxy attribute) lookup_route() (celery.app.routes.Router method) loop() (celery.worker.pidbox.gPidbox method) loop_args() (celery.worker.consumer.Consumer method) lpmerge() (in module celery.utils) LRUCache (class in celery.datastructures) (class in celery.utils.functional)

M

magenta() (celery.utils.term.colored method) mail (celery.loaders.base.BaseLoader attribute) mail_admins() (celery.Celery method) (celery.loaders.base.BaseLoader method) Mailer (class in celery.utils.mail) main (celery.Celery attribute) main() (in module celery.bin.celery) (in module celery.bin.worker) maintain_pool() (celery.concurrency.base.BasePool method) make_aware() (in module celery.utils.timeutils) make_request() (celery.task.http.HttpDispatch method) map() (celery.app.task.Task method) MapAnnotation (class in celery.app.annotations) MapRoute (class in celery.app.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.functional) max_connections (celery.backends.redis.RedisBackend attribute) max_interval (celery.beat.Scheduler attribute) max_pool_size (celery.backends.mongodb.MongoBackend attribute) max_retries (celery.app.task.Task attribute) (Task attribute) MaxRetriesExceededError maybe_declare() (celery.backends.amqp.AMQPBackend.Producer method) maybe_detach() (celery.bin.worker.worker method) maybe_drop_privileges() (in module celery.platforms) maybe_due() (celery.beat.Scheduler method) maybe_evaluate() (in module celery.utils.functional) maybe_expire() (celery.worker.job.Request method) maybe_iso8601() (in module celery.utils.timeutils) maybe_list() (in module celery.utils.functional) maybe_make_aware() (celery.schedules.schedule method) (in module celery.utils.timeutils) maybe_patch_concurrency() (celery.bin.base.Command method) maybe_reraise() (celery.result.AsyncResult method) (celery.result.ResultSet method) (in module celery.utils) maybe_s_to_ms() (in module celery.utils.timeutils) maybe_scale() (celery.worker.autoscale.Autoscaler method) maybe_schedule() (in module celery.schedules) maybe_shutdown() (in module celery.worker.state)

maybe_timedelta() (in module celery.utils.timeutils) mem_rss() (in module celery.utils.debug) memdump() (celery.app.control.Inspect method) (in module celery.utils.debug) memoize() (in module celery.utils.functional) memsample() (celery.app.control.Inspect method) merge() (celery.events.state.State.Task method) (celery.events.state.Task method) (celery.worker.state.Persistent method) merge_inplace() (celery.beat.Scheduler method) merge_rules (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) message (celery.exceptions.Retry attribute) Message (class in celery.utils.mail) Message() (celery.backends.amqp.AMQPBackend.Exchange method) meta_from_decoded() (celery.backends.base.BaseBackend method) method (in module celery.task.http) mget() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.couchbase.CouchBaseBackend 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) minute (celery.schedules.crontab attribute) mlazy (class in celery.utils.functional) mlevel() (in module celery.utils.log) mode (celery.utils.log.LoggingProxy attribute) module_file() (in module celery.utils.imports) MongoBackend (class in celery.backends.mongodb) Monitor (celery.worker.autoreload.Autoreloader attribute) (in module celery.worker.autoreload) month_of_year (celery.schedules.crontab attribute) move() (in module celery.contrib.migrate) move_by_idmap() (in module celery.contrib.migrate) move_by_taskmap() (in module celery.contrib.migrate) move_selection() (celery.events.cursesmon.CursesMonitor method) move_selection_down() (celery.events.cursesmon.CursesMonitor method) move_selection_up() (celery.events.cursesmon.CursesMonitor method) move_task_by_id() (in module celery.contrib.migrate) MP_LOG, [1] mro_lookup() (in module celery.utils.objects) multi_call() (celery.app.control.Control.Mailbox method) MultiTool (class in celery.bin.multi)

N

name (celery.app.task.Task attribute) (Task attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] (celery.beat.ScheduleEntry attribute) (celery.bootsteps.Blueprint attribute) (celery.bootsteps.ConsumerStep attribute) (celery.bootsteps.StartStopStep attribute) (celery.bootsteps.Step attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) (celery.utils.log.LoggingProxy attribute) (celery.worker.WorkController.Blueprint attribute) (celery.worker.autoreload.WorkerComponent 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.Queues attribute) (celery.worker.components.StateDB attribute) (celery.worker.components.Timer attribute) (celery.worker.consumer.Agent attribute) (celery.worker.consumer.Connection attribute) (celery.worker.consumer.Consumer.Blueprint attribute) (celery.worker.consumer.Control attribute) (celery.worker.consumer.Events attribute) (celery.worker.consumer.Evloop attribute) (celery.worker.consumer.Gossip attribute) (celery.worker.consumer.Heart attribute) (celery.worker.consumer.Mingle attribute) (celery.worker.consumer.Tasks attribute) (celery.worker.job.Request attribute) names() (celery.bin.multi.MultiTool method) namespace (celery.app.control.Control.Mailbox attribute) (celery.bin.base.Command attribute) (celery.bin.celery.CeleryCommand attribute) (celery.bin.worker.worker attribute)

nap() (celery.events.cursesmon.CursesMonitor method) needs_reconnect (celery.bin.amqp.AMQShell attribute) new_missing() (celery.app.amqp.Queues method) next() (celery.beat.ScheduleEntry method) (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) no_ack (celery.backends.amqp.AMQPBackend.Consumer attribute) no_color (celery.bin.base.Command attribute) no_color() (celery.utils.term.colored method) Node() (celery.app.control.Control.Mailbox method) node() (celery.utils.term.colored method) node_alive() (celery.bin.multi.MultiTool method) node_cls (celery.app.control.Control.Mailbox attribute) node_format() (celery.bin.base.Command method) nodename() (in module celery.utils) nodesplit() (in module celery.utils) noop() (in module celery.utils.functional) NOSE_VERBOSE NotAPackage NotConfigured note() (celery.bin.amqp.AMQPAdmin method) (celery.bin.amqp.AMQShell method) (celery.bin.multi.MultiTool method) NotRegistered now() (celery.Celery method) (celery.loaders.base.BaseLoader method) (celery.schedules.crontab method) (celery.schedules.schedule method) nowfun (celery.schedules.crontab attribute) nullipotent num_processes (celery.concurrency.base.BasePool attribute) (celery.concurrency.gevent.TaskPool attribute) (celery.concurrency.prefork.TaskPool attribute)

O

obj (celery.bootsteps.StartStopStep attribute) (celery.datastructures.DictAttribute attribute) objgraph() (celery.app.control.Inspect method) oid (celery.app.control.Control.Mailbox attribute) (celery.backends.rpc.RPCBackend attribute) OK (celery.bin.multi.MultiTool attribute) on_accepted() (celery.worker.job.Request method) on_ack (celery.worker.job.Request attribute) on_after_init() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_apply() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.threads.TaskPool method) on_before_init() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_bound() (celery.app.task.Task class method) on_change() (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) on_chord_part_return() (celery.backends.base.BaseBackend method) (celery.backends.base.KeyValueStoreBackend method) on_cleanup() (celery.events.snapshot.Polaroid method) on_close() (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) (celery.worker.WorkController method) (celery.worker.consumer.Consumer method) on_concurrency_setup() (celery.bin.base.Command method) (celery.bin.celery.CeleryCommand method) on_configure() (celery.Celery method) on_connection_error() (celery.backends.redis.RedisBackend method) on_consume_ready() (celery.events.EventReceiver method) on_consumer_ready() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_crash() (celery.utils.threads.bgThread method) on_decode_error (celery.backends.amqp.AMQPBackend.Consumer attribute) on_decode_error() (celery.worker.consumer.Consumer method) on_disabled (celery.events.EventDispatcher attribute) on_elect() (celery.worker.consumer.Gossip method) on_elect_ack() (celery.worker.consumer.Gossip method) on_enabled (celery.events.EventDispatcher attribute) on_error() (celery.bin.base.Command method) on_event() (celery.events.dumper.Dumper method) on_event_loop_close() (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) on_failed() (celery.events.state.State.Task method) (celery.events.state.Task method) on_failure() (celery.app.task.Task method) (celery.worker.job.Request method) on_hard_timeout() (celery.concurrency.base.BasePool method) on_heartbeat() (celery.events.state.State.Worker method) (celery.events.state.Worker method) on_init() (celery.worker.autoreload.Autoreloader method) on_init_blueprint() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_invalid_task() (celery.worker.consumer.Consumer method) on_message (celery.backends.amqp.AMQPBackend.Consumer attribute) on_message() (celery.worker.consumer.Gossip method) (celery.worker.pidbox.Pidbox method) on_node_join() (celery.worker.consumer.Gossip method) on_node_leave() (celery.worker.consumer.Gossip method) on_node_lost() (celery.worker.consumer.Gossip method) on_offline() (celery.events.state.State.Worker method) (celery.events.state.Worker method) on_online() (celery.events.state.State.Worker method) (celery.events.state.Worker method) on_process_cleanup() (celery.loaders.base.BaseLoader method) on_readable() (celery.worker.autoreload.InotifyMonitor method) on_ready() (celery.worker.consumer.Consumer method)

on_received() (celery.events.state.State.Task method) (celery.events.state.Task method) on_reject (celery.worker.job.Request attribute) on_reply_declare() (celery.backends.amqp.AMQPBackend method) (celery.backends.rpc.RPCBackend method) on_retried() (celery.events.state.State.Task method) (celery.events.state.Task method) on_retry() (celery.app.task.Task method) (celery.worker.job.Request method) on_return (celery.backends.amqp.AMQPBackend.Producer attribute) on_revoked() (celery.events.state.State.Task method) (celery.events.state.Task method) on_sent() (celery.events.state.State.Task method) (celery.events.state.Task 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.concurrency.threads.TaskPool method) (celery.worker.WorkController method) on_started() (celery.events.state.State.Task method) (celery.events.state.Task 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.threads.TaskPool method) (celery.worker.pidbox.Pidbox method) (celery.worker.pidbox.gPidbox method) on_stopped() (celery.worker.WorkController method) on_succeeded() (celery.events.state.State.Task method) (celery.events.state.Task method) on_success() (celery.app.task.Task method) (celery.worker.job.Request method) on_task_call() (celery.backends.base.BaseBackend 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.job.Request method) on_timer_error() (celery.worker.components.Timer method) on_timer_tick() (celery.worker.components.Timer method) on_unknown_event() (celery.events.state.State.Task method) (celery.events.state.Task method) on_unknown_message() (celery.worker.consumer.Consumer method) on_unknown_task() (celery.worker.consumer.Consumer method) on_usage_error() (celery.bin.base.Command method) (celery.bin.celery.CeleryCommand method) on_worker_init() (celery.loaders.base.BaseLoader method) on_worker_process_init() (celery.loaders.base.BaseLoader method) on_worker_shutdown() (celery.loaders.base.BaseLoader method) onecmd() (celery.bin.amqp.AMQShell method) online_str (celery.events.cursesmon.CursesMonitor attribute) open() (celery.platforms.DaemonContext method) (celery.worker.state.Persistent method) Option (class in celery.app.defaults) (class in celery.bin.base) option_list (celery.bin.base.Command attribute) options (celery.backends.mongodb.MongoBackend attribute) (celery.beat.ScheduleEntry attribute) origin (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) osx_proxy_detection_workaround() (celery.apps.worker.Worker method) out() (celery.bin.base.Command method) override_backends (celery.loaders.base.BaseLoader attribute)

P

padlist() (in module celery.utils.functional) Panel (class in celery.worker.control) parent (celery.result.ResultBase attribute) parse() (celery.schedules.crontab_parser method) parse_doc() (celery.bin.base.Command method) parse_gid() (in module celery.platforms) parse_iso8601() (in module celery.utils.iso8601) parse_options() (celery.bin.base.Command method) parse_preload_options() (celery.bin.base.Command method) parse_uid() (in module celery.platforms) ParseException parseline() (celery.bin.amqp.AMQShell method) Parser (celery.bin.base.Command attribute) passive (celery.backends.amqp.AMQPBackend.Exchange attribute) password (celery.backends.couchbase.CouchBaseBackend attribute) (celery.backends.mongodb.MongoBackend attribute) (celery.backends.redis.RedisBackend attribute) patch_all() (celery.worker.consumer.Evloop method) path (celery.platforms.Pidfile attribute) PENDING state PENDING (in module celery.states) periodic() (celery.app.registry.TaskRegistry method) (celery.worker.consumer.Gossip method) persistence (celery.beat.PersistentScheduler attribute) persistent (celery.backends.amqp.AMQPBackend attribute) (celery.backends.base.BaseBackend attribute) (celery.backends.rpc.RPCBackend attribute) Persistent (class in celery.worker.state) PERSISTENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute) PersistentScheduler (class in celery.beat) Pickler (celery.Celery attribute) pid (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) Pidbox (class in celery.worker.pidbox) Pidfile (class in celery.platforms) pidlock (celery.worker.WorkController attribute) ping control ping() (celery.app.control.Control method) (celery.app.control.Inspect method) pluralize() (in module celery.utils.text) Polaroid (class in celery.events.snapshot) poll() (celery.backends.amqp.AMQPBackend method) pool, [1] (celery.Celery attribute) Pool (celery.concurrency.prefork.TaskPool attribute) pool (celery.worker.consumer.Consumer attribute) (celery.worker.WorkController attribute) Pool (class in celery.worker.components) pool_grow() (celery.app.control.Control method) pool_restart control pool_shrink() (celery.app.control.Control method) pop_value() (celery.datastructures.LimitedSet method) popitem() (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) port (celery.backends.couchbase.CouchBaseBackend attribute) (celery.backends.mongodb.MongoBackend attribute) (celery.backends.redis.RedisBackend attribute)

post_async() (celery.task.http.URL method) precedence() (in module celery.states) prefetch count prefetch multiplier preload_options (celery.bin.base.Command attribute) prepare() (in module celery.app.annotations) (in module celery.app.routes) prepare_args() (celery.bin.base.Command method) (celery.worker.WorkController method) prepare_exception() (celery.backends.base.BaseBackend method) prepare_expires() (celery.backends.base.BaseBackend method) prepare_models() (celery.backends.database.session.SessionManager method) prepare_parser() (celery.bin.base.Command method) prepare_persistent() (celery.backends.base.BaseBackend method) prepare_prog_name() (celery.bin.celery.CeleryCommand method) prepare_value() (celery.backends.base.BaseBackend method) preparse_options() (celery.bin.base.Command method) pretty() (celery.bin.base.Command method) (in module celery.utils.text) pretty_dict_ok_error() (celery.bin.base.Command method) pretty_list() (celery.bin.base.Command method) PrivateKey (class in celery.security.key) process() (celery.bin.base.Option method) (celery.events.EventReceiver method) process_() (celery.worker.autoreload.InotifyMonitor method) process_cleanup() (celery.backends.base.BaseBackend method) (celery.backends.cassandra.CassandraBackend method) (celery.backends.mongodb.MongoBackend method) process_cmdline_config() (celery.bin.base.Command method) process_destructor() (in module celery.concurrency.prefork) process_IN_ATTRIB() (celery.worker.autoreload.InotifyMonitor method) process_IN_MODIFY() (celery.worker.autoreload.InotifyMonitor method) process_initializer() (in module celery.concurrency.prefork) processed (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) processes (celery.worker.autoscale.Autoscaler attribute) producer_or_acquire() (celery.Celery method) prog_name (celery.bin.base.Command attribute) (celery.bin.celery.CeleryCommand attribute) prompt (celery.bin.amqp.AMQShell attribute) prompt_fmt (celery.bin.amqp.AMQShell attribute) PROPAGATE_STATES state protocol (celery.worker.state.Persistent attribute) ps() (in module celery.utils.debug) publish() (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Producer method) (celery.events.EventDispatcher method) publisher (celery.beat.Scheduler attribute) (celery.events.EventDispatcher attribute) publisher_pool (celery.app.amqp.AMQP attribute) purge() (celery.app.control.Control method) (celery.backends.amqp.AMQPBackend.Consumer method) (celery.datastructures.LimitedSet method) purge_messages() (celery.apps.worker.Worker method) pyimplementation() (in module celery.platforms) Python Enhancement Proposals PEP 8

Q

qos qos() (celery.backends.amqp.AMQPBackend.Consumer method) qty (celery.worker.autoscale.Autoscaler attribute) qualname() (in module celery.utils.imports) query_task() (celery.app.control.Inspect method) Queue (celery.backends.amqp.AMQPBackend attribute) queue (celery.concurrency.base.BasePool.Timer attribute) (celery.concurrency.eventlet.TaskPool.Timer.Schedule attribute) (celery.concurrency.gevent.TaskPool.Timer.Schedule attribute) (celery.utils.timer2.Timer attribute)

QueueNotFound queues (celery.app.amqp.AMQP attribute) (celery.backends.amqp.AMQPBackend.Consumer attribute) Queues (class in celery.app.amqp) (class in celery.worker.components) Queues() (celery.app.amqp.AMQP method) quiet (celery.backends.couchbase.CouchBaseBackend attribute)

R

rate() (in module celery.utils.timeutils) rate_limit control rate_limit (celery.app.task.Task attribute) (Task attribute) rate_limit() (celery.app.control.Control method) Rdb (class in celery.contrib.rdb) read_configuration() (celery.loaders.base.BaseLoader method) (celery.loaders.default.Loader method) read_pid() (celery.platforms.Pidfile method) readline() (celery.events.cursesmon.CursesMonitor method) ready (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) ready() (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) READY_STATES state READY_STATES (celery.backends.base.BaseBackend attribute) rebuild_taskheap() (celery.events.state.State method) receive() (celery.backends.amqp.AMQPBackend.Consumer method) received (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) RECEIVED (in module celery.states) Receiver (celery.events.Events attribute) receivers (celery.utils.dispatch.Signal attribute) (celery.utils.dispatch.signal.Signal attribute) recover() (celery.backends.amqp.AMQPBackend.Consumer method) 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) RedisBackend (class in celery.backends.redis) reentrant regen() (in module celery.utils.functional) register() (celery.app.registry.TaskRegistry method) (celery.worker.control.Panel class method) register_auth() (in module celery.security.serialization) register_callback() (celery.backends.amqp.AMQPBackend.Consumer method) register_command() (celery.bin.celery.CeleryCommand class method) register_timer() (celery.worker.consumer.Gossip method) register_with_event_loop() (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) (celery.worker.WorkController method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.autoreload.StatMonitor method) (celery.worker.autoreload.WorkerComponent method) (celery.worker.autoscale.WorkerComponent method) (celery.worker.components.Pool method) (celery.worker.consumer.Consumer method) registered() (celery.app.control.Inspect method) registered_tasks() (celery.app.control.Inspect method) regular() (celery.app.registry.TaskRegistry method) reject() (celery.worker.job.Request method) rejected_msg (celery.worker.job.Request attribute) relative (celery.schedules.schedule attribute) release() (celery.backends.amqp.AMQPBackend.Producer method) (celery.platforms.Pidfile method) reload() (celery.worker.WorkController method) reload_from_cwd() (in module celery.utils.imports) reload_group_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) reload_task_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) remaining() (in module celery.utils.timeutils) remaining_delta() (celery.schedules.crontab method) remaining_estimate() (celery.schedules.crontab method) (celery.schedules.schedule method) RemoteExecuteError 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) replace() (celery.signature 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.job.Request attribute) report() (celery.app.control.Inspect method) repr_result() (celery.worker.job.Request method) republish() (in module celery.contrib.migrate) request (celery.app.task.Task attribute) Request (class in celery.worker.job) request (Task attribute) request_dict (celery.worker.job.Request attribute) requires (celery.bootsteps.ConsumerStep attribute) (celery.bootsteps.Step attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.components.Hub attribute) (celery.worker.components.Pool attribute) (celery.worker.components.Queues attribute) (celery.worker.consumer.Agent attribute) (celery.worker.consumer.Control attribute) (celery.worker.consumer.Events attribute) (celery.worker.consumer.Gossip attribute) (celery.worker.consumer.Heart attribute) (celery.worker.consumer.Mingle attribute) (celery.worker.consumer.Tasks attribute) reraise_errors() (in module celery.security.utils)

reserve() (celery.beat.Scheduler method) reserved() (celery.app.control.Inspect method) reserved_requests (in module celery.worker.state) reset() (celery.utils.term.colored method) (celery.worker.pidbox.Pidbox method) (celery.worker.pidbox.gPidbox method) reset_multiprocessing_logger() (in module celery.utils.log) reset_rate_limits() (celery.worker.consumer.Consumer method) (consumer method) reset_worker_optimizations() (in module celery.app.trace) resetscreen() (celery.events.cursesmon.CursesMonitor method) resolve_all() (in module celery.app.annotations) respects_app_option (celery.bin.base.Command attribute) respond() (celery.bin.amqp.AMQShell method) restart() (celery.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) restore() (celery.result.GroupResult class method) (celery.utils.serialization.UnpickleableExceptionWrapper method) restore_group() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) result (celery.backends.database.models.Task attribute) (celery.backends.database.models.TaskSet attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) result_from_tuple() (in module celery.result) ResultBase (class in celery.result) results (celery.result.GroupResult attribute) (celery.result.ResultSet attribute) ResultSession() (celery.backends.database.DatabaseBackend method) ResultSet (class in celery.result) retcode (celery.bin.multi.MultiTool attribute) retried (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) retries (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) RETRY state Retry RETRY (in module celery.states) retry() (celery.app.task.Task method) retry_msg (celery.worker.job.Request attribute) retry_policy (celery.backends.amqp.AMQPBackend attribute) (celery.backends.base.BaseBackend attribute) retval (celery.app.trace.TraceInfo attribute) reverse() (celery.utils.term.colored method) revive() (celery.backends.amqp.AMQPBackend method) (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Producer method) 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.job.Request method) rkey() (celery.backends.amqp.AMQPBackend method) (celery.backends.rpc.RPCBackend method) route() (celery.app.routes.Router method) route_for_task() (celery.app.routes.MapRoute method) router (celery.app.amqp.AMQP attribute) Router (class in celery.app.routes) Router() (celery.app.amqp.AMQP method) routes (celery.app.amqp.AMQP attribute) routing_key (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) RPCBackend (class in celery.backends.rpc) RPCBackend.Consumer (class in celery.backends.rpc) RUN (celery.concurrency.base.BasePool attribute) run() (celery.app.task.Task method) (celery.apps.beat.Beat method) (celery.bin.amqp.AMQPAdmin method) (celery.bin.amqp.amqp method) (celery.bin.base.Command method) (celery.bin.beat.beat method) (celery.bin.events.events method) (celery.bin.graph.graph method) (celery.bin.worker.worker method) (celery.concurrency.base.BasePool.Timer method) (celery.contrib.batches.Batches method) (celery.utils.threads.bgThread method) (celery.utils.timer2.Timer method) run_evcam() (celery.bin.events.events method) run_evdump() (celery.bin.events.events method) run_evtop() (celery.bin.events.events method) run_from_argv() (celery.bin.base.Command method) (celery.bin.worker.worker method) running (celery.concurrency.base.BasePool.Timer attribute) (celery.utils.timer2.Timer attribute) runtime (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) rusage() (celery.worker.WorkController method)

S

s() (celery.app.task.Task method) safe_add_str() (celery.events.cursesmon.CursesMonitor method) safe_ref() (in module celery.utils.dispatch.saferef) sample() (in module celery.utils.debug) sample_mem() (in module celery.utils.debug) save() (celery.result.GroupResult method) (celery.worker.state.Persistent method) save_group() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) say() (celery.bin.amqp.AMQShell method) (celery.bin.multi.MultiTool method) (celery.events.dumper.Dumper method) say_chat() (celery.bin.base.Command method) say_remote_command_reply() (celery.bin.base.Command method) scale_down() (celery.worker.autoscale.Autoscaler method) scale_up() (celery.worker.autoscale.Autoscaler method) schedule (celery.beat.PersistentScheduler attribute) (celery.beat.ScheduleEntry attribute) (celery.beat.Scheduler attribute) Schedule (celery.concurrency.base.BasePool.Timer attribute) (celery.utils.timer2.Timer attribute) schedule (class in celery.schedules) Schedule (in module celery.utils.timer2) scheduled() (celery.app.control.Inspect method) ScheduleEntry (class in celery.beat) scheduler (celery.apps.beat.Beat.Service attribute) (celery.beat.Service attribute) Scheduler (class in celery.beat) scheduler_cls (celery.apps.beat.Beat.Service attribute) (celery.beat.Service attribute) SchedulingError screen_delay (celery.events.cursesmon.CursesMonitor attribute) screen_height (celery.events.cursesmon.CursesMonitor attribute) screen_width (celery.events.cursesmon.CursesMonitor attribute) seconds (celery.schedules.schedule attribute) SecureSerializer (class in celery.security.serialization) SecurityError select() (celery.app.amqp.Queues method) select_add() (celery.app.amqp.Queues method) select_queues() (celery.Celery method) select_remove() (celery.app.amqp.Queues method) 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) semaphore (celery.worker.WorkController attribute) send() (celery.events.EventDispatcher method) (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) (celery.utils.mail.ErrorMail method) (celery.utils.mail.Mailer method) send_all() (celery.bootsteps.Blueprint method) send_error_emails (celery.app.task.Task attribute) (Task attribute) send_event() (celery.worker.job.Request method) send_events (celery.app.task.Task attribute) send_robust() (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) send_task() (celery.beat.Scheduler method) (celery.Celery method) SendmailWarning sent (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) serializable() (celery.result.AsyncResult method) (celery.result.GroupResult method) serialize() (celery.security.serialization.SecureSerializer method) serializer (celery.app.control.Control.Mailbox attribute) (Task attribute) (celery.app.task.Task attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) SERVER_EMAIL setting servers (celery.backends.cache.CacheBackend attribute) (celery.backends.cassandra.CassandraBackend attribute), [1] Service (class in celery.beat) session_factory() (celery.backends.database.session.SessionManager method) SessionManager (class in celery.backends.database.session) set() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.couchbase.CouchBaseBackend method) (celery.backends.redis.RedisBackend method) (celery.signature method) set_current() (celery.Celery method) set_default_app() (in module celery._state) set_in_sighandler() (in module celery.utils.log) set_mp_process_title() (in module celery.platforms) set_process_status() (celery.apps.worker.Worker method) (celery.bin.events.events method) set_process_title() (celery.apps.beat.Beat method) (in module celery.platforms) set_schedule() (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) set_trace() (in module celery.contrib.rdb) setdefault() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) setgid() (in module celery.platforms) setgroups() (in module celery.platforms) setter() (celery.utils.cached_property method) setting ADMINS 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_TRANSPORT BROKER_TRANSPORT_OPTIONS BROKER_URL BROKER_USE_SSL CASSANDRA_COLUMN_FAMILY CASSANDRA_DETAILED_MODE CASSANDRA_KEYSPACE CASSANDRA_READ_CONSISTENCY CASSANDRA_SERVERS CASSANDRA_WRITE_CONSISTENCY CELERYBEAT_MAX_LOOP_INTERVAL CELERYBEAT_SCHEDULE CELERYBEAT_SCHEDULER CELERYBEAT_SCHEDULE_FILENAME CELERYBEAT_SYNC_EVERY CELERYD_AUTORELOADER CELERYD_AUTOSCALER CELERYD_CONCURRENCY CELERYD_CONSUMER CELERYD_HIJACK_ROOT_LOGGER CELERYD_LOG_COLOR CELERYD_LOG_FORMAT CELERYD_MAX_TASKS_PER_CHILD CELERYD_POOL CELERYD_POOL_RESTARTS CELERYD_PREFETCH_MULTIPLIER CELERYD_STATE_DB CELERYD_TASK_LOG_FORMAT CELERYD_TASK_SOFT_TIME_LIMIT CELERYD_TASK_TIME_LIMIT CELERYD_TIMER CELERYD_TIMER_PRECISION CELERYD_WORKER_LOST_WAIT CELERYMON_LOG_FORMAT CELERY_ACCEPT_CONTENT CELERY_ACKS_LATE CELERY_ALWAYS_EAGER CELERY_ANNOTATIONS CELERY_BROADCAST_EXCHANGE CELERY_BROADCAST_EXCHANGE_TYPE CELERY_BROADCAST_QUEUE CELERY_CACHE_BACKEND CELERY_CACHE_BACKEND_OPTIONS CELERY_CHORD_PROPAGATES CELERY_COUCHBASE_BACKEND_SETTINGS 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_ENABLE_REMOTE_CONTROL CELERY_ENABLE_UTC CELERY_EVENT_QUEUE_EXPIRES CELERY_EVENT_QUEUE_TTL CELERY_EVENT_SERIALIZER CELERY_IGNORE_RESULT CELERY_IMPORTS CELERY_INCLUDE CELERY_MAX_CACHED_RESULTS CELERY_MESSAGE_COMPRESSION CELERY_MONGODB_BACKEND_SETTINGS CELERY_QUEUES CELERY_QUEUE_HA_POLICY CELERY_REDIRECT_STDOUTS CELERY_REDIRECT_STDOUTS_LEVEL CELERY_REDIS_MAX_CONNECTIONS CELERY_RESULT_BACKEND CELERY_RESULT_DBURI CELERY_RESULT_DB_SHORT_LIVED_SESSIONS CELERY_RESULT_DB_TABLENAMES CELERY_RESULT_ENGINE_OPTIONS CELERY_RESULT_EXCHANGE CELERY_RESULT_EXCHANGE_TYPE CELERY_RESULT_PERSISTENT CELERY_RESULT_SERIALIZER CELERY_ROUTES CELERY_SECURITY_CERTIFICATE CELERY_SECURITY_CERT_STORE CELERY_SECURITY_KEY CELERY_SEND_EVENTS CELERY_SEND_TASK_ERROR_EMAILS CELERY_SEND_TASK_SENT_EVENT CELERY_STORE_ERRORS_EVEN_IF_IGNORED CELERY_TASK_PUBLISH_RETRY CELERY_TASK_PUBLISH_RETRY_POLICY CELERY_TASK_RESULT_EXPIRES CELERY_TASK_SERIALIZER CELERY_TIMEZONE CELERY_TRACK_STARTED CELERY_WORKER_DIRECT EMAIL_HOST EMAIL_HOST_PASSWORD EMAIL_HOST_USER EMAIL_PORT EMAIL_TIMEOUT EMAIL_USE_SSL EMAIL_USE_TLS SERVER_EMAIL Settings (class in celery.app.utils) setuid() (in module celery.platforms) setup() (celery.app.log.Logging method) setup_app_from_commandline() (celery.bin.base.Command method) setup_defaults() (celery.worker.WorkController method) setup_handlers() (celery.app.log.Logging method) setup_includes() (celery.worker.WorkController method) setup_instance() (celery.worker.WorkController method) setup_logger() (celery.app.log.Logging method) setup_logging signal setup_logging() (celery.apps.beat.Beat method) (celery.apps.worker.Worker method) setup_logging_subsystem() (celery.app.log.Logging method) setup_queues() (celery.worker.WorkController method) setup_schedule() (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) setup_security() (celery.Celery method) (in module celery.security) setup_settings() (celery.loaders.default.Loader method) setup_task_loggers() (celery.app.log.Logging method) setup_worker_optimizations() (in module celery.app.trace) Shell (celery.bin.amqp.AMQPAdmin attribute) shortinfo() (celery.worker.job.Request method) should_send() (celery.app.task.Task.ErrorMail method) (celery.utils.mail.ErrorMail method)

should_sync() (celery.beat.Scheduler method) should_use_eventloop() (celery.worker.WorkController method) show() (celery.bin.multi.MultiTool method) show_body (celery.bin.base.Command attribute) show_reply (celery.bin.base.Command attribute) shrink() (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) shutdown control shutdown() (celery.bootsteps.ConsumerStep method) (celery.worker.consumer.Connection method) (celery.worker.consumer.Consumer method) (celery.worker.consumer.Consumer.Blueprint method) (celery.worker.consumer.Events method) (celery.worker.consumer.Heart method) (celery.worker.consumer.Tasks method) (celery.worker.pidbox.Pidbox method) shutdown_nodes() (celery.bin.multi.MultiTool 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 import_modules setup_logging task_failure task_postrun task_prerun task_retry task_revoked task_sent task_success user_preload_options worker_init worker_process_init worker_process_shutdown worker_ready worker_shutdown Signal (class in celery.utils.dispatch) (class in celery.utils.dispatch.signal) signal_consumer_close() (celery.worker.WorkController method) signal_node() (celery.bin.multi.MultiTool method) signal_safe (celery.concurrency.base.BasePool attribute) (celery.concurrency.eventlet.TaskPool attribute) (celery.concurrency.gevent.TaskPool attribute) signature (class in celery) signature() (celery.Celery method) SimpleRequest (class in celery.contrib.batches) soft_time_limit (celery.app.task.Task attribute) (Task attribute) SoftTimeLimitExceeded SOFTWARE_INFO (in module celery.worker.state) Spec (class in celery.bin.amqp) splash() (celery.bin.multi.MultiTool method) starmap() (celery.app.task.Task method) start() (celery.apps.beat.Beat.Service method) (celery.Celery 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.eventlet.TaskPool.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.worker.WorkController method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.autoreload.StatMonitor method) (celery.worker.components.Hub method) (celery.worker.consumer.Connection method) (celery.worker.consumer.Consumer method) (celery.worker.consumer.Events method) (celery.worker.consumer.Evloop method) (celery.worker.consumer.Gossip method) (celery.worker.consumer.Heart method) (celery.worker.consumer.Mingle method) (celery.worker.consumer.Tasks method) (celery.worker.heartbeat.Heart method) (celery.worker.pidbox.Pidbox method) (celery.worker.pidbox.gPidbox method) start_filter() (in module celery.contrib.migrate) start_scheduler() (celery.apps.beat.Beat method) STARTED state started (celery.bootsteps.Blueprint attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) STARTED (in module celery.states) StartStopStep (class in celery.bootsteps) startup_info() (celery.apps.beat.Beat method) (celery.apps.worker.Worker method) stat (celery.utils.sysinfo.df attribute) state ALL_STATES EXCEPTION_STATES FAILURE PENDING PROPAGATE_STATES READY_STATES RETRY REVOKED STARTED SUCCESS UNREADY_STATES state (celery.app.trace.TraceInfo attribute) (celery.bootsteps.Blueprint attribute) State (celery.events.Events attribute) state (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) (celery.worker.WorkController attribute) State (class in celery.contrib.migrate) (class in celery.events.state) state (class in celery.states) State.Task (class in celery.events.state) State.Worker (class in celery.events.state) state_to_name (celery.bootsteps.Blueprint attribute) statedb StateDB (class in celery.worker.components) StatMonitor (class in celery.worker.autoreload) stats() (celery.app.control.Inspect method) (celery.worker.WorkController method) status (celery.backends.database.models.Task attribute) (celery.bin.base.Command.Error attribute) (celery.bin.base.Command.UsageError attribute) (celery.bin.base.Error attribute) (celery.bin.base.UsageError attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) status_string (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) Step (class in celery.bootsteps) steps (celery.Celery attribute) stop() (celery.apps.beat.Beat.Service method) (celery.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.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.utils.threads.bgThread method) (celery.utils.timer2.Timer method) (celery.worker.WorkController method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.components.Hub method) (celery.worker.consumer.Consumer method) (celery.worker.consumer.Events method) (celery.worker.consumer.Heart method) (celery.worker.consumer.Tasks method) (celery.worker.heartbeat.Heart method) (celery.worker.pidbox.Pidbox method) stop_verify() (celery.bin.multi.MultiTool method) StopFiltering stopwait() (celery.bin.multi.MultiTool method) storage (celery.worker.state.Persistent attribute) STORE_ACTIONS (celery.bin.base.Option attribute) store_errors (celery.worker.job.Request attribute) store_errors_even_if_ignored (celery.app.task.Task attribute) (Task attribute) store_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.DisabledBackend method) str_args_to_python() (celery.bin.amqp.Spec method) strategies Strategies (celery.worker.consumer.Consumer attribute) Strategy (celery.app.task.Task attribute) Strategy() (celery.contrib.batches.Batches method) strtobool() (in module celery.utils) strtotal (celery.contrib.migrate.State attribute) subclass_exception() (in module celery.utils.serialization) subject (celery.utils.mail.ErrorMail attribute) subpolling_interval (celery.backends.base.BaseBackend attribute) (celery.backends.database.DatabaseBackend attribute) subtask() (celery.app.task.Task method) subtasks (celery.result.ResultSet attribute) succeeded (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) SUCCESS state SUCCESS (in module celery.states) success_msg (celery.worker.job.Request attribute) successful() (celery.result.AsyncResult method) (celery.result.ResultSet method) supports_args (celery.bin.base.Command attribute) (celery.bin.beat.beat attribute) (celery.bin.events.events attribute) (celery.bin.worker.worker attribute) supports_autoexpire (celery.backends.amqp.AMQPBackend attribute) (celery.backends.base.BaseBackend attribute) (celery.backends.cache.CacheBackend attribute) (celery.backends.cassandra.CassandraBackend attribute) (celery.backends.mongodb.MongoBackend attribute) (celery.backends.redis.RedisBackend attribute) supports_color() (celery.app.log.Logging method) supports_native_join (celery.backends.amqp.AMQPBackend attribute) (celery.backends.base.BaseBackend attribute) (celery.backends.cache.CacheBackend attribute) (celery.backends.redis.RedisBackend attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) (celery.result.ResultSet attribute) sw_ident (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) sw_sys (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) sw_ver (celery.events.state.State.Worker attribute) (celery.events.state.Worker attribute) symbol_by_name() (celery.bin.base.Command method) (in module celery.utils.imports) sync() (celery.apps.beat.Beat.Service method) (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) (celery.beat.Service method) (celery.worker.state.Persistent method) sync_every (celery.beat.Scheduler attribute) sync_every_tasks (celery.beat.Scheduler attribute) synloop() (in module celery.worker.loops)

T

table() (celery.app.utils.Settings method) take_action() (celery.bin.base.Option method) takes_value() (celery.bin.base.Option method) Task (celery.Celery attribute) task (celery.worker.job.Request attribute) Task (class in celery.app.task) (class in celery.backends.database.models) (class in celery.events.state) task() (celery.Celery method) (in module celery.contrib.methods) task-failed event task-received event task-retried event task-revoked event task-sent event task-started event task-succeeded event Task.ErrorMail (class in celery.app.task) Task.MaxRetriesExceededError task_accepted() (in module celery.worker.state) task_buckets task_consumer task_count (celery.events.state.State attribute) task_event() (celery.events.state.State method) task_failure signal task_id (celery.backends.database.models.Task attribute) (celery.result.AsyncResult attribute) (celery.worker.job.Request attribute) task_id_eq() (in module celery.contrib.migrate) task_id_in() (in module celery.contrib.migrate) task_join_will_block (celery.concurrency.base.BasePool attribute) (celery.concurrency.eventlet.TaskPool attribute) (celery.concurrency.gevent.TaskPool attribute) task_keyprefix (celery.backends.base.KeyValueStoreBackend attribute) task_method (class in celery.contrib.methods) task_name (celery.result.EagerResult attribute) (celery.worker.job.Request attribute) task_postrun signal task_prerun signal task_ready() (in module celery.worker.state), [1] task_reserved() (in module celery.worker.state), [1] task_retry signal task_revoked signal task_sent signal task_success signal task_types() (celery.events.state.State method) TaskConsumer (celery.app.amqp.AMQP attribute) TaskFormatter (class in celery.app.log) tasklist() (celery.apps.worker.Worker method) taskmeta_collection (celery.backends.mongodb.MongoBackend attribute) TaskPool (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) (class in celery.concurrency.prefork) (class in celery.concurrency.solo) (class in celery.concurrency.threads) TaskPool.Timer (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) TaskPool.Timer.Schedule (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) TaskProducer (celery.app.amqp.AMQP attribute) TaskPublisher (class in celery.app.amqp) TaskRegistry (class in celery.app.registry) TaskRegistry.NotRegistered TaskRevokedError tasks (celery.Celery attribute) (celery.events.cursesmon.CursesMonitor attribute)

Tasks (class in celery.worker.consumer) tasks_by_time() (celery.events.state.State method) 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.backends.database.models) taskset_id (celery.backends.database.models.TaskSet attribute) TaskType (class in celery.app.task) tb (celery.datastructures.ExceptionInfo attribute) TERMINATE (celery.concurrency.base.BasePool attribute) terminate() (celery.bootsteps.StartStopStep method) (celery.concurrency.base.BasePool method) (celery.worker.WorkController method) (celery.worker.components.Hub method) (celery.worker.components.Pool method) (celery.worker.job.Request method) terminate_job() (celery.concurrency.base.BasePool method) Terminated thaw() (State 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_start (celery.worker.job.Request attribute) timedelta_seconds() (in module celery.utils.timeutils) TimeLimitExceeded timeout (celery.backends.couchbase.CouchBaseBackend attribute) (celery.task.http.HttpDispatch attribute) TimeoutError timer, [1] (celery.events.snapshot.Polaroid attribute) (celery.worker.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 (celery.Celery attribute) to_dict() (celery.backends.database.models.Task method) (celery.backends.database.models.TaskSet method) to_local() (celery.schedules.schedule method) to_python() (celery.app.defaults.Option method) to_timestamp() (in module celery.utils.timer2) to_utc() (in module celery.utils.timeutils) total_apx (celery.contrib.migrate.State attribute) total_blocks (celery.utils.sysinfo.df attribute) total_count (in module celery.worker.state) total_run_count (celery.beat.ScheduleEntry attribute) trace_task() (in module celery.app.trace) traceback (celery.backends.database.models.Task attribute) (celery.datastructures.ExceptionInfo attribute) (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) TraceInfo (class in celery.app.trace) track_started (celery.app.task.Task attribute) (Task attribute) trail (celery.app.task.Task attribute) (Task attribute) transcoder (celery.backends.couchbase.CouchBaseBackend attribute) TRANSIENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute) tref (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) truncate() (in module celery.utils.text) type (celery.app.control.Control.Mailbox attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] (celery.datastructures.ExceptionInfo attribute) TYPE_CHECKER (celery.bin.base.Option attribute) TYPED_ACTIONS (celery.bin.base.Option attribute) typemap (celery.app.defaults.Option attribute) TYPES (celery.bin.base.Option attribute) tz (celery.schedules.schedule attribute) tzlocal (celery.worker.job.Request attribute) tzname() (celery.utils.timeutils.LocalTimezone method)

U

unbind_from() (celery.backends.amqp.AMQPBackend.Exchange method) underline() (celery.utils.term.colored method) uniq() (in module celery.utils.functional) UnknownStatusError unlock_gil (celery.backends.couchbase.CouchBaseBackend attribute) UnpickleableExceptionWrapper UNREADY_STATES state UNREADY_STATES (celery.backends.base.BaseBackend attribute) unregister() (celery.app.registry.TaskRegistry method) update() (celery.beat.ScheduleEntry method) (celery.datastructures.ConfigurationView method) (celery.datastructures.LRUCache method) (celery.datastructures.LimitedSet method) (celery.events.state.State.Task method) (celery.events.state.State.Worker method) (celery.events.state.Task method) (celery.events.state.Worker method) (celery.result.ResultSet method) (celery.utils.functional.LRUCache method) (celery.worker.autoscale.Autoscaler method) update_from_dict() (celery.beat.Scheduler method)

update_heartbeat() (celery.events.state.State.Worker method) (celery.events.state.Worker method) update_state() (celery.app.task.Task method) update_strategies() (celery.worker.consumer.Consumer method) URL (class in celery.task.http) url (in module celery.task.http) usage() (celery.bin.base.Command method) (celery.bin.multi.MultiTool method) UsageError USE_FAST_LOCALS user (celery.backends.mongodb.MongoBackend attribute) user_agent (celery.task.http.HttpDispatch attribute) user_options (celery.Celery attribute) user_preload_options signal username (celery.backends.couchbase.CouchBaseBackend attribute) uses_semaphore (celery.concurrency.base.BasePool attribute) (celery.concurrency.prefork.TaskPool attribute) utc (celery.worker.job.Request attribute) utc_enabled (celery.schedules.schedule attribute) utcoffset() (celery.utils.timeutils.LocalTimezone method) (in module celery.utils.timeutils)

V

value_set_for() (celery.app.utils.Settings method) values() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method)

verify() (celery.security.certificate.Certificate method) verify_args() (celery.bin.base.Command method) version (celery.bin.base.Command attribute)

W

wait() (celery.result.AsyncResult method) (celery.result.EagerResult method) wait_for() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.DisabledBackend method) waitexec() (celery.bin.multi.MultiTool method) waiting() (celery.result.ResultSet method) wakeup_workers() (celery.events.EventReceiver method) warn_deprecated() (in module celery.utils) warn_if_yajl() (celery.events.EventDispatcher method) weekday() (in module celery.utils.timeutils) when (celery.exceptions.Retry attribute) white() (celery.utils.term.colored method) win (celery.events.cursesmon.CursesMonitor attribute) with_detacher_default_options() (celery.bin.multi.MultiTool method) with_pool_option() (celery.bin.base.Command method) (celery.bin.celery.CeleryCommand method) (celery.bin.worker.worker method) without_defaults() (celery.app.utils.Settings method) WorkController (celery.Celery attribute) (class in celery.worker) WorkController.Blueprint (class in celery.worker) Worker (celery.Celery attribute) worker (celery.events.state.State.Task attribute) (celery.events.state.Task attribute) Worker (class in celery.apps.worker) worker (class in celery.bin.worker) Worker (class in celery.events.state) worker-heartbeat event

worker-offline event worker-online event worker_direct() (in module celery.utils) worker_event() (celery.events.state.State method) worker_init signal worker_initialized (celery.loaders.base.BaseLoader attribute) worker_main() (celery.Celery method) worker_pid (celery.worker.job.Request attribute) worker_process_init signal worker_process_shutdown signal worker_ready signal worker_shutdown signal WorkerComponent (class in celery.worker.autoreload) (class in celery.worker.autoscale) WorkerLostError workers (celery.events.cursesmon.CursesMonitor attribute) workers() (celery.bin.graph.graph method) WorkerShutdown WorkerTerminate write() (celery.utils.log.LoggingProxy method) write_pid() (celery.platforms.Pidfile method) write_stats (celery.concurrency.prefork.TaskPool attribute) writelines() (celery.utils.log.LoggingProxy method)

Y

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