Index

Symbols

--app command line option --autoreload celeryd command line option --autoscale celeryd command line option --config command line option --detach celerybeat command line option celeryev command line option --gid command line option --loader command line option --maxtasksperchild celeryd command line option --no-execv celeryd command line option --pidfile celeryd command line option command line option --purge celeryd command line option --scheduler celeryd command line option --soft-time-limit celeryd command line option --time-limit celeryd command line option --uid command line option --umask command line option --workdir command line option

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

_

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

A

abbr() (in module celery.utils.text) abbreviations() (in module celery.bin.celeryd_multi) 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.BaseTask attribute) (Task attribute) (celery.worker.abstract.Component attribute) accept_magic_kwargs (celery.app.task.BaseTask attribute) (celery.contrib.abortable.AbortableTask attribute) (celery.task.http.HttpDispatchTask attribute) acknowledge() (celery.worker.job.Request method) acknowledged (celery.worker.job.Request attribute) acks_late (celery.app.task.BaseTask attribute) (Task attribute) (celery.contrib.abortable.AbortableTask attribute) (celery.task.http.HttpDispatchTask attribute) acquire() (celery.platforms.PIDFile method) active (celery.concurrency.base.BasePool attribute) active() (celery.app.control.Inspect method) active_queues() (celery.app.control.Inspect method) (in module celery.worker.control) active_requests (in module celery.worker.state) add() (celery.app.amqp.Queues method) (celery.beat.Scheduler method) (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) add_backend_cleanup_task() (in module celery.app.builtins) add_bucket_for_type() (celery.worker.buckets.TaskBucket method) add_cert() (celery.security.certificate.CertStore method) add_chain_task() (in module celery.app.builtins) add_chord_task() (in module celery.app.builtins) add_chunk_task() (in module celery.app.builtins) add_consumer() (celery.app.control.Inspect method) (in module celery.worker.control) add_group_task() (in module celery.app.builtins) add_map_task() (in module celery.app.builtins) add_option() (celery.bin.celeryd_multi.NamespacedOptionParser method) add_queue() (celery.backends.amqp.AMQPBackend.Consumer method) add_starmap_task() (in module celery.app.builtins) add_unlock_chord_task() (in module celery.app.builtins) ADMINS setting after_return() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) after_setup_logger signal after_setup_task_logger signal alert() (celery.events.cursesmon.CursesMonitor method) alert_remote_control_reply() (celery.events.cursesmon.CursesMonitor method) alias (celery.backends.amqp.AMQPBackend.Queue attribute) alive (celery.events.state.Worker attribute) alive_workers() (celery.events.state.State method) ALL_STATES state AlreadyRegistered alt (celery.app.defaults.Option attribute) AlwaysEagerIgnored amqp (celery.bin.camqadm.AMQShell attribute), [1]

AMQP (class in celery.app.amqp) amqp (class in celery.bin.celery) AMQPAdmin (class in celery.bin.camqadm) AMQPAdminCommand (class in celery.bin.camqadm) AMQPBackend (class in celery.backends.amqp) AMQPBackend.BacklogLimitExceeded AMQPBackend.Consumer (class in celery.backends.amqp) AMQPBackend.Exchange (class in celery.backends.amqp) AMQPBackend.Producer (class in celery.backends.amqp) AMQPBackend.Queue (class in celery.backends.amqp) AMQShell (class in celery.bin.camqadm) annotate() (celery.app.annotations.MapAnnotation method) annotate_any() (celery.app.annotations.MapAnnotation method) app (celery.app.control.Inspect attribute) (celery.apps.beat.Beat attribute) (celery.apps.worker.Worker attribute) (celery.apps.worker.Worker.WorkController attribute) (celery.result.AsyncResult attribute) (celery.result.ResultSet attribute) (celery.task.sets.TaskSet attribute) (celery.worker.WorkController attribute) (celery.worker.job.Request attribute) app_or_default() (in module celery.app) AppLoader (class in celery.loaders.app) apply (class in celery.bin.celery) apply() (celery.app.task.BaseTask method) (celery.concurrency.processes.TaskPool.Pool method) (celery.task.base.BaseTask method) (celery.task.sets.TaskSet method) (celery.worker.abstract.Namespace method) (subtask method) apply_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_async() (celery.app.task.BaseTask method) (celery.beat.Scheduler method) (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool.Pool method) (celery.task.base.BaseTask method) (celery.task.sets.TaskSet method) (subtask method) apply_at() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_buffer() (celery.contrib.batches.Batches method) apply_entry() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_eta_task() (celery.worker.consumer.Consumer method) apply_interval() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_target() (in module celery.concurrency.base) (in module celery.concurrency.eventlet) AppPickler (class in celery.app.utils) args (celery.beat.ScheduleEntry attribute) (celery.bin.base.Command attribute) (celery.bin.celery.Command attribute) (celery.bin.celery.apply attribute) (celery.bin.celery.list_ attribute) (celery.bin.celery.result attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.Request attribute) arguments (celery.backends.amqp.AMQPBackend.Exchange attribute) as_dict() (celery.datastructures.LimitedSet method) AsyncResult (class in celery.result) AsyncResult() (celery.app.task.BaseTask method) (celery.contrib.abortable.AbortableTask class method) (celery.task.base.BaseTask method) AsyncResult.TimeoutError AttributeDict (class in celery.datastructures) AttributeDictMixin (class in celery.datastructures) attrs (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) authkey (celery.concurrency.processes.TaskPool.Pool.Process attribute) auto_declare (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) auto_delete (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] (celery.backends.amqp.AMQPBackend.Queue attribute), [1] autoregister (celery.app.task.BaseTask attribute) Autoreloader (class in celery.worker.autoreload) autoreloader_cls (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) autoscale() (in module celery.worker.control) Autoscaler (class in celery.worker.autoscale) autoscaler_cls (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute)

B

b64decode() (in module celery.security.serialization) b64encode() (in module celery.security.serialization) backend (Task attribute) (celery.app.task.BaseTask attribute) (celery.contrib.abortable.AbortableTask attribute) (celery.result.AsyncResult attribute) (celery.task.http.HttpDispatchTask attribute) background (celery.events.cursesmon.CursesMonitor attribute) BacklogLimitExceeded BaseAsyncResult (in module celery.result) BaseBackend (class in celery.backends.base) BaseBackend.TimeoutError BaseDictBackend (class in celery.backends.base) 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) BasePool.Timer.Schedule (class in celery.concurrency.base) BaseTask (class in celery.app.task) (class in celery.task.base) BaseTask.ErrorMail (class in celery.app.task) (class in celery.task.base) BaseTask.MaxRetriesExceededError, [1] Batches (class in celery.contrib.batches) Beat (class in celery.apps.beat) beat (class in celery.bin.celery) Beat (class in celery.worker) Beat.Service (class in celery.apps.beat) beat_embedded_init signal beat_init signal BeatCommand (class in celery.bin.celerybeat) bgThread (class in celery.utils.threads) bind() (queue method) bind_component() (celery.worker.abstract.Namespace method) binding_arguments (celery.backends.amqp.AMQPBackend.Queue attribute) black() (celery.utils.term.colored method) blink() (celery.utils.term.colored method) blue() (celery.utils.term.colored method) body (celery.utils.mail.ErrorMail attribute)

body() (celery.concurrency.processes.TaskPool.Pool.ResultHandler method) (celery.concurrency.processes.TaskPool.Pool.Supervisor method) (celery.concurrency.processes.TaskPool.Pool.TaskHandler method) (celery.concurrency.processes.TaskPool.Pool.TimeoutHandler method) (celery.utils.threads.bgThread method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoscale.Autoscaler method) (celery.worker.mediator.Mediator method) bold() (celery.utils.term.colored method) BoundMethodWeakref (class in celery.utils.dispatch.saferef) BoundNonDescriptorMethodWeakref (class in celery.utils.dispatch.saferef) bright() (celery.utils.term.colored method) broadcast() (celery.app.control.Control method) broadcast_consumer (celery.worker.consumer.Consumer attribute) BROKER_BACKEND (celery.app.utils.Settings attribute) BROKER_CONNECTION_MAX_RETRIES setting BROKER_CONNECTION_RETRY setting BROKER_CONNECTION_TIMEOUT setting BROKER_HOST setting BROKER_HOST (celery.app.utils.Settings attribute) BROKER_PASSWORD setting BROKER_POOL_LIMIT setting BROKER_PORT setting BROKER_TRANSPORT setting BROKER_TRANSPORT (celery.app.utils.Settings attribute) BROKER_TRANSPORT_OPTIONS setting BROKER_URL setting BROKER_USE_SSL setting BROKER_USER setting BROKER_VHOST setting BrokerConnection (celery.app.amqp.AMQP attribute) bugreport() (in module celery.app.utils) build_graph() (celery.result.AsyncResult method) build_kwargs() (celery.app.utils.AppPickler method) build_standard_kwargs() (celery.app.utils.AppPickler method) build_tracer() (in module celery.task.trace) builtin_boot_steps (celery.worker.Namespace attribute) builtin_modules (celery.loaders.base.BaseLoader attribute) builtins (celery.bin.camqadm.AMQShell attribute) Bunch (class in celery.backends.mongodb)

C

CacheBackend (class in celery.backends.cache) calculate_key() (celery.utils.dispatch.saferef.BoundMethodWeakref class method) call() (celery.app.control.Control.Mailbox method) callback (celery.worker.mediator.Mediator attribute) callbacks (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.worker.job.Request attribute) camqadm() (in module celery.bin.camqadm) can_cache_declaration (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) cancel() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Queue method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.base.BasePool.Timer.Entry method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.eventlet.Timer method) (celery.events.snapshot.Polaroid method) (celery.utils.timer2.Entry method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Entry method) cancel_by_queue() (celery.backends.amqp.AMQPBackend.Consumer method) cancel_consumer() (celery.app.control.Inspect method) (in module celery.worker.control) cancelled (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) capture() (celery.events.EventReceiver method) (celery.events.snapshot.Polaroid method) capture_events() (in module celery.events.cursesmon) 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.app (module) celery.app.abstract (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.state (module) celery.app.task (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.database (module) celery.backends.database.models (module) celery.backends.database.session (module) celery.backends.mongodb (module) celery.backends.redis (module) celery.beat (module) celery.bin.base (module) celery.bin.camqadm (module) celery.bin.celery (module) celery.bin.celerybeat (module) celery.bin.celeryd (module) celery.bin.celeryd_multi (module) celery.bin.celeryev (module) celery.concurrency (module) celery.concurrency.base (module) celery.concurrency.eventlet (module) celery.concurrency.gevent (module) celery.concurrency.processes (module) celery.concurrency.solo (module) celery.concurrency.threads (module) celery.contrib.abortable (module) celery.contrib.batches (module) celery.contrib.migrate (module) celery.contrib.rdb (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 (module) celery.task.base (module), [1] celery.task.chords (module) celery.task.control (module) celery.task.http (module), [1] celery.task.sets (module) celery.task.trace (module) celery.utils (module) celery.utils.compat (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.log (module) celery.utils.mail (module) celery.utils.serialization (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.abstract (module) celery.worker.autoreload (module) celery.worker.autoscale (module) celery.worker.buckets (module) celery.worker.consumer (module) celery.worker.control (module) celery.worker.heartbeat (module) celery.worker.job (module) celery.worker.mediator (module) celery.worker.state (module) celery.worker.strategy (module) CELERY_ACKS_LATE setting CELERY_ALWAYS_EAGER setting CELERY_AMQP_TASK_RESULT_EXPIRES setting CELERY_ANNOTATIONS setting 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_CONFIG_MODULE 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_UTC setting CELERY_EVENT_SERIALIZER setting CELERY_IGNORE_RESULT setting CELERY_IMPORTS setting CELERY_LOADER, [1], [2], [3], [4], [5], [6] CELERY_MAX_CACHED_RESULTS setting CELERY_MESSAGE_COMPRESSION setting CELERY_MONGODB_BACKEND_SETTINGS setting CELERY_QUEUES setting CELERY_RDB_HOST CELERY_RDB_PORT CELERY_RDBSIG CELERY_REDIRECT_STDOUTS setting CELERY_REDIRECT_STDOUTS_LEVEL setting CELERY_REDIS_DB setting

CELERY_REDIS_HOST setting CELERY_REDIS_MAX_CONNECTIONS setting CELERY_REDIS_PASSWORD setting CELERY_REDIS_PORT setting CELERY_RESULT_BACKEND setting CELERY_RESULT_BACKEND (celery.app.utils.Settings attribute) CELERY_RESULT_DB_SHORT_LIVED_SESSIONS CELERY_RESULT_DB_SHORT_LIVED_SESSIONS = True 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_ERROR_WHITELIST 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_TRACE_APP, [1] CELERY_TRACK_STARTED setting celerybeat command line option --detach -S, --scheduler -f, --logfile -l, --loglevel -s, --schedule max-interval CELERYBEAT_LOG_FILE setting CELERYBEAT_LOG_LEVEL setting CELERYBEAT_MAX_LOOP_INTERVAL setting CELERYBEAT_SCHEDULE setting CELERYBEAT_SCHEDULE_FILENAME setting CELERYBEAT_SCHEDULER setting CeleryCommand (class in celery.bin.celery) celeryd command line option --autoreload --autoscale --maxtasksperchild --no-execv --pidfile --purge --scheduler --soft-time-limit --time-limit -B, --beat -E, --events -I, --include -P, --pool -Q, --queues -S, --statedb -c, --concurrency -f, --logfile -l, --loglevel -n, --hostname -s, --schedule CELERYD_AUTORELOADER setting CELERYD_AUTOSCALER setting CELERYD_BOOT_STEPS setting CELERYD_CONCURRENCY setting CELERYD_CONSUMER setting CELERYD_ETA_SCHEDULER setting CELERYD_ETA_SCHEDULER_PRECISION setting CELERYD_FORCE_EXECV setting CELERYD_FSNOTIFY, [1] CELERYD_HIJACK_ROOT_LOGGER setting celeryd_init signal CELERYD_LOG_COLOR setting CELERYD_LOG_FILE setting CELERYD_LOG_FORMAT setting CELERYD_LOG_LEVEL setting CELERYD_MAX_TASKS_PER_CHILD setting CELERYD_MEDIATOR setting CELERYD_POOL setting CELERYD_PREFETCH_MULTIPLIER setting CELERYD_STATE_DB setting CELERYD_TASK_LOG_FORMAT setting CELERYD_TASK_SOFT_TIME_LIMIT setting CELERYD_TASK_TIME_LIMIT setting CELERYD_WORKER_LOST_WAIT setting celeryev command line option --detach -F, --freq, --frequency -c, --camera -d, --dump -l, --loglevel -r, --maxrate CELERYMON_LOG_FILE setting CELERYMON_LOG_FORMAT setting CELERYMON_LOG_LEVEL setting Certificate (class in celery.security.certificate) CertStore (class in celery.security.certificate) chain (built-in class) chain_from_iterable() (in module celery.task.chords) (in module celery.utils.compat) (in module celery.worker.buckets) chan (celery.bin.camqadm.AMQShell attribute) changes (celery.datastructures.ConfigurationView attribute) channel (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) check_args() (celery.bin.base.Command method) children (celery.result.AsyncResult attribute) choices (celery.bin.celery.inspect attribute) chord (built-in class) chord_keyprefix (celery.backends.base.KeyValueStoreBackend attribute) chronologically (celery.datastructures.LimitedSet attribute) chunks() (in module celery.utils.functional) cleanup() (celery.backends.base.BaseBackend method) (celery.backends.database.DatabaseBackend method) (celery.backends.mongodb.MongoBackend method) (celery.events.snapshot.Polaroid method) cleanup_signal (celery.events.snapshot.Polaroid attribute) clear() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.base.BasePool.Timer.Schedule method) (celery.concurrency.eventlet.Schedule method) (celery.concurrency.eventlet.TaskPool.Timer.Schedule method) (celery.concurrency.eventlet.Timer.Schedule method) (celery.concurrency.gevent.Schedule method) (celery.concurrency.gevent.TaskPool.Timer.Schedule method) (celery.concurrency.gevent.Timer.Schedule method) (celery.datastructures.LimitedSet method) (celery.events.state.State method) (celery.result.ResultSet method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Schedule method) (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) clear_after (celery.events.snapshot.Polaroid attribute) clear_tasks() (celery.events.state.State method) client (celery.backends.cache.CacheBackend attribute) (celery.backends.redis.RedisBackend attribute) clone() (subtask method) CLOSE (celery.apps.worker.Worker.WorkController attribute) (celery.concurrency.base.BasePool attribute) (celery.worker.WorkController attribute) close() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Producer method) (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) (celery.concurrency.processes.TaskPool.Pool method) (celery.events.EventDispatcher method) (celery.platforms.DaemonContext method) (celery.utils.log.LoggingProxy method) (celery.worker.state.Persistent method) close_connection() (celery.worker.consumer.Consumer method) closed (celery.utils.log.LoggingProxy attribute) cmdline_config_parser() (celery.loaders.base.BaseLoader method) coerce() (celery.bin.camqadm.Spec method) collect() (celery.result.AsyncResult method) collection (celery.backends.mongodb.MongoBackend attribute) colored (celery.bin.celeryd_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 (celery.bin.celery.amqp attribute) (celery.bin.celery.beat attribute) (celery.bin.celery.events attribute) (celery.bin.celery.worker attribute) (class in celery.bin.base) (class in celery.bin.celery) command line option --app --config --gid --loader --pidfile --uid --umask --workdir -b, --broker -f, --logfile command() (in module celery.bin.celery) commands (celery.bin.celery.CeleryCommand attribute) completed_count() (celery.result.ResultSet method) completenames() (celery.bin.camqadm.AMQShell method) Component (class in celery.worker.abstract) (class in celery.worker.consumer) ComponentType (class in celery.worker.abstract) compression (celery.backends.amqp.AMQPBackend.Producer attribute) concurrency (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) conf (celery.loaders.base.BaseLoader attribute) config_from_cmdline() config_from_envvar() (celery.loaders.base.BaseLoader method) config_from_object() (celery.loaders.base.BaseLoader method) configurated (class in celery.app.abstract) ConfigurationView (class in celery.datastructures) configured (celery.loaders.base.BaseLoader attribute) confopts_as_dict() (celery.app.abstract.configurated method) conn (celery.bin.camqadm.AMQShell attribute) connect() (celery.bin.camqadm.AMQPAdmin method) (celery.utils.dispatch.signal.Signal method) connection (celery.app.control.Control.Mailbox attribute) (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.beat.Scheduler attribute) (celery.worker.consumer.Consumer attribute) connection_errors (celery.worker.job.Request attribute) construct() (celery.app.utils.AppPickler method) consume() (celery.backends.amqp.AMQPBackend method) (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Queue method) consume_from (celery.app.amqp.Queues attribute) consume_messages() (celery.worker.consumer.Consumer method) Consumer (celery.app.amqp.AMQP attribute) (class in celery.worker.consumer) consumer() (celery.events.EventReceiver method) consumer_cls (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) consuming_from() (celery.backends.amqp.AMQPBackend.Consumer method) control disable_events enable_events ping rate_limit revoke shutdown Control (class in celery.app.control) Control.Mailbox (class in celery.app.control) copy_buffer() (celery.events.EventDispatcher method) count (celery.contrib.migrate.State attribute) counter (celery.bin.camqadm.AMQShell attribute) CPendingDeprecationWarning create() (celery.worker.abstract.Component method) (celery.worker.Beat method) (celery.worker.Pool method) (celery.worker.Queues method) (celery.worker.StateDB method) (celery.worker.Timers method) (celery.worker.autoreload.WorkerComponent method) (celery.worker.autoscale.WorkerComponent method) (celery.worker.consumer.Component method) (celery.worker.mediator.WorkerComponent method) create_delegate() (in module celery.bin.celery) create_exception_cls() (in module celery.utils.serialization) create_parser() (celery.bin.base.Command method) (celery.bin.celery.Delegate method) create_pidlock() (in module celery.platforms) create_session() (in module celery.backends.database.session) crontab (class in celery.schedules) crontab_parser (class in celery.schedules) crontab_parser.ParseException cry() (in module celery.utils) current_app (built-in variable) current_loader() (in module celery.loaders) current_task (built-in variable) 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 (celery.concurrency.processes.TaskPool.Pool.Process attribute) daemon_options() (in module celery.bin.base) DaemonContext (class in celery.platforms) data (celery.worker.control.Panel attribute) database (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_week (celery.schedules.crontab attribute) db (celery.backends.redis.RedisBackend attribute) (celery.worker.state.Persistent attribute) debug() (in module celery.worker.consumer) debugger() (in module celery.contrib.rdb) declare() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Producer method) (celery.backends.amqp.AMQPBackend.Queue method) (queue method) decode() (celery.backends.base.BaseBackend method) decrement() (celery.worker.consumer.QoS method) decrement_eventually() (celery.worker.consumer.QoS method) default (celery.platforms.Signals attribute) default() (celery.bin.camqadm.AMQShell method) (in module celery.worker.strategy) default_app (in module celery.app) default_backend (in module celery.backends) default_connection() default_dispatcher() (celery.events.Events method) default_exchange (celery.app.amqp.AMQP attribute) default_implementation() (in module celery.worker.autoreload) default_loader (in module celery.app) default_queue (celery.app.amqp.AMQP attribute) default_retry_delay (celery.app.task.BaseTask attribute) (Task attribute) defaults (celery.datastructures.ConfigurationView attribute) defines_custom_call() (in module celery.task.trace) delay() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) (subtask method) Delegate (class in celery.bin.celery) delete() (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Queue method) (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.redis.RedisBackend method) (celery.result.TaskSetResult method) (exchange method) (queue method) delete_taskset() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) deletion_methods (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) delivery_info (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.Request attribute) delivery_mode (celery.app.task.BaseTask attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] (celery.contrib.abortable.AbortableTask attribute) (celery.task.http.HttpDispatchTask attribute) delta_resolution() (in module celery.utils.timeutils) deprecate_by (celery.app.defaults.Option attribute) deprecated() (in module celery.utils) deserialize() (celery.security.serialization.SecureSerializer method)

detached() (in module celery.platforms) detailed_mode (celery.backends.cassandra.CassandraBackend attribute) determine_exit_status() (in module celery.bin.celery) DictAttribute (class in celery.datastructures) die() (celery.bin.base.Command method) disable() (celery.events.EventDispatcher method) disable_events control disable_events() (celery.app.control.Inspect method) (in module celery.worker.control) disable_rate_limits (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) disable_trace() (in module celery.app) disable_untrusted_serializers() (in module celery.security) DisabledBackend (class in celery.backends.base) discard() (celery.result.ResultSet method) discard_all() (celery.app.control.Control method) disconnect() (celery.utils.dispatch.signal.Signal method) dispatch() (celery.bin.camqadm.AMQShell method) (celery.task.http.HttpDispatch method) Dispatcher (celery.events.Events attribute) dispatcher (celery.task.http.URL attribute) display_command_help() (celery.bin.camqadm.AMQShell method) display_height (celery.events.cursesmon.CursesMonitor attribute) display_task_row() (celery.events.cursesmon.CursesMonitor method) display_width (celery.events.cursesmon.CursesMonitor attribute) DisplayThread (class in celery.events.cursesmon) do_exit() (celery.bin.camqadm.AMQShell method) do_help() (celery.bin.camqadm.AMQShell method) doc (celery.bin.base.Command attribute) (celery.bin.celerybeat.BeatCommand attribute) (celery.bin.celeryd.WorkerCommand attribute) (celery.bin.celeryev.EvCommand attribute) DOWN (celery.bin.celeryd_multi.MultiTool attribute) drain_events() (celery.backends.amqp.AMQPBackend method) (celery.events.EventReceiver method) draw() (celery.events.cursesmon.CursesMonitor method) DummyClient (class in celery.backends.cache) dump_active() (in module celery.worker.control) dump_message() (in module celery.bin.camqadm) dump_reserved() (in module celery.worker.control) dump_revoked() (in module celery.worker.control) dump_schedule() (in module celery.worker.control) dump_tasks() (in module celery.worker.control) Dumper (class in celery.events.dumper) durable (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] (celery.backends.amqp.AMQPBackend.Queue attribute), [1]

E

eager_trace_task() (in module celery.task.trace) EagerResult (class in celery.result) Element (class in celery.events.state) 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.concurrency.base.BasePool.Timer.Schedule method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Schedule method) (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) enable() (celery.events.EventDispatcher method) enable_config_from_cmdline (celery.bin.base.Command attribute) (celery.bin.celery.CeleryCommand attribute) (celery.bin.celerybeat.BeatCommand attribute) (celery.bin.celeryd.WorkerCommand attribute) enable_events control enable_events() (celery.app.control.Inspect method) (in module celery.worker.control) enable_trace() (in module celery.app) enabled (celery.worker.abstract.Component attribute) encode() (celery.backends.base.BaseBackend method) encode_result() (celery.backends.base.BaseBackend method) 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.eventlet.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.concurrency.gevent.Timer method) (celery.utils.timer2.Timer method) enter() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.base.BasePool.Timer.Schedule method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Schedule method) 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 CELERYD_FSNOTIFY, [1] CELERY_BROKER_URL CELERY_CONFIG_MODULE CELERY_LOADER, [1], [2], [3], [4], [5], [6] CELERY_RDBSIG CELERY_RDB_HOST, [1] CELERY_RDB_PORT, [1] CELERY_TRACE_APP, [1] NOSE_VERBOSE PATH errbacks (celery.worker.job.Request attribute) Error error() (celery.bin.celery.Command method) (celery.bin.celeryd_multi.MultiTool method) error_envvar_not_set (celery.loaders.base.BaseLoader attribute) error_msg (celery.worker.job.Request attribute) error_whitelist (celery.app.task.BaseTask attribute) (Task attribute) (celery.utils.mail.ErrorMail attribute) ErrorMail (class in celery.utils.mail) establish_connection() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) eta (celery.worker.job.Request attribute) eta_schedule (celery.worker.consumer.Consumer attribute) eta_scheduler_cls (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) eta_scheduler_precision (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) evaluate() (celery.utils.functional.mpromise method) evaluated (celery.utils.functional.mpromise attribute), [1] evcam() (in module celery.events.snapshot) EvCommand (class in celery.bin.celeryev) evdump() (in module celery.events.dumper) Event (class in celery.utils.threads)

event() (celery.events.state.State method) Event() (in module celery.events) event_count (celery.events.state.State attribute) event_dispatcher (celery.worker.consumer.Consumer attribute) EventDispatcher (class in celery.events) 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 (class in celery.bin.celery) Events (class in celery.events) evtop() (in module celery.events.cursesmon) exc_args (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exc_cls_name (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exc_info (celery.task.trace.TraceInfo attribute) exc_module (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exc_type (celery.task.trace.TraceInfo attribute) exc_value (celery.task.trace.TraceInfo attribute) exception (celery.datastructures.ExceptionInfo attribute) EXCEPTION_STATES state EXCEPTION_STATES (celery.backends.base.BaseBackend attribute) exception_to_python() (celery.backends.base.BaseBackend method) ExceptionInfo (class in celery.datastructures) exchange (celery.app.control.Control.Mailbox attribute) (Task attribute) (celery.app.task.BaseTask attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.backends.amqp.AMQPBackend.Queue attribute), [1] exchange_fmt (celery.app.control.Control.Mailbox attribute) exchange_type (celery.app.task.BaseTask attribute) (celery.contrib.abortable.AbortableTask attribute) (celery.task.http.HttpDispatchTask attribute) exclusive (celery.backends.amqp.AMQPBackend.Queue attribute), [1] execute() (celery.app.task.BaseTask method) (celery.bin.celery.CeleryCommand method) (celery.contrib.batches.Batches method) (celery.task.base.BaseTask method) (celery.worker.job.Request method) execute_and_trace() (in module celery.worker.job) execute_from_commandline() (celery.bin.base.Command method) (celery.bin.celery.CeleryCommand method) (celery.bin.celeryd_multi.MultiTool method) execute_using_pool() (celery.worker.job.Request method) exit_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) exitcode (celery.concurrency.processes.TaskPool.Pool.Process attribute) expand() (celery.bin.celeryd_multi.MultiTool method) expand_destination() (celery.app.routes.Router method) expanduser() (celery.bin.base.Command method) expected_time() (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TokenBucketQueue method) expire() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.redis.RedisBackend method) expire_window (celery.events.state.Worker attribute) expires (celery.app.task.BaseTask attribute) (celery.datastructures.LimitedSet attribute) (celery.worker.job.Request attribute) extend_with_default_kwargs() (celery.worker.job.Request method) extra_info() (celery.apps.worker.Worker method) extract_response() (in module celery.task.http)

F

FAILED (celery.bin.celeryd_multi.MultiTool attribute) failed() (celery.result.AsyncResult method) (celery.result.ResultSet method) FAILURE state fallback_chord_unlock() (celery.backends.base.BaseBackend method) FastQueue (class in celery.worker.buckets) fg() (in module celery.utils.term) file_hash() (in module celery.worker.autoreload) fileno() (celery.utils.log.LoggingProxy method) filter_types() (celery.app.registry.TaskRegistry method) finalize() find() (in module celery.app.defaults) find_app() (celery.bin.base.Command method) find_deprecated_settings() (in module celery.app.defaults) find_module() (celery.loaders.default.Loader method) (in module celery.utils.imports) find_nearest_pickleable_exception() (in module celery.utils.serialization) find_option() (celery.app.utils.Settings method) find_position() (celery.events.cursesmon.CursesMonitor method) find_value_for_key() (celery.app.utils.Settings method) findsig() (in module celery.bin.celeryd_multi) first (celery.datastructures.LimitedSet attribute) first() (celery.datastructures.ConfigurationView method) (in module celery.utils.functional) firstmethod() (in module celery.utils.functional) flatten() (in module celery.app.defaults) flatten_links() (subtask method) flatten_reply() (in module celery.app.control) flow() (celery.backends.amqp.AMQPBackend.Consumer method) flush() (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_execv (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) force_scale_down() (celery.worker.autoscale.Autoscaler method) force_scale_up() (celery.worker.autoscale.Autoscaler method) foreground (celery.events.cursesmon.CursesMonitor attribute) forget() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.result.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.camqadm.Spec method) format_body() (celery.utils.mail.ErrorMail method) format_declare_queue() (in module celery.bin.camqadm) format_opt() (in module celery.bin.celeryd_multi) format_response() (celery.bin.camqadm.Spec method) format_row() (celery.events.cursesmon.CursesMonitor method) format_signature() (celery.bin.camqadm.Spec method) format_subject() (celery.utils.mail.ErrorMail method) format_task_event() (celery.events.dumper.Dumper method) formatException() (celery.utils.log.ColorFormatter method) freeze() (State method) freeze_while() (celery.events.state.State method) (State method) from_config (class in celery.app.abstract) from_exception() (celery.utils.serialization.UnpickleableExceptionWrapper class method) from_message() (celery.worker.job.Request class method) from_request() (celery.contrib.batches.SimpleRequest class method) from_serializable() (in module celery.result) FSCertStore (class in celery.security.certificate) fun_takes_kwargs() (in module celery.utils)

G

get() (celery.backends.amqp.AMQPBackend.Queue method) (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.redis.RedisBackend method) (celery.bin.celeryd_multi.MultiTool method) (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) get_amqp_api_command() (celery.bin.camqadm.AMQShell method) get_async() (celery.task.http.URL method) get_backend_by_url() (in module celery.backends) get_backend_cls() (in module celery.backends) get_best_memcache() (in module celery.backends.cache) get_bound_method_weakref() (in module celery.utils.dispatch.saferef) get_bucket_for_type() (celery.worker.buckets.TaskBucket method) get_by_parts() (celery.app.utils.Settings method) get_children() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) get_cls_by_name() (celery.bin.base.Command method) get_consumer() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) get_current_app() (in module celery.app.state) get_current_task() (in module celery.app.state) get_default_logger() (celery.app.log.Logging method) get_engine() (in module celery.backends.database.session) get_fdmax() (in module celery.platforms) get_id() (celery.security.certificate.Certificate method) get_implementation() (in module celery.concurrency) get_issuer() (celery.security.certificate.Certificate method) get_key() (celery.app.abstract.from_config method) get_key_for_chord() (celery.backends.base.KeyValueStoreBackend method) get_key_for_task() (celery.backends.base.KeyValueStoreBackend method) get_key_for_taskset() (celery.backends.base.KeyValueStoreBackend method) get_leaf() (celery.result.AsyncResult method) get_loader_cls() (in module celery.loaders) get_logger() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) (in module celery.utils.log)

get_many() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.KeyValueStoreBackend method) get_multi() (celery.backends.cache.DummyClient method) get_multiprocessing_logger() (in module celery.utils.log) get_names() (celery.bin.camqadm.AMQShell method) get_nowait() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) get_options() (celery.bin.base.Command method) (celery.bin.celery.Delegate method) (celery.bin.celerybeat.BeatCommand method) (celery.bin.celeryd.WorkerCommand method) (celery.bin.celeryev.EvCommand method) get_or_create_task() (celery.events.state.State method) get_or_create_worker() (celery.events.state.State method) get_pickleable_exception() (in module celery.utils.serialization) get_pickled_exception() (in module celery.utils.serialization) get_publisher() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) 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.BaseDictBackend method) (celery.backends.base.DisabledBackend method) get_schedule() (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) get_scheduler() (celery.apps.beat.Beat.Service method) (celery.beat.Service method) get_serial_number() (celery.security.certificate.Certificate method) get_status() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.backends.base.DisabledBackend method) get_task_meta() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseDictBackend method) get_taskset_meta() (celery.backends.base.BaseDictBackend method) get_traceback() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.backends.base.DisabledBackend method) getpids() (celery.bin.celeryd_multi.MultiTool method) graph (celery.result.AsyncResult attribute) green() (celery.utils.term.colored method) greet (celery.events.cursesmon.CursesMonitor attribute) group (built-in class) grow() (celery.concurrency.gevent.TaskPool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool method)

H

handle_argv() (celery.bin.base.Command method) (celery.bin.celery.CeleryCommand method) handle_error() (celery.concurrency.base.BasePool.Timer.Schedule method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer.Schedule method) handle_error_state() (celery.task.trace.TraceInfo method) handle_failure() (celery.task.trace.TraceInfo method) handle_keypress() (celery.events.cursesmon.CursesMonitor method) handle_retry() (celery.task.trace.TraceInfo method) handlers (celery.events.EventReceiver attribute) has_expired() (celery.security.certificate.Certificate method) heart (celery.worker.consumer.Consumer attribute) Heart (class in celery.worker.heartbeat) heartbeat() (in module celery.worker.control) heartbeat_expires (celery.events.state.Worker attribute) heartbeat_max (celery.events.state.Worker attribute)

help (celery.bin.celery.Command attribute) (celery.events.cursesmon.CursesMonitor attribute) (class in celery.bin.celery) help() (celery.bin.celeryd_multi.MultiTool method) help_title (celery.events.cursesmon.CursesMonitor attribute) host (celery.backends.redis.RedisBackend attribute) hostname (celery.contrib.batches.SimpleRequest attribute) (celery.worker.consumer.Consumer attribute) (celery.worker.job.Request attribute) hour (celery.schedules.crontab attribute) http_headers (celery.task.http.HttpDispatch attribute) HttpDispatch (class in celery.task.http) HttpDispatchTask (class in celery.task.http) human_seconds (celery.schedules.schedule attribute) humanize() (celery.app.utils.Settings method) humanize_seconds() (in module celery.utils.timeutils) humanize_type() (in module celery.events.dumper)

I

iblue() (celery.utils.term.colored method) icyan() (celery.utils.term.colored method) id (celery.backends.database.models.Task attribute) (celery.backends.database.models.TaskSet attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.result.AsyncResult attribute) (celery.result.TaskSetResult attribute) (celery.worker.job.Request attribute) ident (celery.concurrency.processes.TaskPool.Pool.Process attribute) identchars (celery.bin.camqadm.AMQShell attribute) ignore() (celery.platforms.Signals method) ignore_EBADF() (in module celery.platforms) ignore_result (celery.app.task.BaseTask attribute) (Task attribute) ignored (celery.platforms.Signals attribute) igreen() (celery.utils.term.colored method) imagenta() (celery.utils.term.colored method) imap() (celery.concurrency.processes.TaskPool.Pool method) imap_unordered() (celery.concurrency.processes.TaskPool.Pool method) immediate (celery.app.task.BaseTask attribute) (Task attribute) implements_incr (celery.backends.base.KeyValueStoreBackend attribute) (celery.backends.cache.CacheBackend attribute) (celery.backends.redis.RedisBackend attribute) import_best_memcache() (in module celery.backends.cache) import_default_modules() (celery.loaders.base.BaseLoader method) import_from_cwd() (celery.loaders.base.BaseLoader method) (in module celery.utils.imports) import_module() (celery.loaders.base.BaseLoader method) (celery.worker.abstract.Namespace method) import_task_module() (celery.loaders.base.BaseLoader method) ImproperlyConfigured inc_counter (celery.bin.camqadm.AMQShell attribute) include() (celery.worker.abstract.Component method) (celery.worker.abstract.StartStopComponent method) include_if() (celery.worker.abstract.Component method) (celery.worker.mediator.WorkerComponent method) IncompleteStream incr() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.redis.RedisBackend method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) increment() (celery.worker.consumer.QoS method) indent() (in module celery.bin.celery) (in module celery.utils.text) info (celery.beat.PersistentScheduler attribute) (celery.beat.Scheduler attribute) (celery.concurrency.base.BasePool attribute) (celery.result.AsyncResult attribute) (celery.worker.consumer.Consumer attribute) info() (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.base.BasePool.Timer.Schedule method) (celery.events.state.Task method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer.Schedule method) (celery.worker.autoscale.Autoscaler method) (celery.worker.job.Request method) info_str (celery.events.cursesmon.CursesMonitor attribute) inherit_confopts (celery.apps.worker.Worker attribute) init_callback (celery.worker.consumer.Consumer attribute) init_loader() (celery.apps.beat.Beat method) init_queues() (celery.apps.worker.Worker method) init_screen() (celery.events.cursesmon.CursesMonitor method) init_with_registry() (celery.worker.buckets.TaskBucket method) init_worker() (celery.loaders.base.BaseLoader method) init_worker_process() (celery.loaders.base.BaseLoader method) initgroups() (in module celery.platforms) initial_prefetch_count (celery.worker.consumer.Consumer attribute) InotifyMonitor (class in celery.worker.autoreload) inspect (celery.app.control.Control attribute)

Inspect (class in celery.app.control) inspect (class in celery.bin.celery) (in module celery.task.control) install() (celery.events.snapshot.Polaroid method) install_cry_handler() (in module celery.apps.worker) install_default_entries() (celery.beat.Scheduler method) install_HUP_not_supported_handler() (in module celery.apps.worker) install_platform_tweaks() (celery.apps.worker.Worker method) install_rdb_handler() (in module celery.apps.worker) install_sync_handler() (celery.apps.beat.Beat method) install_worker_restart_handler() (in module celery.apps.worker) instantiate() (celery.worker.abstract.Component method) (in module celery.utils.imports) internal (celery.datastructures.ExceptionInfo attribute) internal_error_msg (celery.worker.job.Request attribute) INVALID_TASK_ERROR (in module celery.worker.consumer) InvalidResponseError InvalidTaskError invoke_bpython_shell() (celery.bin.celery.shell method) invoke_default_shell() (celery.bin.celery.shell method) invoke_fallback_shell() (celery.bin.celery.shell method) invoke_ipython_shell() (celery.bin.celery.shell method) ired() (celery.utils.term.colored method) is_aborted() (celery.contrib.abortable.AbortableAsyncResult method) (celery.contrib.abortable.AbortableTask method) is_alive() (celery.concurrency.processes.TaskPool.Pool.Process 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) isatty() (celery.utils.log.LoggingProxy method) (in module celery.utils) items (celery.worker.buckets.FastQueue attribute) (celery.worker.buckets.TaskBucket attribute) (celery.worker.buckets.TokenBucketQueue attribute) items() (celery.datastructures.ConfigurationView method) (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) itersubtasks() (celery.result.TaskSetResult method) itertasks() (celery.events.state.State method) itervalues() (celery.datastructures.ConfigurationView 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.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.result.ResultSet method)

join_native() (celery.result.ResultSet method)

K

key (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) keyalias (celery.events.cursesmon.CursesMonitor attribute) keymap (celery.events.cursesmon.CursesMonitor attribute) keys() (celery.datastructures.ConfigurationView method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) keyspace (celery.backends.cassandra.CassandraBackend attribute)

KeyValueStoreBackend (class in celery.backends.base) kill() (celery.bin.celeryd_multi.MultiTool method) known_suffixes (celery.beat.PersistentScheduler attribute) KQueueMonitor (class in celery.worker.autoreload) kwargs (celery.beat.ScheduleEntry attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.Request attribute)

L

last (celery.worker.abstract.Component attribute) (celery.worker.consumer.Component attribute) last_run_at (celery.beat.ScheduleEntry attribute) limit (celery.events.cursesmon.CursesMonitor attribute) LimitedSet (class in celery.datastructures) link() (subtask method) link_error() (subtask method) list_ (class in celery.bin.celery) list_bindings() (celery.bin.celery.list_ method) load_modules() (celery.worker.abstract.Namespace method) load_settings() (in module celery.loaders) load_shared_tasks() (in module celery.app.builtins) loader

Loader (class in celery.loaders.default) LockFailed log logfile (celery.apps.beat.Beat attribute) (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) logger (celery.beat.Scheduler attribute) Logging (class in celery.app.log) LoggingProxy (class in celery.utils.log) loglevel (celery.apps.beat.Beat attribute) (celery.apps.worker.Worker attribute) (celery.apps.worker.Worker.WorkController attribute) (celery.utils.log.LoggingProxy attribute) (celery.worker.WorkController attribute) lookup_route() (celery.app.routes.Router 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.loaders.base.BaseLoader method) Mailer (class in celery.utils.mail) main main() (in module celery.bin.camqadm) (in module celery.bin.celery) (in module celery.bin.celerybeat) (in module celery.bin.celeryd) (in module celery.bin.celeryd_multi) (in module celery.bin.celeryev) make_request() (celery.task.http.HttpDispatch method) mandatory (celery.app.task.BaseTask attribute) (Task attribute) map() (celery.concurrency.processes.TaskPool.Pool method) map_async() (celery.concurrency.processes.TaskPool.Pool 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-interval celerybeat command line option max_connections (celery.backends.redis.RedisBackend attribute) max_interval (celery.beat.Scheduler attribute) max_retries (celery.app.task.BaseTask attribute) (Task attribute) max_tasks_per_child (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) maxlen (celery.datastructures.LimitedSet attribute) MaxRetriesExceededError maybe_conn_error() (celery.worker.consumer.Consumer method) maybe_declare() (celery.backends.amqp.AMQPBackend.Producer method) maybe_drop_privileges() (in module celery.platforms) maybe_due() (celery.beat.Scheduler method) maybe_expire() (celery.worker.job.Request method) maybe_iso8601() (in module celery.utils.timeutils) maybe_list() (in module celery.utils.functional) maybe_reraise() (in module celery.utils) maybe_schedule() (in module celery.schedules) maybe_timedelta() (in module celery.utils.timeutils) maybe_utf8() (in module celery.task.http)

Mediator (class in celery.worker.mediator) mediator_cls (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) memoize() (in module celery.utils.functional) merge() (celery.events.state.Task method) (celery.worker.state.Persistent method) merge_inplace() (celery.beat.Scheduler method) merge_rules (celery.events.state.Task attribute) Message (class in celery.utils.mail) Message() (celery.backends.amqp.AMQPBackend.Exchange method) method (celery.task.http.HttpDispatchTask attribute), [1] mget() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.redis.RedisBackend method) migrate (class in celery.bin.celery) migrate_task() (in module celery.contrib.migrate) migrate_tasks() (in module celery.contrib.migrate) minute (celery.schedules.crontab attribute) mlevel() (in module celery.utils.log) mode (celery.utils.log.LoggingProxy attribute) module_file() (in module celery.utils.imports) modules() (celery.worker.abstract.Namespace method) (celery.worker.Namespace method) MongoBackend (class in celery.backends.mongodb) mongodb_database (celery.backends.mongodb.MongoBackend attribute) mongodb_host (celery.backends.mongodb.MongoBackend attribute) mongodb_password (celery.backends.mongodb.MongoBackend attribute) mongodb_port (celery.backends.mongodb.MongoBackend attribute) mongodb_taskmeta_collection (celery.backends.mongodb.MongoBackend attribute) mongodb_user (celery.backends.mongodb.MongoBackend attribute) Monitor (celery.worker.autoreload.Autoreloader attribute) (in module celery.worker.autoreload) move() (celery.worker.mediator.Mediator method) move_selection() (celery.events.cursesmon.CursesMonitor method) move_selection_down() (celery.events.cursesmon.CursesMonitor method) move_selection_up() (celery.events.cursesmon.CursesMonitor method) mpromise (class in celery.utils.functional) mro_lookup() (in module celery.task.trace) multi_args() (in module celery.bin.celeryd_multi) multi_call() (celery.app.control.Control.Mailbox method) MultiTool (class in celery.bin.celeryd_multi) MutableURL (class in celery.task.http)

N

name (celery.app.task.BaseTask attribute) (Task attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] (celery.backends.amqp.AMQPBackend.Queue attribute), [1] (celery.beat.ScheduleEntry attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) (celery.contrib.abortable.AbortableTask attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.task.http.HttpDispatchTask attribute) (celery.utils.log.LoggingProxy attribute) (celery.worker.Beat attribute) (celery.worker.Namespace attribute) (celery.worker.Pool attribute) (celery.worker.Queues attribute) (celery.worker.StateDB attribute) (celery.worker.Timers attribute) (celery.worker.abstract.Component attribute) (celery.worker.abstract.Namespace attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.consumer.Component attribute) (celery.worker.job.Request attribute) (celery.worker.mediator.WorkerComponent attribute) names() (celery.bin.celeryd_multi.MultiTool method) namespace (celery.app.control.Control.Mailbox attribute) (celery.bin.base.Command attribute) (celery.bin.celeryd.WorkerCommand attribute) (celery.worker.Beat attribute) (celery.worker.Pool attribute) (celery.worker.Queues attribute) (celery.worker.StateDB attribute) (celery.worker.Timers attribute) (celery.worker.abstract.Component attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.consumer.Component attribute) (celery.worker.mediator.WorkerComponent attribute) Namespace (class in celery.worker) (class in celery.worker.abstract) NamespacedOptionParser (class in celery.bin.celeryd_multi) nap() (celery.events.cursesmon.CursesMonitor method) needs_reconnect (celery.bin.camqadm.AMQShell attribute) new_missing() (celery.app.amqp.Queues method) next() (celery.beat.ScheduleEntry method) (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) no_ack (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.backends.amqp.AMQPBackend.Queue 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.celeryd_multi.MultiTool method) node_cls (celery.app.control.Control.Mailbox attribute) noop() (in module celery.utils.functional) NOSE_VERBOSE NotAPackage NotConfigured note() (celery.bin.camqadm.AMQPAdmin method) (celery.bin.camqadm.AMQShell method) (celery.bin.celeryd_multi.MultiTool method) NotRegistered now() (celery.loaders.base.BaseLoader method) (celery.schedules.schedule method) NullDict (class in celery.concurrency.threads) num_processes (celery.concurrency.base.BasePool attribute) (celery.concurrency.gevent.TaskPool attribute) (celery.concurrency.processes.TaskPool attribute)

O

obj (celery.worker.abstract.Component attribute) OK (celery.bin.celeryd_multi.MultiTool attribute) on_accepted() (celery.worker.job.Request method) on_ack (celery.worker.job.Request attribute) on_apply() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.threads.TaskPool method) on_bound() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) on_change() (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) on_chord_apply() (celery.backends.base.BaseBackend method) (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) on_chord_part_return() (celery.backends.base.BaseBackend method) (celery.backends.base.KeyValueStoreBackend method) on_cleanup() (celery.events.snapshot.Polaroid method) on_consumer_ready() (celery.apps.worker.Worker method) on_control() (celery.worker.consumer.Consumer 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_error (celery.concurrency.base.BasePool.Timer.Schedule attribute) (celery.utils.timer2.Schedule attribute) (celery.utils.timer2.Timer.Schedule attribute) on_event() (celery.events.dumper.Dumper method) on_failed() (celery.events.state.Task method) on_failure() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) (celery.worker.job.Request method) on_heartbeat() (celery.events.state.Worker method) on_migrate_task() (celery.bin.celery.migrate method) on_offline() (celery.events.state.Worker method) on_online() (celery.events.state.Worker method) on_process_cleanup() (celery.loaders.base.BaseLoader method) on_received() (celery.events.state.Task method) on_retried() (celery.events.state.Task method) on_retry() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) (celery.worker.job.Request method) on_return (celery.backends.amqp.AMQPBackend.Producer attribute) on_revoked() (celery.events.state.Task method)

on_sent() (celery.events.state.Task method) on_shutter() (celery.events.snapshot.Polaroid method) on_SIGINT() (in module celery.apps.worker) on_start() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.threads.TaskPool method) on_started() (celery.events.state.Task method) on_stop() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.threads.TaskPool method) on_succeeded() (celery.events.state.Task method) on_success() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) (celery.worker.job.Request method) on_task() (celery.worker.consumer.Consumer method) on_task_init() (celery.loaders.base.BaseLoader method) on_terminate() (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool method) on_tick (celery.concurrency.base.BasePool.Timer attribute) (celery.utils.timer2.Timer attribute) on_timeout() (celery.worker.job.Request method) on_timer_error() (celery.worker.Timers method) on_timer_tick() (celery.worker.Timers method) on_unknown_event() (celery.events.state.Task method) on_worker_init() (celery.loaders.base.BaseLoader method) on_worker_process_init() (celery.loaders.base.BaseLoader method) onecmd() (celery.bin.camqadm.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) option_list (celery.bin.base.Command attribute) (celery.bin.celery.Command attribute) (celery.bin.celery.apply attribute) (celery.bin.celery.inspect attribute) (celery.bin.celery.result attribute) (celery.bin.celery.shell attribute) (celery.bin.celery.status attribute) options (celery.beat.ScheduleEntry attribute) optmerge() (celery.bin.celeryd_multi.NamespacedOptionParser method) osx_proxy_detection_workaround() (celery.apps.worker.Worker method) out() (celery.bin.celery.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.AsyncResult attribute) parse() (celery.bin.celeryd_multi.NamespacedOptionParser method) (celery.schedules.crontab_parser method) parse_doc() (celery.bin.base.Command method) parse_gid() (in module celery.platforms) parse_ns_range() (in module celery.bin.celeryd_multi) parse_options() (celery.bin.base.Command method) parse_preload_options() (celery.bin.base.Command method) parse_uid() (in module celery.platforms) ParseException parseline() (celery.bin.camqadm.AMQShell method) Parser (celery.bin.base.Command attribute) password (celery.backends.redis.RedisBackend attribute) PATH path (celery.platforms.PIDFile attribute) PENDING state periodic() (celery.app.registry.TaskRegistry method) periodic_task() (in module celery.task) PeriodicTask (class in celery.task.base) persistence (celery.beat.PersistentScheduler attribute) Persistent (class in celery.worker.state) PERSISTENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute) PersistentScheduler (class in celery.beat) Pickler pid (celery.concurrency.processes.TaskPool.Pool.Process attribute) pidbox_node (celery.worker.consumer.Consumer attribute) PIDFile (class in celery.platforms) ping control ping() (celery.app.control.Control method) (celery.app.control.Inspect method) (in module celery.worker.control) pluralize() (in module celery.utils.text) Polaroid (class in celery.events.snapshot) poll() (celery.backends.amqp.AMQPBackend method) pool (celery.worker.consumer.Consumer attribute) Pool (class in celery.worker) pool_cls (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) pool_grow() (in module celery.worker.control) pool_putlocks (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) pool_restart() (in module celery.worker.control) pool_shrink() (in module celery.worker.control) pop_value() (celery.datastructures.LimitedSet method) port (celery.backends.redis.RedisBackend attribute) post_async() (celery.task.http.URL method) PRECEDENCE (in module celery.states)

precedence() (in module celery.states) PREFETCH_COUNT_MAX (in module celery.worker.consumer) prefetch_multiplier (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) preload_options (celery.bin.base.Command attribute) (celery.bin.celerybeat.BeatCommand attribute) (celery.bin.celeryev.EvCommand attribute) prepare() (celery.app.utils.AppPickler method) (in module celery.app.annotations) (in module celery.app.routes) prepare_args() (celery.bin.base.Command method) prepare_exception() (celery.backends.base.BaseBackend method) prepare_expires() (celery.backends.base.BaseBackend method) prepare_parser() (celery.bin.base.Command method) prepare_preload_options() (celery.bin.base.Command method) (celery.bin.celerybeat.BeatCommand method) (celery.bin.celeryev.EvCommand method) prepare_value() (celery.backends.base.BaseBackend method) prettify() (celery.bin.celery.Command method) prettify_dict_ok_error() (celery.bin.celery.Command method) prettify_list() (celery.bin.celery.Command method) pretty() (in module celery.utils.text) prev (celery.worker.consumer.QoS attribute) priority (celery.app.task.BaseTask attribute) (Task attribute) priority_timer (celery.worker.consumer.Consumer attribute) PrivateKey (class in celery.security.key) process() (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_IN_ATTRIB() (celery.worker.autoreload.InotifyMonitor method) process_IN_MODIFY() (celery.worker.autoreload.InotifyMonitor method) process_initializer() (in module celery.concurrency.processes) process_long_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method) process_short_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method) process_task() (celery.apps.worker.Worker.WorkController method) (celery.worker.WorkController method) processes (celery.worker.autoscale.Autoscaler attribute) prog_name (celery.bin.celery.CeleryCommand attribute) (celery.bin.celery.Command attribute) prompt (celery.bin.camqadm.AMQShell attribute) prompt_fmt (celery.bin.camqadm.AMQShell attribute) PROPAGATE_STATES state publish() (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Producer method) publisher (celery.beat.Scheduler attribute) publisher_pool (celery.app.amqp.AMQP attribute) purge (class in celery.bin.celery) purge() (celery.app.control.Control method) (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Queue method) purge_messages() (celery.apps.worker.Worker method) put() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) put_nowait() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) pyimplementation() (in module celery.platforms) Python Enhancement Proposals PEP 8

Q

QoS (class in celery.worker.consumer) qos() (celery.backends.amqp.AMQPBackend.Consumer method) qsize() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) qty (celery.worker.autoscale.Autoscaler attribute) qualname() (in module celery.utils.imports) queue (celery.app.task.BaseTask attribute) (Task attribute) (celery.concurrency.base.BasePool.Timer attribute) (celery.concurrency.base.BasePool.Timer.Schedule attribute) (celery.concurrency.eventlet.Schedule attribute) (celery.concurrency.eventlet.TaskPool.Timer.Schedule attribute) (celery.concurrency.eventlet.Timer.Schedule attribute) (celery.concurrency.gevent.Schedule attribute) (celery.concurrency.gevent.TaskPool.Timer.Schedule attribute) (celery.concurrency.gevent.Timer.Schedule attribute) (celery.utils.timer2.Schedule attribute) (celery.utils.timer2.Timer attribute) (celery.utils.timer2.Timer.Schedule attribute) queue_arguments (celery.backends.amqp.AMQPBackend.Queue attribute)

queue_bind() (celery.backends.amqp.AMQPBackend.Queue method) queue_declare() (celery.backends.amqp.AMQPBackend.Queue method) QueueNotFound queues (celery.app.amqp.AMQP attribute) (celery.backends.amqp.AMQPBackend.Consumer attribute) Queues (class in celery.app.amqp) (class in celery.worker) Queues() (celery.app.amqp.AMQP method) quote() (in module celery.bin.celeryd_multi)

R

rate() (in module celery.utils.timeutils) rate_limit control rate_limit (celery.app.task.BaseTask attribute) (Task attribute) (celery.contrib.abortable.AbortableTask attribute) (celery.task.http.HttpDispatchTask attribute) rate_limit() (celery.app.control.Control method) (in module celery.worker.control) RateLimitExceeded 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.Task attribute) ready() (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) ready_queue (celery.worker.consumer.Consumer attribute) (celery.worker.mediator.Mediator attribute) READY_STATES state READY_STATES (celery.backends.base.BaseBackend attribute) receive() (celery.backends.amqp.AMQPBackend.Consumer method) receive_message() (celery.worker.consumer.Consumer method) Receiver (celery.events.Events attribute) receivers (celery.utils.dispatch.signal.Signal attribute) recover() (celery.backends.amqp.AMQPBackend.Consumer method) red() (celery.utils.term.colored method) redirect_stdouts (celery.apps.beat.Beat attribute) (celery.apps.worker.Worker attribute) redirect_stdouts_level (celery.apps.beat.Beat attribute) (celery.apps.worker.Worker attribute) redirect_stdouts_to_logger() (celery.app.log.Logging method) (celery.apps.worker.Worker method) redis (celery.backends.redis.RedisBackend attribute) RedisBackend (class in celery.backends.redis) refresh() (celery.worker.buckets.TaskBucket method) 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) registered() (celery.app.control.Inspect method) registered_tasks() (celery.app.control.Inspect method) regular() (celery.app.registry.TaskRegistry method) relative (celery.schedules.schedule attribute) release() (celery.backends.amqp.AMQPBackend.Producer method) (celery.platforms.PIDFile method) reload() (celery.apps.worker.Worker.WorkController method) (celery.worker.WorkController method) reload_from_cwd() (in module celery.utils.imports) reload_task_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) reload_taskset_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) remaining() (in module celery.utils.timeutils) remaining_estimate() (celery.schedules.crontab method) (celery.schedules.schedule method) RemoteExecuteError remove() (celery.platforms.PIDFile method) (celery.result.ResultSet method) remove_by (celery.app.defaults.Option attribute) remove_if_stale() (celery.platforms.PIDFile method) remove_options_at_beginning() (celery.bin.celery.CeleryCommand method) repair_uuid() (in module celery.backends.amqp) replace() (subtask method) reply_exchange (celery.app.control.Control.Mailbox attribute) reply_exchange_fmt (celery.app.control.Control.Mailbox attribute) report (class in celery.bin.celery) report() (celery.app.control.Inspect method) (in module celery.worker.control) report_internal_error() (in module celery.task.trace) repr_result() (celery.worker.job.Request method) request (celery.app.task.BaseTask attribute) Request (class in celery.worker.job)

request (Task attribute) request_dict (celery.worker.job.Request attribute) requires (celery.worker.abstract.Component attribute) (celery.worker.Pool attribute) (celery.worker.Timers attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.mediator.WorkerComponent attribute) requires_mediator (celery.concurrency.base.BasePool attribute) (celery.concurrency.processes.TaskPool 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.platforms.Signals method) (celery.utils.term.colored method) reset_connection() (celery.worker.consumer.Consumer method) reset_multiprocessing_logger() (in module celery.utils.log) reset_pidbox_node() (celery.worker.consumer.Consumer method) resetscreen() (celery.events.cursesmon.CursesMonitor method) resolve_all() (in module celery.app.annotations) respond() (celery.bin.camqadm.AMQShell method) restart() (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool method) restart_heartbeat() (celery.worker.consumer.Consumer method) restore() (celery.result.TaskSetResult class method) (celery.utils.serialization.UnpickleableExceptionWrapper method) restore_taskset() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) result (celery.backends.database.models.Task attribute) (celery.backends.database.models.TaskSet attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) (class in celery.bin.celery) ResultBase (class in celery.result) results (celery.result.ResultSet attribute) (celery.result.TaskSetResult attribute) ResultSession() (celery.backends.database.DatabaseBackend method) (in module celery.backends.database.session) ResultSet (class in celery.result) retcode (celery.bin.celeryd_multi.MultiTool attribute) RETRY state retry() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) retry_msg (celery.worker.job.Request attribute) RetryTaskError retval (celery.task.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) (in module celery.worker.control) REVOKE_EXPIRES (in module celery.worker.state) revoke_selection() (celery.events.cursesmon.CursesMonitor method) REVOKED state revoked (in module celery.worker.state) revoked() (celery.app.control.Inspect method) (celery.worker.job.Request method) REVOKES_MAX (in module celery.worker.state) rlimit_safe (celery.concurrency.base.BasePool attribute) (celery.concurrency.eventlet.TaskPool attribute) (celery.concurrency.gevent.TaskPool attribute) 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.app.task.BaseTask attribute) (Task attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.backends.amqp.AMQPBackend.Queue attribute), [1] RUN (celery.apps.worker.Worker.WorkController attribute) (celery.concurrency.base.BasePool attribute) (celery.worker.WorkController attribute) run() (celery.app.task.BaseTask method) (celery.apps.beat.Beat method) (celery.apps.worker.Worker method) (celery.bin.base.Command method) (celery.bin.camqadm.AMQPAdmin method) (celery.bin.camqadm.AMQPAdminCommand method) (celery.bin.celery.Delegate method) (celery.bin.celery.apply method) (celery.bin.celery.help method) (celery.bin.celery.inspect method) (celery.bin.celery.list_ method) (celery.bin.celery.migrate method) (celery.bin.celery.purge method) (celery.bin.celery.report method) (celery.bin.celery.result method) (celery.bin.celery.shell method) (celery.bin.celery.status method) (celery.bin.celerybeat.BeatCommand method) (celery.bin.celeryd.WorkerCommand method) (celery.bin.celeryev.EvCommand method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.contrib.batches.Batches method) (celery.events.cursesmon.DisplayThread method) (celery.task.base.BaseTask method) (celery.task.http.HttpDispatchTask method) (celery.utils.threads.bgThread method) (celery.utils.timer2.Timer method) run_evcam() (celery.bin.celeryev.EvCommand method) run_evdump() (celery.bin.celeryev.EvCommand method) run_evtop() (celery.bin.celeryev.EvCommand method) run_from_argv() (celery.bin.celery.Command method) run_worker() (celery.apps.worker.Worker method) running (celery.concurrency.base.BasePool.Timer attribute) (celery.utils.timer2.Timer attribute)

S

s() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) safe_add_str() (celery.events.cursesmon.CursesMonitor method) safe_ref() (in module celery.utils.dispatch.saferef) save() (celery.result.TaskSetResult method) (celery.worker.state.Persistent method) save_taskset() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) say() (celery.bin.camqadm.AMQShell method) (celery.bin.celery.inspect method) (celery.bin.celeryd_multi.MultiTool method) (celery.events.dumper.Dumper method) (in module celery.bin.camqadm) (in module celery.events.dumper) scale_down() (celery.worker.autoscale.Autoscaler method) scale_up() (celery.worker.autoscale.Autoscaler method) schedule (celery.apps.beat.Beat attribute) (celery.beat.PersistentScheduler attribute) (celery.beat.ScheduleEntry attribute) (celery.beat.Scheduler attribute) Schedule (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) schedule (class in celery.schedules) Schedule (class in celery.utils.timer2) schedule_filename (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) 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 attribute) (celery.apps.beat.Beat.Service attribute) (celery.apps.worker.Worker.WorkController attribute) (celery.beat.Service attribute) (celery.worker.WorkController 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_queues() select_subset() (celery.app.amqp.Queues method) selected_position (celery.events.cursesmon.CursesMonitor attribute) selected_str (celery.events.cursesmon.CursesMonitor attribute) selected_task (celery.events.cursesmon.CursesMonitor attribute) selection_info() (celery.events.cursesmon.CursesMonitor method) selection_rate_limit() (celery.events.cursesmon.CursesMonitor method) selection_result() (celery.events.cursesmon.CursesMonitor method) selection_traceback() (celery.events.cursesmon.CursesMonitor method) send() (celery.events.EventDispatcher method) (celery.utils.dispatch.signal.Signal method) (celery.utils.mail.ErrorMail method) (celery.utils.mail.Mailer method) send_error_emails (celery.app.task.BaseTask attribute) (Task attribute) send_event() (celery.worker.job.Request method) send_events (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) (celery.worker.consumer.Consumer attribute) send_robust() (celery.utils.dispatch.signal.Signal method) send_task() (celery.beat.Scheduler method) SendmailWarning sentinel (celery.concurrency.processes.TaskPool.Pool.Process attribute) serializable() (celery.result.AsyncResult method) (celery.result.TaskSetResult method) serialize() (celery.security.serialization.SecureSerializer method) serializer (celery.app.task.BaseTask attribute) (Task attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.contrib.abortable.AbortableTask attribute) (celery.task.http.HttpDispatchTask attribute) SERVER_EMAIL setting servers (celery.backends.cache.CacheBackend attribute) (celery.backends.cassandra.CassandraBackend attribute), [1] Service (class in celery.beat) set() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.redis.RedisBackend method) (celery.worker.consumer.QoS method) (subtask method) set_current() set_default_app() (in module celery.app.state) set_mp_process_title() (in module celery.platforms) set_parent() (celery.result.AsyncResult method) set_process_status() (celery.apps.worker.Worker method) (celery.bin.celeryev.EvCommand method) set_process_title() (celery.apps.beat.Beat method) (in module celery.platforms) set_schedule() (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) set_trace() (in module celery.contrib.rdb) setdefault() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) setegid() (in module celery.platforms) seteuid() (in module celery.platforms) setgid() (in module celery.platforms) setgroups() (in module celery.platforms) setting ADMINS BROKER_CONNECTION_MAX_RETRIES BROKER_CONNECTION_RETRY BROKER_CONNECTION_TIMEOUT BROKER_HOST BROKER_PASSWORD BROKER_POOL_LIMIT BROKER_PORT BROKER_TRANSPORT BROKER_TRANSPORT_OPTIONS BROKER_URL BROKER_USER BROKER_USE_SSL BROKER_VHOST CASSANDRA_COLUMN_FAMILY CASSANDRA_DETAILED_MODE CASSANDRA_KEYSPACE CASSANDRA_READ_CONSISTENCY CASSANDRA_SERVERS CASSANDRA_WRITE_CONSISTENCY CELERYBEAT_LOG_FILE CELERYBEAT_LOG_LEVEL CELERYBEAT_MAX_LOOP_INTERVAL CELERYBEAT_SCHEDULE CELERYBEAT_SCHEDULER CELERYBEAT_SCHEDULE_FILENAME CELERYD_AUTORELOADER CELERYD_AUTOSCALER CELERYD_BOOT_STEPS CELERYD_CONCURRENCY CELERYD_CONSUMER CELERYD_ETA_SCHEDULER CELERYD_ETA_SCHEDULER_PRECISION CELERYD_FORCE_EXECV CELERYD_HIJACK_ROOT_LOGGER CELERYD_LOG_COLOR CELERYD_LOG_FILE CELERYD_LOG_FORMAT CELERYD_LOG_LEVEL CELERYD_MAX_TASKS_PER_CHILD CELERYD_MEDIATOR CELERYD_POOL CELERYD_PREFETCH_MULTIPLIER CELERYD_STATE_DB CELERYD_TASK_LOG_FORMAT CELERYD_TASK_SOFT_TIME_LIMIT CELERYD_TASK_TIME_LIMIT CELERYD_WORKER_LOST_WAIT CELERYMON_LOG_FILE CELERYMON_LOG_FORMAT CELERYMON_LOG_LEVEL CELERY_ACKS_LATE CELERY_ALWAYS_EAGER CELERY_AMQP_TASK_RESULT_EXPIRES CELERY_ANNOTATIONS CELERY_BROADCAST_EXCHANGE CELERY_BROADCAST_EXCHANGE_TYPE CELERY_BROADCAST_QUEUE CELERY_CACHE_BACKEND CELERY_CACHE_BACKEND_OPTIONS CELERY_CREATE_MISSING_QUEUES CELERY_DEFAULT_DELIVERY_MODE CELERY_DEFAULT_EXCHANGE CELERY_DEFAULT_EXCHANGE_TYPE CELERY_DEFAULT_QUEUE CELERY_DEFAULT_RATE_LIMIT CELERY_DEFAULT_ROUTING_KEY CELERY_DISABLE_RATE_LIMITS CELERY_EAGER_PROPAGATES_EXCEPTIONS CELERY_ENABLE_UTC CELERY_EVENT_SERIALIZER CELERY_IGNORE_RESULT CELERY_IMPORTS CELERY_MAX_CACHED_RESULTS CELERY_MESSAGE_COMPRESSION CELERY_MONGODB_BACKEND_SETTINGS CELERY_QUEUES CELERY_REDIRECT_STDOUTS CELERY_REDIRECT_STDOUTS_LEVEL CELERY_REDIS_DB CELERY_REDIS_HOST CELERY_REDIS_MAX_CONNECTIONS CELERY_REDIS_PASSWORD CELERY_REDIS_PORT CELERY_RESULT_BACKEND CELERY_RESULT_DBURI CELERY_RESULT_DB_SHORT_LIVED_SESSIONS CELERY_RESULT_DB_SHORT_LIVED_SESSIONS = True 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_ERROR_WHITELIST CELERY_TASK_PUBLISH_RETRY CELERY_TASK_PUBLISH_RETRY_POLICY CELERY_TASK_RESULT_EXPIRES CELERY_TASK_SERIALIZER CELERY_TIMEZONE CELERY_TRACK_STARTED 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.app.abstract.configurated method) setup_handlers() (celery.app.log.Logging method) setup_logger() (celery.app.log.Logging method) setup_logging signal setup_logging() (celery.apps.beat.Beat method) setup_logging_subsystem() (celery.app.log.Logging method) setup_results() (in module celery.backends.database.session) setup_schedule() (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) setup_security() (in module celery.security) setup_settings() (celery.loaders.default.Loader method) setup_task_loggers() (celery.app.log.Logging method)

shared_task() (in module celery.app.builtins) Shell (celery.bin.camqadm.AMQPAdmin attribute) shell (class in celery.bin.celery) shellsplit() (in module celery.platforms) shortinfo() (celery.worker.job.Request method) should_send() (celery.app.task.BaseTask.ErrorMail method) (celery.task.base.BaseTask.ErrorMail method) (celery.utils.mail.ErrorMail method) should_sync() (celery.beat.Scheduler method) show() (celery.bin.celeryd_multi.MultiTool method) show_body (celery.bin.celery.inspect attribute) show_help() (celery.bin.celery.Command method) shrink() (celery.concurrency.gevent.TaskPool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool method) shutdown control shutdown() (in module celery.worker.control) shutdown_nodes() (celery.bin.celeryd_multi.MultiTool method) shutter() (celery.events.snapshot.Polaroid method) shutter_signal (celery.events.snapshot.Polaroid attribute) sign() (celery.security.key.PrivateKey method) signal after_setup_logger after_setup_task_logger beat_embedded_init beat_init celeryd_init eventlet_pool_apply eventlet_pool_postshutdown eventlet_pool_preshutdown eventlet_pool_started setup_logging task_failure task_postrun task_prerun task_sent worker_init worker_process_init worker_ready worker_shutdown Signal (class in celery.utils.dispatch.signal) signal_node() (celery.bin.celeryd_multi.MultiTool method) signal_safe (celery.concurrency.base.BasePool attribute) (celery.concurrency.eventlet.TaskPool attribute) (celery.concurrency.gevent.TaskPool attribute) Signals (class in celery.platforms) signum() (celery.platforms.Signals method) SimpleRequest (class in celery.contrib.batches) soft_time_limit (celery.app.task.BaseTask attribute) (Task attribute) SOFTWARE_INFO (in module celery.worker.state) Spec (class in celery.bin.camqadm) splash() (celery.bin.celeryd_multi.MultiTool method) starmap() (celery.concurrency.processes.TaskPool.Pool method) starmap_async() (celery.concurrency.processes.TaskPool.Pool method) start() (celery.apps.beat.Beat.Service method) (celery.apps.worker.Worker.WorkController method) (celery.beat.Service method) (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.eventlet.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.concurrency.gevent.Timer method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.worker.WorkController method) (celery.worker.abstract.StartStopComponent method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.autoreload.StatMonitor method) (celery.worker.consumer.Consumer method) (celery.worker.heartbeat.Heart method) start_scheduler() (celery.apps.beat.Beat method) STARTED state StartStopComponent (class in celery.worker.abstract) startup_info() (celery.apps.beat.Beat method) (celery.apps.worker.Worker method) state ALL_STATES EXCEPTION_STATES FAILURE PENDING PROPAGATE_STATES READY_STATES RETRY REVOKED STARTED SUCCESS UNREADY_STATES state (celery.apps.worker.Worker.WorkController attribute) State (celery.events.Events attribute) state (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) (celery.task.trace.TraceInfo attribute) (celery.worker.WorkController attribute) State (class in celery.contrib.migrate) (class in celery.events.state) state (class in celery.states) state_db (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) StateDB (class in celery.worker) StatMonitor (class in celery.worker.autoreload) stats() (celery.app.control.Inspect method) (in module celery.worker.control) status (celery.backends.database.models.Task attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) (class in celery.bin.celery) stop() (celery.apps.beat.Beat.Service method) (celery.apps.worker.Worker.WorkController method) (celery.beat.Service method) (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.base.BasePool method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.eventlet.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.concurrency.gevent.Timer method) (celery.utils.threads.bgThread method) (celery.utils.timer2.Timer method) (celery.worker.WorkController method) (celery.worker.abstract.StartStopComponent method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.consumer.Consumer method) (celery.worker.heartbeat.Heart method) stop_consumers() (celery.worker.consumer.Consumer method) stop_pidbox_node() (celery.worker.consumer.Consumer method) stop_verify() (celery.bin.celeryd_multi.MultiTool method) storage (celery.worker.state.Persistent attribute) store_errors (celery.worker.job.Request attribute) store_errors_even_if_ignored (celery.app.task.BaseTask attribute) (Task attribute) store_result() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.backends.base.DisabledBackend method) str_args_to_python() (celery.bin.camqadm.Spec method) str_to_bool() (in module celery.app.defaults) strargv() (in module celery.platforms) Strategy (celery.app.task.BaseTask attribute) strtb (celery.task.trace.TraceInfo attribute) 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 (built-in class) subtask() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) subtasks (celery.result.ResultSet attribute) SUCCESS state success_msg (celery.worker.job.Request attribute) successful() (celery.result.AsyncResult method) (celery.result.ResultSet method) supported() (celery.platforms.Signals method) supports_args (celery.bin.base.Command attribute) (celery.bin.celerybeat.BeatCommand attribute) (celery.bin.celeryd.WorkerCommand attribute) (celery.bin.celeryev.EvCommand attribute) supports_color() (celery.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.ResultSet attribute) supports_timeout (celery.utils.mail.Mailer 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) SystemTerminate

T

Task task (celery.worker.job.Request attribute) Task (class in celery.backends.database.models) (class in celery.events.state) (class in celery.task) task() (in module celery.task) task_accepted() (in module celery.worker.state) task_consumer (celery.worker.consumer.Consumer attribute) task_count (celery.events.state.State attribute) task_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_keyprefix (celery.backends.base.KeyValueStoreBackend attribute) task_name (celery.worker.job.Request attribute) task_postrun signal task_prerun signal task_ready() (in module celery.worker.state) task_reserved() (in module celery.worker.state) task_sent signal task_soft_time_limit (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) task_time_limit (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) task_types() (celery.events.state.State method) TaskBucket (class in celery.worker.buckets) TaskConsumer (celery.app.amqp.AMQP attribute) TaskFormatter (class in celery.app.log) tasklist() (celery.apps.worker.Worker method) TaskPool (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) (class in celery.concurrency.processes) (class in celery.concurrency.solo) (class in celery.concurrency.threads) TaskPool.Pool (class in celery.concurrency.processes) TaskPool.Pool.Process (class in celery.concurrency.processes) TaskPool.Pool.ResultHandler (class in celery.concurrency.processes) TaskPool.Pool.SoftTimeLimitExceeded TaskPool.Pool.Supervisor (class in celery.concurrency.processes) TaskPool.Pool.TaskHandler (class in celery.concurrency.processes) TaskPool.Pool.TimeoutHandler (class in celery.concurrency.processes) TaskPool.Timer (class in celery.concurrency.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 (in module celery.app.amqp) TaskRegistry (class in celery.app.registry) TaskRegistry.NotRegistered TaskRequest (class in celery.worker.job) TaskRevokedError tasks (celery.events.cursesmon.CursesMonitor attribute) (celery.task.sets.TaskSet attribute) 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) (class in celery.task.sets) taskset_id (celery.backends.database.models.TaskSet attribute) (celery.result.TaskSetResult attribute) taskset_keyprefix (celery.backends.base.KeyValueStoreBackend attribute) TaskSetResult (class in celery.result) TaskType (class in celery.app.task) (class in celery.task.base) tb (celery.datastructures.ExceptionInfo attribute) (celery.task.trace.TraceInfo attribute) terminable (celery.worker.abstract.StartStopComponent attribute) TERMINATE (celery.apps.worker.Worker.WorkController attribute) (celery.concurrency.base.BasePool attribute) (celery.worker.WorkController attribute) terminate() (celery.apps.worker.Worker.WorkController method) (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.worker.WorkController method) (celery.worker.abstract.StartStopComponent method) (celery.worker.job.Request method) terminate_job() (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool method) thaw() (State method) Thread (class in celery.utils.threads) tick() (celery.beat.Scheduler method) time_limit (celery.app.task.BaseTask attribute) (Task attribute) time_limit() (celery.app.control.Control method) (in module celery.worker.control) time_start (celery.worker.job.Request attribute) timedelta_seconds() (in module celery.utils.timeutils) timeout (celery.task.http.HttpDispatch attribute) TimeoutError timer (celery.events.snapshot.Polaroid attribute) Timer (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) (class in celery.utils.timer2) Timer.Entry (class in celery.utils.timer2) Timer.Schedule (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) (class in celery.utils.timer2) Timers (class in celery.worker) to_dict() (celery.backends.database.models.Task method) (celery.backends.database.models.TaskSet method) to_python() (celery.app.defaults.Option method) to_timestamp() (in module celery.utils.timer2) TokenBucketQueue (class in celery.worker.buckets) TokenBucketQueue.RateLimitExceeded total (celery.result.ResultSet attribute) total_apx (celery.contrib.migrate.State attribute) total_count (in module celery.worker.state) total_run_count (celery.beat.ScheduleEntry attribute) trace_task() (in module celery.task.trace) traceback (celery.backends.database.models.Task attribute) (celery.datastructures.ExceptionInfo attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) TraceInfo (class in celery.task.trace) track_started (celery.app.task.BaseTask attribute) (Task attribute) TRANSIENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange attribute) truncate() (in module celery.utils.text) type (celery.app.control.Control.Mailbox attribute) (celery.app.task.BaseTask attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute), [1] (celery.datastructures.ExceptionInfo attribute) typemap (celery.app.defaults.Option attribute) tzlocal (celery.worker.job.Request attribute)

U

umask (celery.platforms.DaemonContext attribute) unbind() (celery.backends.amqp.AMQPBackend.Queue method) underline() (celery.utils.term.colored method) uniq() (in module celery.utils.functional) UNKNOWN_TASK_ERROR (in module celery.worker.consumer) UnknownStatusError unpickle_backend() (in module celery.backends.base) UnpickleableExceptionWrapper UNREADY_STATES state UNREADY_STATES (celery.backends.base.BaseBackend attribute) unregister() (celery.app.registry.TaskRegistry method)

unwanted_base_classes (in module celery.utils.serialization) update() (celery.beat.ScheduleEntry method) (celery.datastructures.ConfigurationView method) (celery.datastructures.LimitedSet method) (celery.events.state.Task method) (celery.platforms.Signals method) (celery.result.ResultSet method) (celery.worker.autoscale.Autoscaler method) (celery.worker.consumer.QoS method) update_bucket_for_type() (celery.worker.buckets.TaskBucket method) update_from_dict() (celery.beat.Scheduler method) update_state() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) update_strategies() (celery.worker.consumer.Consumer method) url (celery.task.http.HttpDispatchTask attribute), [1] URL (class in celery.task.http) usage() (celery.bin.base.Command method) (celery.bin.celery.Command method) (celery.bin.celery.help method) (celery.bin.celery.inspect method) (celery.bin.celery.migrate method) (celery.bin.celeryd_multi.MultiTool method) user_agent (celery.task.http.HttpDispatch attribute) utf8dict() (in module celery.task.http)

V

values() (celery.datastructures.ConfigurationView method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) verify() (celery.security.certificate.Certificate method)

version (celery.bin.base.Command attribute) (celery.bin.celery.Command attribute)

W

wait() (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TokenBucketQueue method) wait_for() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.DisabledBackend method) waitexec() (celery.bin.celeryd_multi.MultiTool method) waiting() (celery.result.ResultSet method) wakeup_workers() (celery.events.EventReceiver method) wanted_module_item() (celery.loaders.default.Loader method) warn_deprecated() (in module celery.utils) weak_func (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) weak_self (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) weekday() (in module celery.utils.timeutils) when_bound() (celery.backends.amqp.AMQPBackend.Queue method) white() (celery.utils.term.colored method) win (celery.events.cursesmon.CursesMonitor attribute) with_detacher_default_options() (celery.bin.celeryd_multi.MultiTool method) without_defaults() (celery.app.utils.Settings method) WorkController (class in celery.worker) workdir (celery.platforms.DaemonContext attribute) Worker (class in celery.apps.worker) worker (class in celery.bin.celery)

Worker (class in celery.events.state) Worker.WorkController (class in celery.apps.worker) worker_event() (celery.events.state.State method) worker_init signal worker_initialized (celery.loaders.base.BaseLoader attribute) worker_lost_wait (celery.apps.worker.Worker.WorkController attribute) (celery.worker.WorkController attribute) worker_main() worker_pid (celery.worker.job.Request attribute) worker_process_init signal worker_ready signal worker_shutdown signal WORKER_SIGIGNORE (in module celery.concurrency.processes) WORKER_SIGRESET (in module celery.concurrency.processes) WorkerCommand (class in celery.bin.celeryd) WorkerComponent (class in celery.worker.autoreload) (class in celery.worker.autoscale) (class in celery.worker.mediator) workers (celery.events.cursesmon.CursesMonitor attribute) write() (celery.utils.log.LoggingProxy method) write_pid() (celery.platforms.PIDFile method) writelines() (celery.utils.log.LoggingProxy method)

Y

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