Index

Symbols

--maxtasksperchild celeryd command line option --purge, --discard celeryd command line option --scheduler celeryd command line option --soft-time-limit celeryd command line option --time-limit celeryd command line option -B, --beat celeryd command line option -c, --concurrency celeryd command line option -E, --events celeryd command line option

-f, --logfile celerybeat command line option celeryd command line option -I, --include celeryd command line option -l, --loglevel celerybeat command line option celeryd command line option -n, --hostname celeryd command line option -Q, --queues celeryd command line option -s, --schedule celerybeat command line option celeryd command line option -S, --scheduler celerybeat command line option

_

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

A

abbr() (in module celery.utils) abbreviations() (in module celery.bin.celeryd_multi) abbrtask() (in module celery.utils) abcast() (celery.task.control.Control.Mailbox method) abort() (celery.contrib.abortable.AbortableAsyncResult method) AbortableAsyncResult (class in celery.contrib.abortable) AbortableTask (class in celery.contrib.abortable) abstract (celery.app.task.BaseTask attribute) (Task attribute) accept_magic_kwargs (celery.app.task.BaseTask attribute) accepted() (celery.concurrency.processes.pool.ApplyResult method) (celery.concurrency.processes.pool.MapResult method) acknowledge() (celery.worker.job.TaskRequest method) acknowledged (celery.worker.job.TaskRequest attribute) acks_late (celery.app.task.BaseTask attribute) (Task attribute) acquire() (celery.platforms.PIDFile method) active (celery.concurrency.base.BasePool attribute) active() (celery.task.control.Inspect method) active_queues() (celery.task.control.Inspect method) active_requests (in module celery.worker.state) add() (celery.app.amqp.Queues method) (celery.beat.Scheduler method) (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) add_bucket_for_type() (celery.worker.buckets.TaskBucket method) add_consumer() (celery.task.control.Inspect method) add_option() (celery.bin.celeryd_multi.NamespacedOptionParser method) add_queue() (celery.backends.amqp.AMQPBackend.Consumer method) ADMINS setting after_return() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) after_setup_logger signal after_setup_task_logger signal alert() (celery.events.cursesmon.CursesMonitor method) alert_remote_control_reply() (celery.events.cursesmon.CursesMonitor method) alias (celery.backends.amqp.AMQPBackend.Queue attribute) alive (celery.events.state.Worker attribute) alive_workers() (celery.events.state.State method) ALL_STATES state AlreadyRegistered amqp (celery.app.App attribute) (celery.bin.camqadm.AMQShell attribute) AMQP (class in celery.app.amqp)

AMQPAdmin (class in celery.bin.camqadm) AMQPAdminCommand (class in celery.bin.camqadm) AMQPBackend (class in celery.backends.amqp) AMQPBackend.BacklogLimitExceeded AMQPBackend.Consumer (class in celery.backends.amqp) AMQPBackend.Exchange (class in celery.backends.amqp) AMQPBackend.Producer (class in celery.backends.amqp) AMQPBackend.Queue (class in celery.backends.amqp) AMQShell (class in celery.bin.camqadm) app (celery.app.task.BaseTask attribute) App (class in celery.app) app_or_default() (in module celery.app) AppLoader (class in celery.loaders.app) apply (class in celery.bin.celeryctl) apply() (celery.app.task.BaseTask class method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.pool.Pool method) (celery.task.base.BaseTask class method) (celery.task.sets.TaskSet method) (celery.task.sets.subtask method) apply_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_async() (celery.app.task.BaseTask class method) (celery.beat.Scheduler method) (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.pool.Pool method) (celery.task.base.BaseTask class method) (celery.task.sets.TaskSet method) (celery.task.sets.subtask method) apply_at() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_buffer() (celery.contrib.batches.Batches method) apply_entry() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_eta_task() (celery.worker.consumer.Consumer method) apply_interval() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) apply_target() (in module celery.concurrency.base) (in module celery.concurrency.eventlet) ApplyResult (class in celery.concurrency.processes.pool) args (celery.beat.ScheduleEntry attribute) (celery.bin.base.Command attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.TaskRequest attribute) arguments (celery.backends.amqp.AMQPBackend.Exchange attribute) as_dict() (celery.datastructures.LimitedSet method) AsyncResult (class in celery.result) AsyncResult() (celery.app.App method) (celery.app.task.BaseTask class method) (celery.contrib.abortable.AbortableTask class method) (celery.task.base.BaseTask class method) AttributeDict (class in celery.datastructures) AttributeDictMixin (class in celery.datastructures) authkey (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) auto_delete (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) autoregister (celery.app.task.BaseTask attribute) Autoscaler (class in celery.worker.autoscale)

B

backend (celery.app.App attribute) (Task attribute) (celery.app.task.BaseTask attribute) (celery.result.AsyncResult attribute) (celery.result.BaseAsyncResult attribute) BacklogLimitExceeded BaseAsyncResult (class in celery.result) BaseBackend (class in celery.backends.base) BaseBackend.TimeoutError BaseDictBackend (class in celery.backends.base) BaseLoader (class in celery.loaders.base) BasePool (class in celery.concurrency.base) BasePool.Timer (class in celery.concurrency.base) BasePool.Timer.Entry (class in celery.concurrency.base) BasePool.Timer.Schedule (class in celery.concurrency.base) BaseTask (class in celery.app.task) (class in celery.task.base) BaseTask.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() (celery.app.App method) Beat.Service (class in celery.apps.beat) beat_embedded_init signal beat_init signal BeatCommand (class in celery.bin.celerybeat) bind() (queue method) binding_arguments (celery.backends.amqp.AMQPBackend.Queue attribute) black() (celery.utils.term.colored method) blink() (celery.utils.term.colored method) blue() (celery.utils.term.colored method)

body (celery.utils.mail.ErrorMail attribute) body() (celery.concurrency.processes.pool.Pool.ResultHandler method) (celery.concurrency.processes.TaskPool.Pool.ResultHandler method) (celery.concurrency.processes.TaskPool.Pool.Supervisor method) (celery.concurrency.processes.TaskPool.Pool.TaskHandler method) (celery.concurrency.processes.TaskPool.Pool.TimeoutHandler method) (celery.concurrency.processes.pool.Pool.Supervisor method) (celery.concurrency.processes.pool.Pool.TaskHandler method) (celery.concurrency.processes.pool.Pool.TimeoutHandler method) (celery.concurrency.processes.pool.ResultHandler method) (celery.concurrency.processes.pool.Supervisor method) (celery.concurrency.processes.pool.TaskHandler method) (celery.concurrency.processes.pool.TimeoutHandler method) bold() (celery.utils.term.colored method) BoundMethodWeakref (class in celery.utils.dispatch.saferef) BoundNonDescriptorMethodWeakref (class in celery.utils.dispatch.saferef) bright() (celery.utils.term.colored method) broadcast() (celery.task.control.Control method) broadcast_consumer (celery.worker.consumer.Consumer attribute) broker_connection() (celery.app.App method) BROKER_CONNECTION_MAX_RETRIES setting BROKER_CONNECTION_RETRY setting BROKER_CONNECTION_TIMEOUT setting BROKER_HOST setting BROKER_PASSWORD setting BROKER_POOL_LIMIT setting BROKER_PORT setting BROKER_TRANSPORT setting BROKER_TRANSPORT_OPTIONS setting BROKER_URL setting BROKER_USE_SSL setting BROKER_USER setting BROKER_VHOST setting BrokerConnection (celery.app.amqp.AMQP attribute) Bunch (class in celery.backends.mongodb) bytes_to_str() (in module celery.utils.encoding)

C

CacheBackend (class in celery.backends.cache) calculate_key() (celery.utils.dispatch.saferef.BoundMethodWeakref class method) call() (celery.task.control.Control.Mailbox method) callback (celery.worker.mediator.Mediator attribute) camqadm() (in module celery.bin.camqadm) can_cache_declaration (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) can_consume() (celery.datastructures.TokenBucket method) cancel() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Queue method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.base.BasePool.Timer.Entry method) (celery.concurrency.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.task.control.Inspect method) capacity (celery.datastructures.TokenBucket attribute) capture() (celery.events.EventReceiver method) (celery.events.snapshot.Polaroid method) CassandraBackend (class in celery.backends.cassandra) cast() (celery.task.control.Control.Mailbox method) CDeprecationWarning celery.app (module) celery.app.amqp (module) celery.app.defaults (module) celery.app.task (module) celery.apps.beat (module) celery.apps.worker (module) celery.backends (module) celery.backends.amqp (module) celery.backends.base (module) celery.backends.cache (module) celery.backends.cassandra (module) celery.backends.database (module) celery.backends.mongodb (module) celery.backends.redis (module) celery.backends.tyrant (module) celery.beat (module) celery.bin.base (module) celery.bin.camqadm (module) celery.bin.celerybeat (module) celery.bin.celeryctl (module) celery.bin.celeryd (module) celery.bin.celeryd_multi (module) celery.bin.celeryev (module) celery.concurrency (module) celery.concurrency.base (module) celery.concurrency.eventlet (module) celery.concurrency.gevent (module) celery.concurrency.processes (module) celery.concurrency.processes.pool (module) celery.concurrency.solo (module) celery.concurrency.threads (module) celery.contrib.abortable (module) celery.contrib.batches (module) celery.contrib.rdb (module) celery.datastructures (module) celery.db.models (module) celery.db.session (module) celery.events (module) celery.events.cursesmon (module) celery.events.dumper (module) celery.events.snapshot (module) celery.events.state (module) celery.exceptions (module) celery.execute.trace (module) celery.loaders (module) celery.loaders.app (module) celery.loaders.base (module) celery.loaders.default (module) celery.log (module) celery.platforms (module) celery.registry (module) celery.result (module) celery.routes (module) celery.schedules (module) celery.signals (module) celery.states (module) celery.task (module) celery.task.base (module), [1] celery.task.chords (module) celery.task.control (module) celery.task.http (module), [1] celery.task.sets (module) celery.utils (module) celery.utils.compat (module) celery.utils.dispatch (module) celery.utils.dispatch.saferef (module) celery.utils.dispatch.signal (module) celery.utils.encoding (module) celery.utils.functional (module) celery.utils.mail (module) celery.utils.patch (module) celery.utils.serialization (module) celery.utils.term (module) celery.utils.timer2 (module) celery.utils.timeutils (module) celery.worker (module) celery.worker.autoscale (module) celery.worker.buckets (module) celery.worker.consumer (module) celery.worker.heartbeat (module) celery.worker.job (module) celery.worker.mediator (module) celery.worker.state (module) CELERY_ACKS_LATE setting CELERY_ALWAYS_EAGER setting CELERY_AMQP_TASK_RESULT_EXPIRES 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, [1] CELERY_CREATE_MISSING_QUEUES setting CELERY_DEFAULT_DELIVERY_MODE setting CELERY_DEFAULT_EXCHANGE setting CELERY_DEFAULT_EXCHANGE_TYPE setting CELERY_DEFAULT_QUEUE setting CELERY_DEFAULT_RATE_LIMIT setting CELERY_DEFAULT_ROUTING_KEY setting CELERY_DISABLE_RATE_LIMITS setting CELERY_EAGER_PROPAGATES_EXCEPTIONS setting CELERY_EVENT_SERIALIZER setting CELERY_IGNORE_RESULT setting CELERY_IMPORTS setting CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_MAX_CACHED_RESULTS setting

CELERY_MESSAGE_COMPRESSION setting CELERY_MONGODB_BACKEND_SETTINGS setting CELERY_QUEUES setting CELERY_RDB_HOST CELERY_RDB_PORT CELERY_RDBSIG CELERY_REDIRECT_STDOUTS setting CELERY_REDIRECT_STDOUTS_LEVEL setting CELERY_REDIS_DB setting CELERY_REDIS_HOST setting CELERY_REDIS_PASSWORD setting CELERY_REDIS_PORT setting CELERY_RESULT_BACKEND setting CELERY_RESULT_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_SEND_EVENTS setting CELERY_SEND_TASK_ERROR_EMAILS setting CELERY_SEND_TASK_SENT_EVENT setting CELERY_STORE_ERRORS_EVEN_IF_IGNORED setting CELERY_TASK_ERROR_WHITELIST setting CELERY_TASK_PUBLISH_RETRY setting CELERY_TASK_PUBLISH_RETRY_POLICY setting CELERY_TASK_RESULT_EXPIRES setting CELERY_TASK_SERIALIZER setting CELERY_TRACE_APP, [1] CELERY_TRACK_STARTED setting celerybeat command line option -S, --scheduler -f, --logfile -l, --loglevel -s, --schedule CELERYBEAT_LOG_FILE setting CELERYBEAT_LOG_LEVEL setting CELERYBEAT_MAX_LOOP_INTERVAL setting CELERYBEAT_SCHEDULE setting CELERYBEAT_SCHEDULE_FILENAME setting CELERYBEAT_SCHEDULER setting celeryctl (class in celery.bin.celeryctl) celeryd command line option --maxtasksperchild --purge, --discard --scheduler --soft-time-limit --time-limit -B, --beat -E, --events -I, --include -Q, --queues -c, --concurrency -f, --logfile -l, --loglevel -n, --hostname -s, --schedule CELERYD_AUTOSCALER setting CELERYD_CONCURRENCY setting CELERYD_CONSUMER setting CELERYD_ETA_SCHEDULER setting CELERYD_ETA_SCHEDULER_PRECISION setting CELERYD_HIJACK_ROOT_LOGGER setting CELERYD_LOG_COLOR setting CELERYD_LOG_FILE setting CELERYD_LOG_FORMAT setting CELERYD_LOG_LEVEL setting CELERYD_MAX_TASKS_PER_CHILD setting CELERYD_MEDIATOR setting CELERYD_POOL setting CELERYD_PREFETCH_MULTIPLIER setting CELERYD_STATE_DB setting CELERYD_TASK_LOG_FORMAT setting CELERYD_TASK_SOFT_TIME_LIMIT setting CELERYD_TASK_TIME_LIMIT setting CELERYMON_LOG_FILE setting CELERYMON_LOG_FORMAT setting CELERYMON_LOG_LEVEL setting chain_from_iterable() (in module celery.utils.compat) (in module celery.worker.buckets) channel (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) chord (celery.worker.job.TaskRequest attribute) Chord (class in celery.task.chords) chord (class in celery.task.chords) chord.Chord (class in celery.task.chords) chronologically (celery.datastructures.LimitedSet attribute) chunks() (in module celery.utils) cleanup() (celery.backends.base.BaseBackend method) (celery.backends.database.DatabaseBackend method) (celery.backends.mongodb.MongoBackend method) (celery.events.snapshot.Polaroid method) 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.concurrency.processes.pool.LaxBoundedSemaphore 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_tasks() (celery.events.state.State method) client (celery.backends.cache.CacheBackend attribute) (celery.backends.redis.RedisBackend attribute) close() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Producer method) (celery.backends.tyrant.TyrantBackend method) (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.pool.PoolThread method) (celery.events.EventDispatcher method) (celery.log.LoggingProxy method) (celery.platforms.DaemonContext method) (celery.worker.state.Persistent method) close_connection() (celery.worker.consumer.Consumer method) cmdline_config_parser() (celery.loaders.base.BaseLoader method) coerce() (celery.bin.camqadm.Spec method) colored (class in celery.utils.term) colored() (celery.log.Logging method) ColorFormatter (class in celery.log) COLORS (celery.log.ColorFormatter attribute) Command (class in celery.bin.base) (class in celery.bin.celeryctl) command() (in module celery.bin.celeryctl) completed_count() (celery.result.ResultSet method) completenames() (celery.bin.camqadm.AMQShell method) concurrency (celery.worker.WorkController attribute) conf (celery.app.App attribute) (celery.loaders.base.BaseLoader attribute) config_from_cmdline() (celery.app.App method) config_from_envvar() (celery.app.App method) (celery.loaders.base.BaseLoader method) config_from_object() (celery.app.App method) (celery.loaders.base.BaseLoader method) ConfigurationView (class in celery.datastructures) connect() (celery.bin.camqadm.AMQPAdmin method) (celery.utils.dispatch.signal.Signal method) connection (celery.backends.amqp.AMQPBackend.Consumer attribute) (celery.backends.amqp.AMQPBackend.Producer attribute) (celery.beat.Scheduler attribute) (celery.worker.consumer.Consumer attribute) consume() (celery.backends.amqp.AMQPBackend method) (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Queue method) consume_messages() (celery.worker.consumer.Consumer method) Consumer (celery.app.amqp.AMQP attribute) consumer (celery.worker.WorkController attribute) Consumer (class in celery.worker.consumer) consumer() (celery.events.EventReceiver method) ConsumerSet (celery.app.amqp.AMQP attribute) consuming_from() (celery.backends.amqp.AMQPBackend.Consumer method) control disable_events enable_events ping rate_limit revoke shutdown control (celery.app.App attribute) Control (class in celery.task.control) Control.Mailbox (class in celery.task.control) copy_buffer() (celery.events.EventDispatcher method) CPendingDeprecationWarning cpu_count() (in module celery.apps.worker) create_exception_cls() (in module celery.utils.serialization) create_parser() (celery.bin.base.Command method) (celery.bin.celeryctl.Command method) create_pidlock() (in module celery.platforms) create_session() (in module celery.db.session) create_task_cls() (celery.app.App method) crontab (class in celery.schedules) crontab_parser (class in celery.schedules) crontab_parser.ParseException cry() (in module celery.utils) current_loader() (in module celery.loaders) CursesMonitor (class in celery.events.cursesmon) cwd_in_path() (in module celery.utils) cyan() (celery.utils.term.colored method)

D

daemon (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) daemon_options() (in module celery.bin.base) DaemonContext (class in celery.platforms) DatabaseBackend (class in celery.backends.database) date_done (celery.db.models.Task attribute) (celery.db.models.TaskSet attribute) day_of_week (celery.schedules.crontab attribute) db (celery.backends.redis.RedisBackend attribute) (celery.worker.state.Persistent attribute) debug() (celery.contrib.batches.Batches method) debugger() (in module celery.contrib.rdb) declare() (celery.app.amqp.TaskPublisher method) (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Producer method) (celery.backends.amqp.AMQPBackend.Queue method) (queue method) decode() (celery.backends.base.BaseBackend method) decrement() (celery.worker.consumer.QoS method) decrement_eventually() (celery.worker.consumer.QoS method) default() (celery.bin.camqadm.AMQShell method) default_dispatcher() (celery.events.Events method) default_encode() (in module celery.worker.job) default_encoding() (in module celery.utils.encoding) default_retry_delay (celery.app.task.BaseTask attribute) (Task attribute) delay() (celery.app.task.BaseTask class method) (celery.task.base.BaseTask class method) (celery.task.sets.subtask method) delay_task() (celery.app.amqp.TaskPublisher method) delete() (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Queue method) (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.redis.RedisBackend method) (celery.backends.tyrant.TyrantBackend method) (celery.result.TaskSetResult method) (exchange method) (queue method) delete_taskset() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) deletion_methods (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) delivery_info (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.TaskRequest attribute) delivery_mode (celery.app.task.BaseTask attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute) delta_resolution() (in module celery.utils.timeutils) deprecated() (in module celery.utils)

detached() (in module celery.platforms) DictAttribute (class in celery.datastructures) die() (celery.apps.worker.Worker method) disable() (celery.events.EventDispatcher method) disable_events control disable_events() (celery.task.control.Inspect method) DisabledBackend (class in celery.backends.base) discard() (celery.result.ResultSet method) discard_all() (celery.task.control.Control method) disconnect() (celery.utils.dispatch.signal.Signal method) dispatch() (celery.bin.camqadm.AMQShell method) (celery.task.http.HttpDispatch method) dispatcher (celery.task.http.URL attribute) Dispatcher() (celery.events.Events method) display_command_help() (celery.bin.camqadm.AMQShell method) display_height (celery.events.cursesmon.CursesMonitor attribute) display_task_row() (celery.events.cursesmon.CursesMonitor method) display_width (celery.events.cursesmon.CursesMonitor attribute) DisplayThread (class in celery.events.cursesmon) do_exit() (celery.bin.camqadm.AMQShell method) do_help() (celery.bin.camqadm.AMQShell method) drain_events() (celery.backends.amqp.AMQPBackend method) (celery.events.EventReceiver method) draw() (celery.events.cursesmon.CursesMonitor method) DummyClient (class in celery.backends.cache) dump_message() (in module celery.bin.camqadm) Dumper (class in celery.events.dumper) durable (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) DynamicPool (in module celery.concurrency.processes.pool)

E

EagerResult (class in celery.result) EagerResult.TimeoutError either() (celery.app.App method) Element (class in celery.events.state) EMAIL_HOST setting EMAIL_HOST_PASSWORD setting EMAIL_HOST_USER setting EMAIL_PORT setting EMAIL_TIMEOUT setting EMAIL_USE_SSL setting EMAIL_USE_TLS setting embed() (celery.utils.term.colored method) embed_clockservice (celery.worker.WorkController attribute) EmbeddedService() (in module celery.beat) empty() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.base.BasePool.Timer.Schedule method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Schedule method) (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) enable() (celery.events.EventDispatcher method) enable_config_from_cmdline (celery.bin.base.Command attribute) enable_events control enable_events() (celery.task.control.Inspect method) encode() (celery.backends.base.BaseBackend method) encode_result() (celery.backends.base.BaseBackend method) ensure_bytes() (in module celery.utils.encoding) ensure_process_aware_logger() (in module celery.utils.patch) 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.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.utils.timer2.Schedule method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Schedule method) enter_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) Entry (celery.beat.Scheduler attribute) (class in celery.utils.timer2) environment variable CELERY_BROKER_URL CELERY_CONFIG_MODULE, [1] CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_RDBSIG CELERY_RDB_HOST, [1] CELERY_RDB_PORT, [1] CELERY_TRACE_APP, [1] NOSE_VERBOSE PATH Error error() (celery.bin.celeryctl.Command method) (celery.bin.celeryd_multi.MultiTool method) (in module celery.concurrency.processes.pool) error_msg (celery.worker.job.TaskRequest attribute) error_whitelist (celery.app.task.BaseTask attribute) (Task attribute) ErrorMail (class in celery.utils.mail) establish_connection() (celery.app.task.BaseTask class method) (celery.task.base.BaseTask class method) eta (celery.worker.job.TaskRequest attribute) eta_schedule (celery.worker.consumer.Consumer attribute) evaluate() (celery.utils.mpromise method) (celery.utils.promise method) evaluated (celery.utils.mpromise attribute)

evcam() (in module celery.events.snapshot) EvCommand (class in celery.bin.celeryev) evdump() (in module celery.events.dumper) event() (celery.events.state.State method) Event() (in module celery.events) event_dispatcher (celery.worker.consumer.Consumer attribute) EventDispatcher (class in celery.events) eventlet_pool_apply signal eventlet_pool_postshutdown signal eventlet_pool_preshutdown signal eventlet_pool_started signal EventReceiver (class in celery.events) Events (class in celery.events) evtop() (in module celery.events.cursesmon) exc_args (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exc_cls_name (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exc_module (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exception (celery.datastructures.ExceptionInfo attribute) EXCEPTION_STATES state exception_to_python() (celery.backends.base.BaseBackend method) ExceptionInfo (class in celery.datastructures) exchange (celery.app.task.BaseTask attribute) (Task attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) exchange_type (celery.app.task.BaseTask attribute) exclusive (celery.backends.amqp.AMQPBackend.Queue attribute) execute() (celery.app.task.BaseTask method) (celery.bin.celeryctl.celeryctl method) (celery.contrib.batches.Batches method) (celery.execute.trace.TaskTrace method) (celery.task.base.BaseTask method) (celery.worker.job.TaskRequest method) (celery.worker.job.WorkerTaskTrace method) execute_and_trace() (in module celery.worker.job) execute_from_commandline() (celery.bin.base.Command method) (celery.bin.celeryd_multi.MultiTool method) execute_safe() (celery.worker.job.WorkerTaskTrace method) execute_using_pool() (celery.worker.job.TaskRequest method) exit_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) exitcode (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) (celery.concurrency.processes.pool.ThreadPool.DummyProcess attribute) expand() (celery.bin.celeryd_multi.MultiTool method) expand_destination() (celery.routes.Router method) expected_time() (celery.datastructures.TokenBucket method) (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TokenBucketQueue method) expires (celery.app.task.BaseTask attribute) (celery.datastructures.LimitedSet attribute) (celery.worker.job.TaskRequest attribute) extend_with_default_kwargs() (celery.worker.job.TaskRequest method) extra_info() (celery.apps.worker.Worker method) extract_response() (in module celery.task.http)

F

failed() (celery.result.BaseAsyncResult method) (celery.result.ResultSet method) FAILURE state FastQueue (class in celery.worker.buckets) fg() (in module celery.utils.term) fileno() (celery.log.LoggingProxy method) fill_rate (celery.datastructures.TokenBucket attribute) filter_types() (celery.registry.TaskRegistry method) find_deprecated_settings() (in module celery.app.defaults) find_module() (celery.loaders.default.Loader method) (in module celery.utils) find_nearest_pickleable_exception() (in module celery.utils.serialization) find_position() (celery.events.cursesmon.CursesMonitor method) findsig() (in module celery.bin.celeryd_multi) first (celery.datastructures.LimitedSet attribute) first() (in module celery.utils) firstmethod() (in module celery.utils) flatten() (in module celery.app.defaults) flatten_reply() (in module celery.task.control) flow() (celery.backends.amqp.AMQPBackend.Consumer method) flush() (celery.contrib.batches.Batches method) (celery.events.EventDispatcher method) (celery.log.LoggingProxy method) flush_every (celery.contrib.batches.Batches attribute) flush_interval (celery.contrib.batches.Batches attribute)

force_scale_down() (celery.worker.autoscale.Autoscaler method) force_scale_up() (celery.worker.autoscale.Autoscaler method) forget() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.result.BaseAsyncResult method) (celery.result.ResultSet method) format() (celery.app.amqp.Queues method) (celery.log.ColorFormatter method) format_arg() (celery.bin.camqadm.Spec method) format_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.log.ColorFormatter method) freeze() (State method) freeze_while() (celery.events.state.State method) (State method) from_exception() (celery.utils.serialization.UnpickleableExceptionWrapper class method) from_message() (celery.worker.job.TaskRequest class method) from_request() (celery.contrib.batches.SimpleRequest class method) from_utf8() (in module celery.utils.encoding) fun_takes_kwargs() (in module celery.utils)

G

get() (celery.backends.amqp.AMQPBackend.Queue method) (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.redis.RedisBackend method) (celery.backends.tyrant.TyrantBackend method) (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.processes.pool.ApplyResult method) (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) get_amqp_api_command() (celery.bin.camqadm.AMQShell method) get_async() (celery.task.http.URL method) get_backend_cls() (in module celery.backends) get_best_memcache() (in module celery.backends.cache) get_bound_method_weakref() (in module celery.utils.dispatch.saferef) get_bucket_for_type() (celery.worker.buckets.TaskBucket method) get_cls_by_name() (celery.bin.base.Command method) (in module celery.utils) get_consumer() (celery.app.task.BaseTask class method) (celery.task.base.BaseTask class method) get_default_logger() (celery.log.Logging method) get_default_queue() (celery.app.amqp.AMQP method) get_engine() (in module celery.db.session) get_fdmax() (in module celery.platforms) get_full_cls_name() (in module celery.utils) get_implementation() (in module celery.concurrency) get_instance_attrs() (celery.worker.job.TaskRequest method) get_key_for_task() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) get_key_for_taskset() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) get_loader_cls() (in module celery.loaders) get_logger() (celery.app.task.BaseTask class method) (celery.task.base.BaseTask class method) get_many() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.KeyValueStoreBackend method) get_multi() (celery.backends.cache.DummyClient method) get_names() (celery.bin.camqadm.AMQShell method)

get_nowait() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) get_options() (celery.bin.base.Command method) (celery.bin.celerybeat.BeatCommand method) (celery.bin.celeryd.WorkerCommand method) (celery.bin.celeryev.EvCommand method) get_or_create_task() (celery.events.state.State method) get_or_create_worker() (celery.events.state.State method) get_pickleable_exception() (in module celery.utils.serialization) get_pickled_exception() (in module celery.utils.serialization) get_process_name() (in module celery.apps.worker) get_publisher() (celery.app.task.BaseTask class method) (celery.task.base.BaseTask class method) get_queue() (celery.task.control.Control.Mailbox method) get_reply_queue() (celery.task.control.Control.Mailbox method) get_result() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.backends.base.DisabledBackend method) get_schedule() (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) get_scheduler() (celery.apps.beat.Beat.Service method) (celery.beat.Service method) get_status() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.backends.base.DisabledBackend method) get_symbol_by_name() (in module celery.utils) get_task_consumer() (celery.app.amqp.AMQP method) get_task_logger() (celery.log.Logging method) get_task_meta() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseDictBackend method) get_taskset_meta() (celery.backends.base.BaseDictBackend method) get_traceback() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) (celery.backends.base.DisabledBackend method) getpids() (celery.bin.celeryd_multi.MultiTool method) green() (celery.utils.term.colored method) grow() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool method)

H

handle_after_return() (celery.execute.trace.TaskTrace method) handle_argv() (celery.bin.base.Command method) (celery.bin.celeryctl.celeryctl method) handle_error() (celery.concurrency.base.BasePool.Timer.Schedule method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer.Schedule method) handle_failure() (celery.execute.trace.TaskTrace method) (celery.worker.job.WorkerTaskTrace method) handle_keypress() (celery.events.cursesmon.CursesMonitor method) handle_retry() (celery.execute.trace.TaskTrace method) (celery.worker.job.WorkerTaskTrace method) handle_success() (celery.execute.trace.TaskTrace method) (celery.worker.job.WorkerTaskTrace method) heart (celery.worker.consumer.Consumer attribute) Heart (class in celery.worker.heartbeat) HEARTBEAT_EXPIRE (in module celery.events.state) help (class in celery.bin.celeryctl)

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

I

iblue() (celery.utils.term.colored method) icyan() (celery.utils.term.colored method) id (celery.contrib.batches.SimpleRequest attribute) (celery.db.models.Task attribute) (celery.db.models.TaskSet attribute) ident (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) ignore() (celery.platforms.Signals method) ignore_result (celery.app.task.BaseTask attribute) (Task attribute) igreen() (celery.utils.term.colored method) imagenta() (celery.utils.term.colored method) imap() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool.Pool method) imap_unordered() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool.Pool method) IMapIterator (class in celery.concurrency.processes.pool) IMapUnorderedIterator (class in celery.concurrency.processes.pool) immediate (celery.app.task.BaseTask attribute) (Task attribute) import_best_memcache() (in module celery.backends.cache) import_default_modules() (celery.loaders.base.BaseLoader method) import_from_cwd() (celery.loaders.base.BaseLoader method) (in module celery.utils) import_module() (celery.loaders.base.BaseLoader method) import_task_module() (celery.loaders.base.BaseLoader method) ImproperlyConfigured increment() (celery.worker.consumer.QoS method) indent() (in module celery.bin.celeryctl) info (celery.beat.PersistentScheduler attribute) (celery.beat.Scheduler attribute) (celery.concurrency.base.BasePool attribute) (celery.result.BaseAsyncResult attribute) (celery.worker.consumer.Consumer attribute) info() (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.base.BasePool.Timer.Schedule method) (celery.events.state.Task method) (celery.utils.timer2.Schedule method) (celery.utils.timer2.Timer.Schedule method) (celery.worker.autoscale.Autoscaler method) (celery.worker.job.TaskRequest method) init_callback (celery.worker.consumer.Consumer attribute) init_loader() (celery.apps.beat.Beat method) (celery.apps.worker.Worker method) init_queues() (celery.apps.worker.Worker method) init_screen() (celery.events.cursesmon.CursesMonitor method) init_with_registry() (celery.worker.buckets.TaskBucket method) init_worker() (celery.loaders.base.BaseLoader method) init_worker_process() (celery.loaders.base.BaseLoader method) initial_prefetch_count (celery.worker.consumer.Consumer attribute) inspect (class in celery.bin.celeryctl) Inspect (class in celery.task.control) inspect() (celery.task.control.Control method)

install() (celery.events.snapshot.Polaroid method) install_cry_handler() (in module celery.apps.worker) install_default_entries() (celery.beat.Scheduler method) install_HUP_not_supported_handler() (in module celery.apps.worker) install_platform_tweaks() (celery.apps.worker.Worker method) install_rdb_handler() (in module celery.apps.worker) install_sync_handler() (celery.apps.beat.Beat method) install_worker_int_again_handler() (in module celery.apps.worker) install_worker_int_handler() (in module celery.apps.worker) install_worker_restart_handler() (in module celery.apps.worker) install_worker_term_handler() (in module celery.apps.worker) instantiate() (in module celery.utils) INVALID_TASK_ERROR (in module celery.worker.consumer) InvalidResponseError InvalidTaskError ired() (celery.utils.term.colored method) is_aborted() (celery.contrib.abortable.AbortableAsyncResult method) (celery.contrib.abortable.AbortableTask method) is_alive() (celery.concurrency.processes.pool.Pool.Process method) (celery.concurrency.processes.TaskPool.Pool.Process method) is_due() (celery.beat.ScheduleEntry method) (celery.schedules.crontab method) (celery.schedules.schedule method) (celery.task.base.PeriodicTask method) is_iterable() (in module celery.utils) is_locked() (celery.platforms.PIDFile method) isatty() (celery.log.LoggingProxy method) (in module celery.utils) items (celery.worker.buckets.FastQueue attribute) (celery.worker.buckets.TaskBucket attribute) (celery.worker.buckets.TokenBucketQueue attribute) items() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) iter_native() (celery.result.ResultSet method) iterate() (celery.result.ResultSet method) itercapture() (celery.events.EventReceiver method) iteritems() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.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) iwhite() (celery.utils.term.colored method) iyellow() (celery.utils.term.colored method)

J

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

join_native() (celery.result.ResultSet method)

K

key (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) keys() (celery.datastructures.ConfigurationView method) (celery.datastructures.LRUCache method) KeyValueStoreBackend (class in celery.backends.base)

kill() (celery.bin.celeryd_multi.MultiTool method) kwargs (celery.beat.ScheduleEntry attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.TaskRequest attribute) kwdict() (in module celery.utils)

L

last_run_at (celery.beat.ScheduleEntry attribute) LaxBoundedSemaphore (class in celery.concurrency.processes.pool) limit (celery.concurrency.processes.TaskPool attribute) (celery.events.cursesmon.CursesMonitor attribute) LimitedSet (class in celery.datastructures) list_ (class in celery.bin.celeryctl) list_bindings() (celery.bin.celeryctl.list_ method) load_settings() (in module celery.loaders) loader (celery.app.App attribute) (celery.worker.job.WorkerTaskTrace attribute) Loader (class in celery.loaders.default) LockFailed

log (celery.app.App attribute) logfile (celery.worker.WorkController attribute) logger (celery.beat.Scheduler attribute) (celery.concurrency.processes.TaskPool attribute) (celery.contrib.batches.Batches attribute) (celery.worker.WorkController attribute) (celery.worker.consumer.Consumer attribute) Logging (class in celery.log) LoggingProxy (class in celery.log) loglevel (celery.worker.WorkController attribute) lookup_route() (celery.routes.Router method) lpmerge() (in module celery.utils) LRUCache (class in celery.datastructures)

M

magenta() (celery.utils.term.colored method) mail (celery.loaders.base.BaseLoader attribute) mail_admins() (celery.app.App method) (celery.loaders.base.BaseLoader method) Mailer (class in celery.utils.mail) main (celery.app.App attribute) main() (in module celery.bin.camqadm) (in module celery.bin.celerybeat) (in module celery.bin.celeryctl) (in module celery.bin.celeryd) (in module celery.bin.celeryd_multi) (in module celery.bin.celeryev) make_request() (celery.task.http.HttpDispatch method) mandatory (celery.app.task.BaseTask attribute) (Task attribute) map() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool.Pool method) map_async() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool.Pool method) MapResult (class in celery.concurrency.processes.pool) MapRoute (class in celery.routes) mapstar() (in module celery.concurrency.processes.pool) mark_as_done() (celery.backends.base.BaseBackend method) mark_as_failure() (celery.backends.base.BaseBackend method) mark_as_retry() (celery.backends.base.BaseBackend method) mark_as_revoked() (celery.backends.base.BaseBackend method) mark_as_started() (celery.backends.base.BaseBackend method) mattrgetter() (in module celery.utils) max_interval (celery.beat.Scheduler attribute) max_retries (celery.app.task.BaseTask attribute) (Task attribute) maxlen (celery.datastructures.LimitedSet attribute) MaxRetriesExceededError maybe_conn_error() (celery.worker.consumer.Consumer method) maybe_declare() (celery.backends.amqp.AMQPBackend.Producer method) maybe_due() (celery.beat.Scheduler method) maybe_expire() (celery.worker.job.TaskRequest method) maybe_iso8601() (in module celery.utils.timeutils) maybe_list() (in module celery.utils.functional)

maybe_promise() (in module celery.utils) maybe_schedule() (in module celery.schedules) maybe_subtask() (in module celery.task.sets) maybe_timedelta() (in module celery.utils.timeutils) maybe_utf8() (in module celery.task.http) MaybeEncodingError mediator (celery.worker.WorkController attribute) Mediator (class in celery.worker.mediator) memoize() (in module celery.utils.functional) merge() (celery.app.App method) (celery.events.state.Task method) (celery.worker.state.Persistent method) merge_inplace() (celery.beat.Scheduler method) merge_rules (celery.events.state.Task attribute) message (celery.worker.job.TaskRequest attribute) Message (class in celery.utils.mail) Message() (celery.backends.amqp.AMQPBackend.Exchange method) method (celery.task.http.HttpDispatchTask attribute) mget() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.redis.RedisBackend method) minute (celery.schedules.crontab attribute) MongoBackend (class in celery.backends.mongodb) move() (celery.worker.mediator.Mediator method) move_selection() (celery.events.cursesmon.CursesMonitor method) move_selection_down() (celery.events.cursesmon.CursesMonitor method) move_selection_up() (celery.events.cursesmon.CursesMonitor method) mpromise (class in celery.utils) multi_args() (in module celery.bin.celeryd_multi) multi_call() (celery.task.control.Control.Mailbox method) MultiTool (class in celery.bin.celeryd_multi) MutableURL (class in celery.task.http)

N

name (celery.app.task.BaseTask attribute) (Task attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) (celery.beat.ScheduleEntry attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) (celery.concurrency.processes.pool.Pool.Process attribute) (celery.contrib.batches.SimpleRequest attribute) (celery.worker.job.TaskRequest attribute) names() (celery.bin.celeryd_multi.MultiTool method) namespace (celery.bin.base.Command attribute) NamespacedOptionParser (class in celery.bin.celeryd_multi) nap() (celery.events.cursesmon.CursesMonitor method) next() (celery.beat.ScheduleEntry method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.processes.pool.IMapIterator method) (celery.utils.timer2.Timer method) no_color() (celery.utils.term.colored method) Node() (celery.task.control.Control.Mailbox method) node() (celery.utils.term.colored method)

node_alive() (celery.bin.celeryd_multi.MultiTool method) node_cls (celery.task.control.Control.Mailbox attribute) noop() (in module celery.utils) NOSE_VERBOSE NotConfigured note() (celery.bin.celeryd_multi.MultiTool method) NotRegistered NullDict (class in celery.concurrency.threads) num_processes (celery.concurrency.base.BasePool attribute) (celery.concurrency.processes.TaskPool attribute)

O

on_accepted() (celery.worker.job.TaskRequest method) on_ack (celery.worker.job.TaskRequest attribute) on_apply() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.solo.TaskPool method) (celery.concurrency.threads.TaskPool method) on_chord_apply() (celery.backends.base.BaseBackend method) (celery.backends.redis.RedisBackend method) on_chord_part_return() (celery.backends.base.BaseBackend method) (celery.backends.redis.RedisBackend method) on_cleanup() (celery.events.snapshot.Polaroid method) on_consumer_ready() (celery.apps.worker.Worker method) on_control() (celery.worker.consumer.Consumer method) on_decode_error() (celery.worker.consumer.Consumer method) on_event() (celery.events.dumper.Dumper method) on_failed() (celery.events.state.Task method) on_failure() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) (celery.worker.job.TaskRequest method) on_heartbeat() (celery.events.state.Worker method) on_offline() (celery.events.state.Worker method) on_online() (celery.events.state.Worker method) on_process_cleanup() (celery.loaders.base.BaseLoader method) on_ready() (celery.concurrency.base.BasePool method) on_received() (celery.events.state.Task method) on_retried() (celery.events.state.Task method) on_retry() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) (celery.worker.job.TaskRequest method) on_revoked() (celery.events.state.Task method) on_sent() (celery.events.state.Task method) on_shutter() (celery.events.snapshot.Polaroid method) on_start() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.solo.TaskPool method) (celery.concurrency.threads.TaskPool method)

on_started() (celery.events.state.Task method) on_stop() (celery.concurrency.base.BasePool method) (celery.concurrency.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.TaskRequest method) on_task() (celery.worker.consumer.Consumer method) on_task_init() (celery.loaders.base.BaseLoader method) on_terminate() (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool method) on_timeout() (celery.worker.job.TaskRequest method) on_timer_error() (celery.apps.worker.Worker.WorkController method) (celery.worker.WorkController method) on_timer_tick() (celery.apps.worker.Worker.WorkController method) (celery.worker.WorkController method) on_unknown_event() (celery.events.state.Task method) on_worker_error() (celery.concurrency.base.BasePool method) on_worker_init() (celery.loaders.app.AppLoader method) (celery.loaders.base.BaseLoader method) (celery.loaders.default.Loader method) on_worker_process_init() (celery.loaders.base.BaseLoader method) onecmd() (celery.bin.camqadm.AMQShell method) open() (celery.backends.tyrant.TyrantBackend method) (celery.platforms.DaemonContext method) (celery.worker.state.Persistent method) Option (class in celery.app.defaults) option_list (celery.bin.base.Command attribute) options (celery.beat.ScheduleEntry attribute) options() (celery.app.amqp.Queues method) optmerge() (celery.bin.celeryd_multi.NamespacedOptionParser method) osx_proxy_detection_workaround() (celery.apps.worker.Worker method) out() (celery.bin.celeryctl.Command method)

P

padlist() (in module celery.utils) parse() (celery.bin.celeryd_multi.NamespacedOptionParser method) (celery.schedules.crontab_parser method) parse_gid() (in module celery.platforms) parse_ns_range() (in module celery.bin.celeryd_multi) parse_options() (celery.bin.base.Command method) parse_preload_options() (celery.bin.base.Command method) parse_uid() (in module celery.platforms) 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.registry.TaskRegistry method) periodic_task() (in module celery.task) PeriodicTask (class in celery.task.base) Persistent (class in celery.worker.state) PersistentScheduler (class in celery.beat) pid (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) pidbox_node (celery.worker.consumer.Consumer attribute) PIDFile (class in celery.platforms) ping control ping() (celery.task.control.Control method) (celery.task.control.Inspect method) pluralize() (in module celery.bin.celeryctl) Polaroid (class in celery.events.snapshot) poll() (celery.backends.amqp.AMQPBackend method) pool (celery.worker.consumer.Consumer attribute) (celery.worker.WorkController attribute) Pool (class in celery.concurrency.processes.pool) Pool.Process (class in celery.concurrency.processes.pool) Pool.ResultHandler (class in celery.concurrency.processes.pool) Pool.SoftTimeLimitExceeded Pool.Supervisor (class in celery.concurrency.processes.pool) Pool.TaskHandler (class in celery.concurrency.processes.pool) Pool.TimeoutHandler (class in celery.concurrency.processes.pool) PoolThread (class in celery.concurrency.processes.pool) pop() (celery.registry.TaskRegistry method) pop_value() (celery.datastructures.LimitedSet method)

port (celery.backends.redis.RedisBackend attribute) post_async() (celery.task.http.URL method) PRECEDENCE (in module celery.states) precedence() (in module celery.states) PREFETCH_COUNT_MAX (in module celery.worker.consumer) preload_options (celery.bin.base.Command attribute) prepare() (in module celery.routes) prepare_config() (celery.app.App method) prepare_exception() (celery.backends.base.BaseBackend method) prepare_expires() (celery.backends.base.BaseBackend method) prepare_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.celeryctl.Command method) prettify_dict_ok_error() (celery.bin.celeryctl.Command method) prettify_list() (celery.bin.celeryctl.Command method) priority (celery.app.task.BaseTask attribute) (Task attribute) priority_timer (celery.worker.consumer.Consumer attribute) Process (celery.concurrency.processes.pool.ThreadPool attribute) process() (celery.events.EventReceiver method) process_cleanup() (celery.backends.base.BaseBackend method) (celery.backends.cassandra.CassandraBackend method) (celery.backends.mongodb.MongoBackend method) (celery.backends.tyrant.TyrantBackend method) process_cmdline_config() (celery.bin.base.Command method) process_initializer() (in module celery.worker) process_long_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method) process_short_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method) process_task() (celery.apps.worker.Worker.WorkController method) (celery.worker.WorkController method) processes (celery.worker.autoscale.Autoscaler attribute) promise (class in celery.utils) prompt (celery.bin.camqadm.AMQShell attribute) PROPAGATE_STATES state publish() (celery.backends.amqp.AMQPBackend.Exchange method) (celery.backends.amqp.AMQPBackend.Producer method) publisher (celery.beat.Scheduler attribute) purge (class in celery.bin.celeryctl) purge() (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Queue method) purge_messages() (celery.apps.worker.Worker method) put() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) put_nowait() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) pyimplementation() (in module celery.platforms)

Q

QoS (class in celery.worker.consumer) qos() (celery.backends.amqp.AMQPBackend.Consumer method) qsize() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) qty (celery.worker.autoscale.Autoscaler attribute) queue (celery.app.task.BaseTask attribute) (Task attribute) (celery.concurrency.base.BasePool.Timer attribute) (celery.concurrency.base.BasePool.Timer.Schedule attribute) (celery.concurrency.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) Queues (class in celery.app.amqp) Queues() (celery.app.amqp.AMQP method) quote() (in module celery.bin.celeryd_multi)

R

rate() (in module celery.utils.timeutils) rate_limit control rate_limit (celery.app.task.BaseTask attribute) (Task attribute) rate_limit() (celery.task.control.Control method) RateLimitExceeded Rdb (class in celery.contrib.rdb) read_configuration() (celery.loaders.app.AppLoader method) (celery.loaders.default.Loader method) read_pid() (celery.platforms.PIDFile method) readline() (celery.events.cursesmon.CursesMonitor method) ready (celery.events.state.Task attribute) ready() (celery.concurrency.processes.pool.ApplyResult method) (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) ready_queue (celery.worker.consumer.Consumer attribute) (celery.worker.WorkController attribute) (celery.worker.mediator.Mediator attribute) READY_STATES state receive() (celery.backends.amqp.AMQPBackend.Consumer method) receive_message() (celery.worker.consumer.Consumer method) Receiver() (celery.events.Events method) receivers (celery.utils.dispatch.signal.Signal attribute) recover() (celery.backends.amqp.AMQPBackend.Consumer method) red() (celery.utils.term.colored method) redirect_stdouts_to_logger() (celery.apps.worker.Worker method) (celery.log.Logging method) redis (celery.backends.redis.RedisBackend attribute) RedisBackend (class in celery.backends.redis) refresh() (celery.worker.buckets.TaskBucket method) register() (celery.registry.TaskRegistry method) register_callback() (celery.backends.amqp.AMQPBackend.Consumer method) registered() (celery.task.control.Inspect method) registered_tasks() (celery.task.control.Inspect method) regular() (celery.registry.TaskRegistry method) relative (celery.task.base.PeriodicTask attribute) release() (celery.backends.amqp.AMQPBackend.Producer method) (celery.concurrency.processes.pool.LaxBoundedSemaphore method) (celery.platforms.PIDFile method) reload_task_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) reload_taskset_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) remaining() (in module celery.utils.timeutils) remaining_estimate() (celery.schedules.crontab method) (celery.schedules.schedule method) (celery.task.base.PeriodicTask method) RemoteExecuteError remove() (celery.platforms.PIDFile method) (celery.result.ResultSet method) remove_if_stale() (celery.platforms.PIDFile method) remove_options_at_beginning() (celery.bin.celeryctl.celeryctl method) repair_uuid() (in module celery.backends.amqp) repr_result() (celery.worker.job.TaskRequest method) reprcall() (in module celery.utils) reprkwargs() (in module celery.utils) request (celery.app.task.BaseTask attribute) reserve() (celery.beat.Scheduler method)

reserved() (celery.task.control.Inspect method) reserved_requests (in module celery.worker.state) reset() (celery.platforms.Signals method) (celery.utils.term.colored method) reset_connection() (celery.worker.consumer.Consumer method) reset_pidbox_node() (celery.worker.consumer.Consumer method) resetscreen() (celery.events.cursesmon.CursesMonitor method) respond() (celery.bin.camqadm.AMQShell method) restart() (celery.bin.celeryd_multi.MultiTool method) restart_heartbeat() (celery.worker.consumer.Consumer method) restore() (celery.result.TaskSetResult class method) (celery.utils.serialization.UnpickleableExceptionWrapper method) restore_taskset() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) result (celery.db.models.Task attribute) (celery.db.models.TaskSet attribute) (celery.result.BaseAsyncResult attribute) (celery.result.EagerResult attribute) (class in celery.bin.celeryctl) ResultHandler (class in celery.concurrency.processes.pool) results (celery.result.ResultSet attribute) (celery.result.TaskSetResult attribute) ResultSession() (celery.backends.database.DatabaseBackend method) (in module celery.db.session) ResultSet (class in celery.result) retries (celery.worker.job.TaskRequest attribute) RETRY state retry() (celery.app.task.BaseTask class method) (celery.task.base.BaseTask class method) retry_msg (celery.worker.job.TaskRequest attribute) RetryTaskError reverse() (celery.utils.term.colored method) revive() (celery.backends.amqp.AMQPBackend method) (celery.backends.amqp.AMQPBackend.Consumer method) (celery.backends.amqp.AMQPBackend.Producer method) revoke control revoke() (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) (celery.task.control.Control method) REVOKE_EXPIRES (in module celery.worker.state) revoke_selection() (celery.events.cursesmon.CursesMonitor method) REVOKED state revoked (in module celery.worker.state) revoked() (celery.task.control.Inspect method) (celery.worker.job.TaskRequest method) REVOKES_MAX (in module celery.worker.state) route() (celery.routes.Router method) route_for_task() (celery.routes.MapRoute method) Router (class in celery.routes) Router() (celery.app.amqp.AMQP method) routing_key (celery.app.task.BaseTask attribute) (Task attribute) (celery.backends.amqp.AMQPBackend.Queue attribute) run() (celery.app.task.BaseTask method) (celery.apps.beat.Beat method) (celery.apps.worker.Worker method) (celery.bin.base.Command method) (celery.bin.camqadm.AMQPAdmin method) (celery.bin.camqadm.AMQPAdminCommand method) (celery.bin.celerybeat.BeatCommand method) (celery.bin.celeryctl.Command method) (celery.bin.celeryctl.apply method) (celery.bin.celeryctl.help method) (celery.bin.celeryctl.inspect method) (celery.bin.celeryctl.list_ method) (celery.bin.celeryctl.purge method) (celery.bin.celeryctl.result method) (celery.bin.celeryctl.status method) (celery.bin.celeryd.WorkerCommand method) (celery.bin.celeryev.EvCommand method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.concurrency.processes.pool.Pool.Process method) (celery.concurrency.processes.pool.PoolThread method) (celery.contrib.batches.Batches method) (celery.events.cursesmon.DisplayThread method) (celery.task.base.BaseTask method) (celery.task.chords.Chord method) (celery.task.chords.chord.Chord method) (celery.task.http.HttpDispatchTask method) (celery.utils.timer2.Timer method) (celery.worker.autoscale.Autoscaler method) (celery.worker.mediator.Mediator method) run_evcam() (celery.bin.celeryev.EvCommand method) run_evdump() (celery.bin.celeryev.EvCommand method) run_every (celery.task.base.PeriodicTask attribute) run_evtop() (celery.bin.celeryev.EvCommand method) run_from_argv() (celery.bin.celeryctl.Command method) run_worker() (celery.apps.worker.Worker method)

S

safe_add_str() (celery.events.cursesmon.CursesMonitor method) safe_apply_callback() (celery.concurrency.base.BasePool method) safe_ref() (in module celery.utils.dispatch.saferef) safe_repr() (in module celery.utils.encoding) safe_str() (in module celery.utils.encoding) save() (celery.result.TaskSetResult method) (celery.worker.state.Persistent method) save_taskset() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) say() (celery.bin.camqadm.AMQPAdmin method) (celery.bin.camqadm.AMQShell method) (celery.bin.celeryctl.inspect method) (celery.bin.celeryd_multi.MultiTool method) (in module celery.bin.camqadm) (in module celery.bin.celeryd_multi) scale() (celery.worker.autoscale.Autoscaler method) scale_down() (celery.worker.autoscale.Autoscaler method) scale_up() (celery.worker.autoscale.Autoscaler method) schedule (celery.beat.ScheduleEntry attribute) (celery.beat.Scheduler attribute) Schedule (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) schedule (class in celery.schedules) Schedule (class in celery.utils.timer2) scheduled() (celery.task.control.Inspect method) ScheduleEntry (class in celery.beat) scheduler (celery.apps.beat.Beat.Service attribute) (celery.beat.Service attribute) Scheduler (class in celery.beat) scheduler_cls (celery.apps.beat.Beat.Service attribute) (celery.beat.Service attribute) SchedulingError screen_height (celery.events.cursesmon.CursesMonitor attribute) screen_width (celery.events.cursesmon.CursesMonitor attribute) seconds (celery.schedules.schedule attribute) select_subset() (celery.app.amqp.Queues method) 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.TaskRequest method) send_events (celery.worker.consumer.Consumer attribute) (celery.worker.WorkController attribute) send_robust() (celery.utils.dispatch.signal.Signal method) send_task() (celery.app.App method) (celery.beat.Scheduler method) SendmailWarning serializer (celery.app.task.BaseTask attribute) (Task attribute) SERVER_EMAIL setting servers (celery.backends.cassandra.CassandraBackend attribute) Service (class in celery.beat) set() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.redis.RedisBackend method) (celery.backends.tyrant.TyrantBackend method) (celery.worker.consumer.QoS method) set_effective_user() (in module celery.platforms) set_mp_process_title() (in module celery.platforms) set_process_status() (celery.apps.worker.Worker method) (celery.bin.celeryev.EvCommand method) set_process_title() (celery.apps.beat.Beat method) (in module celery.platforms) set_schedule() (celery.beat.Scheduler method) set_trace() (in module celery.contrib.rdb) setdefault() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) setegid() (in module celery.platforms) seteuid() (in module celery.platforms) setgid() (in module celery.platforms) setting ADMINS BROKER_CONNECTION_MAX_RETRIES BROKER_CONNECTION_RETRY BROKER_CONNECTION_TIMEOUT BROKER_HOST BROKER_PASSWORD BROKER_POOL_LIMIT BROKER_PORT BROKER_TRANSPORT BROKER_TRANSPORT_OPTIONS BROKER_URL BROKER_USER BROKER_USE_SSL BROKER_VHOST CELERYBEAT_LOG_FILE CELERYBEAT_LOG_LEVEL CELERYBEAT_MAX_LOOP_INTERVAL CELERYBEAT_SCHEDULE CELERYBEAT_SCHEDULER CELERYBEAT_SCHEDULE_FILENAME CELERYD_AUTOSCALER CELERYD_CONCURRENCY CELERYD_CONSUMER CELERYD_ETA_SCHEDULER CELERYD_ETA_SCHEDULER_PRECISION CELERYD_HIJACK_ROOT_LOGGER CELERYD_LOG_COLOR CELERYD_LOG_FILE CELERYD_LOG_FORMAT CELERYD_LOG_LEVEL CELERYD_MAX_TASKS_PER_CHILD CELERYD_MEDIATOR CELERYD_POOL CELERYD_PREFETCH_MULTIPLIER CELERYD_STATE_DB CELERYD_TASK_LOG_FORMAT CELERYD_TASK_SOFT_TIME_LIMIT CELERYD_TASK_TIME_LIMIT CELERYMON_LOG_FILE CELERYMON_LOG_FORMAT CELERYMON_LOG_LEVEL CELERY_ACKS_LATE CELERY_ALWAYS_EAGER CELERY_AMQP_TASK_RESULT_EXPIRES CELERY_BROADCAST_EXCHANGE CELERY_BROADCAST_EXCHANGE_TYPE CELERY_BROADCAST_QUEUE CELERY_CACHE_BACKEND CELERY_CACHE_BACKEND_OPTIONS CELERY_CREATE_MISSING_QUEUES CELERY_DEFAULT_DELIVERY_MODE CELERY_DEFAULT_EXCHANGE CELERY_DEFAULT_EXCHANGE_TYPE CELERY_DEFAULT_QUEUE CELERY_DEFAULT_RATE_LIMIT CELERY_DEFAULT_ROUTING_KEY CELERY_DISABLE_RATE_LIMITS CELERY_EAGER_PROPAGATES_EXCEPTIONS CELERY_EVENT_SERIALIZER CELERY_IGNORE_RESULT CELERY_IMPORTS CELERY_MAX_CACHED_RESULTS CELERY_MESSAGE_COMPRESSION CELERY_MONGODB_BACKEND_SETTINGS CELERY_QUEUES CELERY_REDIRECT_STDOUTS CELERY_REDIRECT_STDOUTS_LEVEL CELERY_REDIS_DB CELERY_REDIS_HOST CELERY_REDIS_PASSWORD CELERY_REDIS_PORT CELERY_RESULT_BACKEND CELERY_RESULT_DBURI CELERY_RESULT_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_SEND_EVENTS CELERY_SEND_TASK_ERROR_EMAILS CELERY_SEND_TASK_SENT_EVENT CELERY_STORE_ERRORS_EVEN_IF_IGNORED CELERY_TASK_ERROR_WHITELIST CELERY_TASK_PUBLISH_RETRY CELERY_TASK_PUBLISH_RETRY_POLICY CELERY_TASK_RESULT_EXPIRES CELERY_TASK_SERIALIZER CELERY_TRACK_STARTED EMAIL_HOST EMAIL_HOST_PASSWORD EMAIL_HOST_USER EMAIL_PORT EMAIL_TIMEOUT EMAIL_USE_SSL EMAIL_USE_TLS SERVER_EMAIL TT_HOST TT_PORT setuid() (in module celery.platforms) setup_app_from_commandline() (celery.bin.base.Command method) setup_logger() (celery.log.Logging method) setup_logging signal setup_logging() (celery.apps.beat.Beat method) setup_logging_subsystem() (celery.log.Logging method) setup_results() (in module celery.db.session) setup_schedule() (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) setup_settings() (celery.loaders.default.Loader method)

setup_task_logger() (celery.log.Logging method) shellsplit() (in module celery.platforms) shortinfo() (celery.worker.job.TaskRequest 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) shrink() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool method) shutdown control shutdown_nodes() (celery.bin.celeryd_multi.MultiTool method) shutter() (celery.events.snapshot.Polaroid method) signal after_setup_logger after_setup_task_logger beat_embedded_init beat_init eventlet_pool_apply eventlet_pool_postshutdown eventlet_pool_preshutdown eventlet_pool_started setup_logging task_failure task_postrun task_prerun task_sent worker_init worker_process_init worker_ready worker_shutdown Signal (class in celery.utils.dispatch.signal) signal_node() (celery.bin.celeryd_multi.MultiTool method) Signals (class in celery.platforms) signum() (celery.platforms.Signals method) SilenceRepeated (class in celery.log) SimpleRequest (class in celery.contrib.batches) soft_time_limit (celery.app.task.BaseTask attribute) (Task attribute) soft_timeout_sighandler() (in module celery.concurrency.processes.pool) SoftTimeLimitExceeded SOFTWARE_INFO (in module celery.worker.state) Spec (class in celery.bin.camqadm) splash() (celery.bin.celeryd_multi.MultiTool method) start() (celery.apps.beat.Beat.Service method) (celery.apps.worker.Worker.WorkController method) (celery.beat.Service method) (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.base.BasePool method) (celery.concurrency.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.concurrency.processes.pool.Pool.Process method) (celery.concurrency.processes.pool.ThreadPool.DummyProcess method) (celery.worker.WorkController method) (celery.worker.consumer.Consumer method) (celery.worker.heartbeat.Heart method) start_scheduler() (celery.apps.beat.Beat method) STARTED state startup_info() (celery.apps.beat.Beat method) (celery.apps.worker.Worker method) state ALL_STATES EXCEPTION_STATES FAILURE PENDING PROPAGATE_STATES READY_STATES RETRY REVOKED STARTED SUCCESS UNREADY_STATES state (celery.result.BaseAsyncResult attribute) (celery.result.EagerResult attribute) State (class in celery.events.state) state (class in celery.states) State() (celery.events.Events method) stats() (celery.task.control.Inspect method) status (celery.db.models.Task attribute) (celery.result.BaseAsyncResult attribute) (celery.result.EagerResult attribute) (class in celery.bin.celeryctl) stop() (celery.apps.beat.Beat.Service method) (celery.apps.worker.Worker.WorkController method) (celery.beat.Service method) (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.base.BasePool method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.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) (celery.worker.WorkController method) (celery.worker.autoscale.Autoscaler method) (celery.worker.consumer.Consumer method) (celery.worker.heartbeat.Heart method) (celery.worker.mediator.Mediator method) stop_consumers() (celery.worker.consumer.Consumer method) stop_pidbox_node() (celery.worker.consumer.Consumer method) stop_verify() (celery.bin.celeryd_multi.MultiTool method) 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) str_to_bytes() (in module celery.utils.encoding) strargv() (in module celery.platforms) subclass_exception() (in module celery.utils.serialization) subject (celery.utils.mail.ErrorMail attribute) subpolling_interval (celery.backends.base.BaseBackend attribute) subtask (class in celery.task.sets) subtask() (celery.app.task.BaseTask class method) (celery.task.base.BaseTask class method) subtasks (celery.result.ResultSet attribute) SUCCESS state success_msg (celery.worker.job.TaskRequest attribute) successful() (celery.concurrency.processes.pool.ApplyResult method) (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) Supervisor (class in celery.concurrency.processes.pool) supported() (celery.platforms.Signals method) supports_args (celery.bin.base.Command attribute) supports_color() (celery.log.Logging method) sync() (celery.apps.beat.Beat.Service method) (celery.beat.PersistentScheduler method) (celery.beat.Scheduler method) (celery.beat.Service method) (celery.worker.state.Persistent method) sync_every (celery.beat.Scheduler attribute) SystemTerminate

T

task (celery.task.sets.TaskSet attribute) (celery.worker.job.TaskRequest attribute) Task (class in celery.db.models) (class in celery.events.state) (class in celery.task) task() (celery.app.App method) (in module celery.task) task_accepted() (in module celery.worker.state) task_consumer (celery.worker.consumer.Consumer attribute) task_event() (celery.events.state.State method) task_failure signal task_id (celery.db.models.Task attribute) (celery.result.BaseAsyncResult attribute) (celery.worker.job.TaskRequest attribute) task_name (celery.task.sets.TaskSet attribute) task_postrun signal task_prerun signal task_ready() (in module celery.worker.state) task_reserved() (in module celery.worker.state) task_sent signal task_types() (celery.events.state.State method) TaskBucket (class in celery.worker.buckets) TaskConsumer() (celery.app.amqp.AMQP method) TaskHandler (class in celery.concurrency.processes.pool) 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) TaskPublisher (class in celery.app.amqp) TaskPublisher() (celery.app.amqp.AMQP method) TaskRegistry (class in celery.registry) TaskRegistry.NotRegistered TaskRequest (class in celery.worker.job) TaskRevokedError tasks (celery.events.cursesmon.CursesMonitor attribute) (celery.task.sets.TaskSet attribute) (in module celery.registry) tasks_by_timestamp() (celery.events.state.State method) tasks_by_type() (celery.events.state.State method) tasks_by_worker() (celery.events.state.State method) TaskSet (class in celery.db.models) (class in celery.task.sets) TaskSet() (celery.app.App method) taskset_id (celery.db.models.TaskSet attribute) (celery.result.TaskSetResult attribute) (celery.worker.job.TaskRequest attribute) TaskSetResult (class in celery.result)

TaskSetResult() (celery.app.App method) TaskTrace (class in celery.execute.trace) TaskType (class in celery.app.task) (class in celery.task.base) tb (celery.datastructures.ExceptionInfo attribute) terminate() (celery.apps.worker.Worker.WorkController method) (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.pool.Pool.Process method) (celery.concurrency.processes.pool.PoolThread method) (celery.worker.WorkController method) (celery.worker.job.TaskRequest method) terminate_job() (celery.concurrency.base.BasePool method) (celery.concurrency.processes.TaskPool method) textindent() (in module celery.utils) thaw() (State method) ThreadPool (class in celery.concurrency.processes.pool) ThreadPool.DummyProcess (class in celery.concurrency.processes.pool) tick() (celery.beat.Scheduler method) time_limit (celery.app.task.BaseTask attribute) (Task attribute) time_limit() (celery.task.control.Control method) time_start (celery.worker.job.TaskRequest attribute) timedelta_seconds() (celery.task.base.PeriodicTask method) (in module celery.utils.timeutils) TimedFunctionFailed TimeLimitExceeded TimeoutError (celery.result.BaseAsyncResult attribute) TimeoutHandler (class in celery.concurrency.processes.pool) 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) timestamp (celery.datastructures.TokenBucket attribute) to_dict() (celery.db.models.Task method) (celery.db.models.TaskSet method) to_python() (celery.app.defaults.Option method) to_timestamp() (in module celery.utils.timer2) TokenBucket (class in celery.datastructures) TokenBucketQueue (class in celery.worker.buckets) TokenBucketQueue.RateLimitExceeded total (celery.result.ResultSet attribute) (celery.task.sets.TaskSet attribute) total_count (in module celery.worker.state) total_run_count (celery.beat.ScheduleEntry attribute) trace() (celery.execute.trace.TraceInfo class method) traceback (celery.datastructures.ExceptionInfo attribute) (celery.db.models.Task attribute) (celery.result.BaseAsyncResult attribute) (celery.result.EagerResult attribute) TraceInfo (class in celery.execute.trace) track_started (celery.app.task.BaseTask attribute) (Task attribute) truncate_text() (in module celery.utils) TT_HOST setting TT_PORT setting type (celery.app.task.BaseTask attribute) (celery.backends.amqp.AMQPBackend.Exchange attribute) (celery.datastructures.ExceptionInfo attribute) (celery.task.sets.subtask attribute) tyrant_host (celery.backends.tyrant.TyrantBackend attribute) tyrant_port (celery.backends.tyrant.TyrantBackend attribute) TyrantBackend (class in celery.backends.tyrant)

U

unbind() (celery.backends.amqp.AMQPBackend.Queue method) underline() (celery.utils.term.colored method) UNKNOWN_TASK_ERROR (in module celery.worker.consumer) UnknownStatusError unpickle_backend() (in module celery.backends.base) UnpickleableExceptionWrapper UNREADY_STATES state unregister() (celery.registry.TaskRegistry method) unwanted_base_classes (in module celery.utils.serialization)

update() (celery.beat.ScheduleEntry method) (celery.datastructures.ConfigurationView method) (celery.datastructures.LimitedSet method) (celery.events.state.Task method) (celery.platforms.Signals method) (celery.result.ResultSet method) (celery.worker.autoscale.Autoscaler method) (celery.worker.consumer.QoS method) update_bucket_for_type() (celery.worker.buckets.TaskBucket method) update_from_dict() (celery.beat.Scheduler method) update_state() (celery.app.task.BaseTask method) (celery.task.base.BaseTask method) url (celery.task.http.HttpDispatchTask attribute) URL (class in celery.task.http) usage() (celery.bin.base.Command method) (celery.bin.celeryctl.Command method) (celery.bin.celeryctl.help method) (celery.bin.celeryctl.inspect method) (celery.bin.celeryd_multi.MultiTool method) utf8dict() (in module celery.task.http)

V

values() (celery.datastructures.ConfigurationView method) (celery.datastructures.LRUCache method)

version (celery.bin.base.Command attribute)

W

wait() (celery.concurrency.processes.pool.ApplyResult method) (celery.result.BaseAsyncResult method) (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TokenBucketQueue method) wait_for() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.DisabledBackend method) waitexec() (celery.bin.celeryd_multi.MultiTool method) waiting() (celery.result.ResultSet method) wakeup_workers() (celery.events.EventReceiver method) WANTED_DELIVERY_INFO (in module celery.worker.job) wanted_module_item() (celery.loaders.default.Loader method) 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) windows_main() (in module celery.bin.celeryd) with_default_connection() (celery.app.App method) with_defaults() (celery.app.amqp.Queues class method) with_detacher_default_options() (celery.bin.celeryd_multi.MultiTool method) WorkController (class in celery.worker) Worker (class in celery.apps.worker) (class in celery.events.state) Worker() (celery.app.App method) worker() (in module celery.concurrency.processes.pool)

Worker.WorkController (class in celery.apps.worker) worker_event() (celery.events.state.State method) worker_init signal worker_init() (celery.apps.worker.Worker method) worker_main() (celery.app.App method) worker_pid (celery.worker.job.TaskRequest attribute) worker_pids() (celery.concurrency.processes.pool.ApplyResult method) (celery.concurrency.processes.pool.MapResult method) worker_process_init signal worker_ready signal worker_shutdown signal WORKER_SIGIGNORE (in module celery.worker) WORKER_SIGRESET (in module celery.worker) WorkerCommand (class in celery.bin.celeryd) WorkerLostError workers (celery.events.cursesmon.CursesMonitor attribute) WorkersJoined WorkerTaskTrace (class in celery.worker.job) write() (celery.log.LoggingProxy method) write_pid() (celery.platforms.PIDFile method) writelines() (celery.log.LoggingProxy method)

Y

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