Index

Symbols

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

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

_

__call__() (celery.signature method)

A

abbr() (in module celery.utils.text) abbrtask() (in module celery.utils.text) abcast() (celery.app.control.Control.Mailbox method) abort() (celery.contrib.abortable.AbortableAsyncResult method) AbortableAsyncResult (class in celery.contrib.abortable) AbortableTask (class in celery.contrib.abortable) abstract (celery.app.task.Task attribute) (Task attribute) accept (celery.app.control.Control.Mailbox attribute) accept_magic_kwargs (celery.app.task.Task attribute) ack acknowledged acks_late (celery.app.task.Task attribute) (Task attribute) acquire() (celery.platforms.Pidfile method) ACTIONS (celery.bin.base.Option attribute) active (celery.concurrency.base.BasePool attribute) active() (celery.app.control.Inspect method) active_queues control active_queues() (celery.app.control.Inspect method) active_requests (in module celery.worker.state) add() (celery.bin.base.Extensions method) (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) (hub method) add_append_opt() (celery.bin.base.Command method) add_cert() (celery.security.certificate.CertStore method) add_consumer control add_consumer() (celery.app.control.Control method) add_defaults() (celery.Celery method) (celery.datastructures.ConfigurationView method) add_events() (celery.worker.autoreload.KQueueMonitor method) add_reader() (hub method) add_writer() (hub method) ADMINS setting after_return() (celery.app.task.Task method) after_setup_logger signal after_setup_task_logger signal after_task_publish signal alias (celery.bootsteps.Blueprint attribute) (celery.bootsteps.Step attribute) ALL_STATES state already_setup (celery.app.log.Logging attribute) AlreadyRegistered alt (celery.app.defaults.Option attribute)

ALWAYS_TYPED_ACTIONS (celery.bin.base.Option attribute) AlwaysEagerIgnored amqp (celery.bin.amqp.AMQShell attribute), [1] (celery.Celery attribute) (class in celery.bin.amqp) AMQPAdmin (class in celery.bin.amqp) AMQShell (class in celery.bin.amqp) annotate() (celery.app.annotations.MapAnnotation method) annotate_any() (celery.app.annotations.MapAnnotation method) app, [1] (celery.app.control.Inspect attribute) (celery.result.AsyncResult attribute) (celery.result.ResultSet attribute) (celery.worker.WorkController attribute) app_or_default() (in module celery.app) AppLoader (class in celery.loaders.app) apply apply() (celery.app.task.Task method) (celery.bootsteps.Blueprint method) (celery.signature method) apply_async() (celery.app.task.Task method) (celery.concurrency.base.BasePool method) (celery.signature method) apply_eta_task() apply_target() (in module celery.concurrency.base) appstr() (in module celery.app.utils) args (celery.bin.base.Command attribute) (celery.bin.graph.graph attribute) (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) as_dict() (celery.datastructures.LimitedSet method) as_tuple() (celery.result.AsyncResult method) (celery.result.GroupResult method) ask() (celery.bin.base.Command method) AsyncResult (celery.Celery attribute) (class in celery.result) AsyncResult() (celery.app.task.Task method) (celery.contrib.abortable.AbortableTask method) AsyncResult.TimeoutError asynloop() (in module celery.worker.loops) AttributeDict (class in celery.datastructures) AttributeDictMixin (class in celery.datastructures) ATTRS (celery.bin.base.Option attribute) autodiscover_tasks() (celery.Celery method) (celery.loaders.base.BaseLoader method) autoregister (celery.app.task.Task attribute) autoreloader Autoreloader (class in celery.worker.autoreload) autoscale() (celery.app.control.Control method) autoscaler Autoscaler (class in celery.worker.autoscale) available (celery.utils.sysinfo.df attribute) AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY

B

backend (celery.app.task.Task attribute) (Task attribute) (celery.Celery attribute) (celery.result.AsyncResult attribute) (celery.result.ResultSet attribute) 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) Beat (celery.Celery attribute) beat (class in celery.bin.beat) Beat (class in celery.worker.components) beat_embedded_init signal beat_init signal before_task_publish signal bgThread (class in celery.utils.threads) billiard bind() (queue method) black() (celery.utils.term.colored method) blink() (celery.utils.term.colored method) BlockingPool (celery.concurrency.prefork.TaskPool attribute) blue() (celery.utils.term.colored method) blueprint, [1] (celery.worker.WorkController attribute) Blueprint (class in celery.bootsteps) body (celery.utils.mail.ErrorMail attribute) body() (celery.utils.threads.bgThread method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoscale.Autoscaler method) bold() (celery.utils.term.colored method)

bootsteps() (celery.bin.graph.graph method) bright() (celery.utils.term.colored method) broadcast() (celery.app.control.Control method) BROKER_BACKEND (celery.app.utils.Settings attribute) BROKER_CONNECTION_MAX_RETRIES setting BROKER_CONNECTION_RETRY setting BROKER_CONNECTION_TIMEOUT setting BROKER_FAILOVER_STRATEGY setting BROKER_HEARTBEAT setting BROKER_HEARTBEAT_CHECKRATE setting BROKER_LOGIN_METHOD setting BROKER_POOL_LIMIT setting BROKER_TRANSPORT setting BROKER_TRANSPORT (celery.app.utils.Settings attribute) BROKER_TRANSPORT_OPTIONS setting BROKER_URL setting BROKER_URL (celery.app.utils.Settings attribute) BROKER_USE_SSL setting bucket_for_task() (consumer method) bugreport() (celery.Celery method) (in module celery.app.utils) build_graph() (celery.result.AsyncResult method) build_tracer() (in module celery.app.trace) builtin_modules (celery.loaders.base.BaseLoader attribute) builtins (celery.bin.amqp.AMQShell attribute)

C

C_FAKEFORK, [1], [2], [3] C_IMPDEBUG cached_property (in module celery.utils) call() (celery.app.control.Control.Mailbox method) call_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) call_at() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) call_repeatedly() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) calling cancel() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.base.BasePool.Timer.Entry method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.utils.timer2.Entry method) (celery.utils.timer2.Timer method) (celery.utils.timer2.Timer.Entry method) cancel_consumer control cancel_consumer() (celery.app.control.Control method) cancel_task_queue() (consumer method) cancelled (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) capacity (celery.utils.sysinfo.df attribute) carp() (celery.bin.multi.MultiTool method) CASSANDRA_COLUMN_FAMILY setting CASSANDRA_DETAILED_MODE setting CASSANDRA_KEYSPACE setting CASSANDRA_READ_CONSISTENCY setting CASSANDRA_SERVERS setting CASSANDRA_WRITE_CONSISTENCY setting cast() (celery.app.control.Control.Mailbox method) CDeprecationWarning Celery (class in celery) celery (module) celery-beat command line option --detach --max-interval -S, --scheduler -f, --logfile -l, --loglevel -s, --schedule celery-events command line option --detach -F, --freq, --frequency -c, --camera -d, --dump -l, --loglevel -r, --maxrate celery-worker command line option --autoreload --autoscale --heartbeat-interval --maxtasksperchild --no-execv --pidfile --purge --scheduler --soft-time-limit --time-limit --without-gossip --without-heartbeat --without-mingle -B, --beat -E, --events -I, --include -O -P, --pool -Q, --queues -S, --statedb -c, --concurrency -f, --logfile -l, --loglevel -n, --hostname -s, --schedule celery._state (module) celery.app (module) celery.app.annotations (module) celery.app.builtins (module) celery.app.control (module) celery.app.defaults (module) celery.app.log (module) celery.app.registry (module) celery.app.routes (module) celery.app.task (module) celery.app.trace (module) celery.app.utils (module) celery.apps.worker (module) celery.backends (module) celery.bin.amqp (module) celery.bin.base (module) celery.bin.beat (module) celery.bin.events (module) celery.bin.graph (module) celery.bin.multi (module) celery.bin.worker (module) celery.bootsteps (module) celery.concurrency (module) celery.concurrency.base (module) celery.concurrency.eventlet (module) celery.concurrency.gevent (module) celery.concurrency.prefork (module) celery.concurrency.solo (module) celery.concurrency.threads (module) celery.contrib.abortable (module) celery.contrib.methods (module) celery.contrib.migrate (module) celery.contrib.rdb (module) celery.contrib.sphinx (module) celery.datastructures (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.security (module) celery.security.certificate (module) celery.security.key (module) celery.security.serialization (module) celery.security.utils (module) celery.signals (module) celery.states (module) celery.task.base (module) celery.task.http (module) celery.utils (module) celery.utils.compat (module) celery.utils.debug (module) celery.utils.dispatch (module) celery.utils.dispatch.saferef (module) celery.utils.dispatch.signal (module) celery.utils.functional (module) celery.utils.imports (module) celery.utils.log (module) celery.utils.mail (module) celery.utils.objects (module) celery.utils.serialization (module) celery.utils.sysinfo (module) celery.utils.term (module) celery.utils.text (module) celery.utils.threads (module) celery.utils.timer2 (module) celery.worker (module) celery.worker.autoreload (module) celery.worker.autoscale (module) celery.worker.components (module) celery.worker.heartbeat (module) celery.worker.loops (module) celery.worker.state (module) CELERY_ACCEPT_CONTENT setting CELERY_ACKS_LATE setting CELERY_ALWAYS_EAGER setting CELERY_ANNOTATIONS setting CELERY_BENCH CELERY_BROADCAST_EXCHANGE setting CELERY_BROADCAST_EXCHANGE_TYPE setting CELERY_BROADCAST_QUEUE setting CELERY_BROKER_URL CELERY_CACHE_BACKEND setting CELERY_CACHE_BACKEND_OPTIONS setting CELERY_CHDIR CELERY_CHORD_PROPAGATES setting CELERY_CONFIG_MODULE, [1], [2] CELERY_COUCHBASE_BACKEND_SETTINGS setting CELERY_CREATE_DIRS CELERY_CREATE_MISSING_QUEUES setting CELERY_DEFAULT_DELIVERY_MODE setting CELERY_DEFAULT_EXCHANGE setting CELERY_DEFAULT_EXCHANGE_TYPE setting CELERY_DEFAULT_QUEUE setting CELERY_DEFAULT_RATE_LIMIT setting CELERY_DEFAULT_ROUTING_KEY setting CELERY_DISABLE_RATE_LIMITS setting CELERY_EAGER_PROPAGATES_EXCEPTIONS setting CELERY_ENABLE_REMOTE_CONTROL setting CELERY_ENABLE_UTC setting CELERY_EVENT_QUEUE_EXPIRES setting CELERY_EVENT_QUEUE_TTL setting CELERY_EVENT_SERIALIZER setting CELERY_IGNORE_RESULT setting CELERY_IMPORTS setting CELERY_INCLUDE setting CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_MAX_CACHED_RESULTS setting CELERY_MESSAGE_COMPRESSION setting

CELERY_MONGODB_BACKEND_SETTINGS setting CELERY_QUEUE_HA_POLICY setting CELERY_QUEUES setting CELERY_RDB_HOST CELERY_RDB_PORT CELERY_RDBSIG CELERY_REDIRECT_STDOUTS setting CELERY_REDIRECT_STDOUTS_LEVEL setting CELERY_REDIS_MAX_CONNECTIONS setting CELERY_RESULT_BACKEND setting CELERY_RESULT_BACKEND (celery.app.utils.Settings attribute) CELERY_RESULT_DB_SHORT_LIVED_SESSIONS setting CELERY_RESULT_DB_TABLENAMES setting CELERY_RESULT_DBURI setting CELERY_RESULT_ENGINE_OPTIONS setting CELERY_RESULT_EXCHANGE setting CELERY_RESULT_EXCHANGE_TYPE setting CELERY_RESULT_PERSISTENT setting CELERY_RESULT_SERIALIZER setting CELERY_ROUTES setting CELERY_SECURITY_CERT_STORE setting CELERY_SECURITY_CERTIFICATE setting CELERY_SECURITY_KEY setting CELERY_SEND_EVENTS setting CELERY_SEND_TASK_ERROR_EMAILS setting CELERY_SEND_TASK_SENT_EVENT setting CELERY_STORE_ERRORS_EVEN_IF_IGNORED setting CELERY_TASK_PUBLISH_RETRY setting CELERY_TASK_PUBLISH_RETRY_POLICY setting CELERY_TASK_RESULT_EXPIRES setting CELERY_TASK_SERIALIZER setting CELERY_TIMEZONE setting CELERY_TIMEZONE (celery.app.utils.Settings attribute) CELERY_TRACE_APP, [1], [2] CELERY_TRACK_STARTED setting CELERY_WORKER_DIRECT setting CELERYBEAT_MAX_LOOP_INTERVAL setting CELERYBEAT_SCHEDULE setting CELERYBEAT_SCHEDULE_FILENAME setting CELERYBEAT_SCHEDULER setting CELERYBEAT_SYNC_EVERY setting celeryd_after_setup signal CELERYD_AUTORELOADER setting CELERYD_AUTOSCALER setting CELERYD_CONCURRENCY setting CELERYD_CONSUMER setting CELERYD_FSNOTIFY, [1] CELERYD_HIJACK_ROOT_LOGGER setting celeryd_init signal CELERYD_LOG_COLOR setting CELERYD_LOG_FORMAT setting CELERYD_MAX_TASKS_PER_CHILD setting CELERYD_POOL setting CELERYD_POOL_RESTARTS setting CELERYD_PREFETCH_MULTIPLIER setting CELERYD_STATE_DB setting CELERYD_TASK_LOG_FORMAT setting CELERYD_TASK_SOFT_TIME_LIMIT setting CELERYD_TASK_TIME_LIMIT setting CELERYD_TIMER setting CELERYD_TIMER_PRECISION setting CELERYD_WORKER_LOST_WAIT setting CELERYMON_LOG_FORMAT setting Certificate (class in celery.security.certificate) CertStore (class in celery.security.certificate) chain (class in celery) chan (celery.bin.amqp.AMQShell attribute) changes (celery.datastructures.ConfigurationView attribute) check_args() (celery.bin.base.Command method) CHECK_METHODS (celery.bin.base.Option attribute) check_value() (celery.bin.base.Option method) children (celery.result.AsyncResult attribute) (celery.result.GroupResult attribute) chord (class in celery) ChordError chunks() (celery.app.task.Task method) (in module celery.utils.functional) cipater claim_steps() (celery.bootsteps.Blueprint method) cleanup() (celery.utils.threads.LocalManager method) clear() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.eventlet.TaskPool.Timer.Schedule method) (celery.concurrency.gevent.TaskPool.Timer.Schedule method) (celery.datastructures.ConfigurationView method) (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) (celery.utils.timer2.Timer method) clock() (celery.app.control.Inspect method) clone() (celery.signature method) CLOSE (celery.concurrency.base.BasePool attribute) close() (celery.bootsteps.Blueprint method) (celery.Celery method) (celery.bootsteps.StartStopStep method) (celery.concurrency.base.BasePool method) (celery.platforms.DaemonContext method) (celery.utils.log.LoggingProxy method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.components.Pool method) (celery.worker.state.Persistent method) close_open_fds() (in module celery.platforms) closed (celery.utils.log.LoggingProxy attribute) cmdline_config_parser() (celery.loaders.base.BaseLoader method) coerce() (celery.bin.amqp.Spec method) collect() (celery.result.AsyncResult method) colored (celery.bin.base.Command attribute) (celery.bin.multi.MultiTool attribute) (class in celery.utils.term) colored() (celery.app.log.Logging method) ColorFormatter (class in celery.utils.log) COLORS (celery.utils.log.ColorFormatter attribute) colors (celery.utils.log.ColorFormatter attribute) Command (class in celery.bin.base) command line option --config --executable --gid --loader --pidfile --uid --umask --workdir -A, --app -b, --broker -f, --logfile Command.Error Command.UsageError completed_count() (celery.result.ResultSet method) completenames() (celery.bin.amqp.AMQShell method) compress() (celery.worker.state.Persistent method) compression (Task attribute) conditional (celery.bootsteps.Step attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.components.Beat attribute) conf (celery.Celery attribute) (celery.loaders.base.BaseLoader attribute) conf() (celery.app.control.Inspect method) config_from_object() (celery.Celery method) (celery.loaders.base.BaseLoader method) ConfigurationView (class in celery.datastructures) configured (celery.loaders.base.BaseLoader attribute) conn (celery.bin.amqp.AMQShell attribute) connect() (celery.bin.amqp.AMQPAdmin method) (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) connect_on_app_finalize() (in module celery._state) connect_with() (celery.bootsteps.Blueprint method) connection (celery.app.control.Control.Mailbox attribute) connection() (celery.Celery method) connection_or_acquire() (celery.Celery method) CONST_ACTIONS (celery.bin.base.Option attribute) Consumer (class in celery.worker.components) consumers (celery.bootsteps.ConsumerStep attribute) ConsumerStep (class in celery.bootsteps) context control active_queues add_consumer cancel_consumer disable_events enable_events ping pool_restart rate_limit revoke shutdown control (celery.Celery attribute) Control (class in celery.app.control) Control.Mailbox (class in celery.app.control) controller convert_value() (celery.bin.base.Option method) count (celery.contrib.migrate.State attribute) counter (celery.bin.amqp.AMQShell attribute) CPendingDeprecationWarning create() (celery.bootsteps.Step method) (celery.worker.autoreload.WorkerComponent method) (celery.worker.autoscale.WorkerComponent method) (celery.worker.components.Beat method) (celery.worker.components.Consumer method) (celery.worker.components.Hub method) (celery.worker.components.Pool method) (celery.worker.components.Queues method) (celery.worker.components.StateDB method) (celery.worker.components.Timer method) create_exception_cls() (in module celery.utils.serialization) create_notifier() (celery.worker.autoreload.InotifyMonitor method) create_parser() (celery.bin.base.Command method) create_pidlock() (in module celery.platforms) cry() (in module celery.utils) current_app (in module celery) current_task (celery.Celery attribute) (in module celery) cwd_in_path() (in module celery.utils.imports) cyan() (celery.utils.term.colored method)

D

daemon_options() (in module celery.bin.base) DaemonContext (class in celery.platforms) db (celery.worker.state.Persistent attribute) debugger() (in module celery.contrib.rdb) declare() (queue method) decompress() (celery.worker.state.Persistent method) dedent() (in module celery.utils.text) dedent_initial() (in module celery.utils.text) default() (celery.bin.amqp.AMQShell method) default_app (in module celery.app) default_loader (in module celery.app) default_nodename() (in module celery.worker) default_retry_delay (celery.app.task.Task attribute) (Task attribute) default_socket_timeout() (in module celery.utils.threads) default_steps (celery.bootsteps.Blueprint attribute) (celery.worker.WorkController.Blueprint attribute) defaults (celery.datastructures.ConfigurationView attribute) delay() (celery.app.task.Task method) (celery.signature method) delete() (celery.result.GroupResult method) (exchange method) (queue method) deprecate_by (celery.app.defaults.Option attribute) deprecated() (in module celery.utils) description (celery.bin.base.Command attribute)

deserialize() (celery.security.serialization.SecureSerializer method) detached() (in module celery.platforms) df (class in celery.utils.sysinfo) DictAttribute (class in celery.datastructures) dictfilter() (in module celery.utils.functional) did_start_ok() (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) die() (celery.bin.base.Command method) disable_events control disable_events() (celery.app.control.Control method) disable_trace() (in module celery.app) discard() (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) discard_all() (celery.app.control.Control method) disconnect() (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) dispatch() (celery.bin.amqp.AMQShell method) display_command_help() (celery.bin.amqp.AMQShell method) DJANGO_SETTINGS_MODULE, [1], [2], [3], [4] do_exit() (celery.bin.amqp.AMQShell method) do_help() (celery.bin.amqp.AMQShell method) doc (celery.bin.base.Command attribute) (celery.bin.beat.beat attribute) (celery.bin.events.events attribute) (celery.bin.worker.worker attribute) DOWN (celery.bin.multi.MultiTool attribute) DuplicateNodenameWarning

E

eager_trace_task() (in module celery.app.trace) EagerResult (class in celery.result) early_version() (celery.bin.base.Command method) election() (celery.app.control.Control method) 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) empty() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) enable_config_from_cmdline (celery.bin.base.Command attribute) (celery.bin.beat.beat attribute) (celery.bin.worker.worker attribute) enable_events control enable_events() (celery.app.control.Control method) enable_trace() (in module celery.app) enabled (celery.bootsteps.Step attribute) ensure_2lines() (in module celery.utils.text) ensure_process_aware_logger() (in module celery.utils.log) ensure_started() (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.utils.timer2.Timer method) enter() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) enter_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) Entry (class in celery.utils.timer2) environment variable AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY CELERYD_FSNOTIFY, [1] CELERY_BENCH CELERY_BROKER_URL CELERY_CHDIR CELERY_CONFIG_MODULE, [1], [2] CELERY_CREATE_DIRS CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_RDBSIG CELERY_RDB_HOST, [1] CELERY_RDB_PORT, [1] CELERY_TRACE_APP, [1], [2] C_FAKEFORK, [1], [2], [3] C_IMPDEBUG DJANGO_SETTINGS_MODULE, [1], [2], [3], [4] IRON_PROJECT_ID IRON_TOKEN MP_LOG, [1] NOSE_VERBOSE USE_FAST_LOCALS epilog (celery.bin.base.Command attribute) Error error() (celery.bin.base.Command method) (celery.bin.multi.MultiTool method)

ErrorMail (class in celery.utils.mail) (Task attribute) evaluate() (celery.utils.functional.lazy method) (celery.utils.functional.mlazy method) evaluated (celery.utils.functional.mlazy attribute), [1] event task-failed task-received task-retried task-revoked task-sent task-started task-succeeded worker-heartbeat worker-offline worker-online event_dispatcher eventlet_pool_apply signal eventlet_pool_postshutdown signal eventlet_pool_preshutdown signal eventlet_pool_started signal events (celery.Celery attribute) (class in celery.bin.events) exc (celery.exceptions.Retry attribute) exc_args (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exc_cls_name (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exc_module (celery.utils.serialization.UnpickleableExceptionWrapper attribute) exception (celery.datastructures.ExceptionInfo attribute) EXCEPTION_STATES state ExceptionInfo (class in celery.datastructures) exchange (celery.app.control.Control.Mailbox attribute) exchange_fmt (celery.app.control.Control.Mailbox attribute) execute_from_commandline() (celery.bin.base.Command method) (celery.bin.multi.MultiTool method) executing exit_after() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) expand() (celery.bin.multi.MultiTool method) expand_destination() (celery.app.routes.Router method) expanduser() (celery.bin.base.Command method) expires (celery.app.task.Task attribute) Extensions (class in celery.bin.base) extra_info() (celery.apps.worker.Worker method)

F

FAILED (celery.bin.multi.MultiTool attribute) failed() (celery.result.AsyncResult method) (celery.result.ResultSet method) FAILURE state FAILURE (in module celery.states) fd_by_path() (in module celery.platforms) file_hash() (in module celery.worker.autoreload) fill_paragraphs() (in module celery.utils.text) filter_hidden_settings() (in module celery.app.utils) filter_types() (celery.app.registry.TaskRegistry method) filtered (celery.contrib.migrate.State attribute) finalize() (celery.Celery method) find() (in module celery.app.defaults) find_app() (celery.bin.base.Command method) (in module celery.app.utils) find_changes() (celery.worker.autoreload.StatMonitor method) find_module() (celery.loaders.base.BaseLoader method) (in module celery.utils.imports) find_option() (celery.app.utils.Settings method) find_pickleable_exception() (in module celery.utils.serialization) find_value_for_key() (celery.app.utils.Settings method) first() (celery.datastructures.ConfigurationView method) (in module celery.utils.functional) firstmethod() (in module celery.utils.functional) FixupWarning

flatten() (in module celery.app.defaults) flatten_links() (celery.signature method) flatten_reply() (in module celery.app.control) flush() (celery.concurrency.base.BasePool method) (celery.utils.log.LoggingProxy method) force_scale_down() (celery.worker.autoscale.Autoscaler method) force_scale_up() (celery.worker.autoscale.Autoscaler method) forget() (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) format() (celery.app.log.TaskFormatter method) (celery.utils.log.ColorFormatter method) format_arg() (celery.bin.amqp.Spec method) format_body() (celery.utils.mail.ErrorMail method) format_description() (celery.bin.base.HelpFormatter method) format_epilog() (celery.bin.base.HelpFormatter method) format_response() (celery.bin.amqp.Spec method) format_signature() (celery.bin.amqp.Spec method) format_subject() (celery.utils.mail.ErrorMail method) formatException() (celery.utils.log.ColorFormatter method) freeze() (celery.signature method) (State method) freeze_while() (State method) from_exception() (celery.utils.serialization.UnpickleableExceptionWrapper class method) FSCertStore (class in celery.security.certificate) fun (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute)

G

gen_task_name() (in module celery.utils) get() (celery.bin.multi.MultiTool method) (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) get_amqp_api_command() (celery.bin.amqp.AMQShell method) get_backend_by_url() (in module celery.backends) get_backend_cls() (in module celery.backends) get_by_parts() (celery.app.utils.Settings method) get_cls_by_name() (celery.bin.base.Command method) get_consumers() (celery.bootsteps.ConsumerStep method) get_current_app() (in module celery._state) get_current_task() (in module celery._state) get_current_worker_task() (in module celery._state) get_default_logger() (celery.app.log.Logging method) get_errno_name() (in module celery.platforms) get_fdmax() (in module celery.platforms) get_id() (celery.security.certificate.Certificate method) get_ident() (celery.utils.threads.LocalManager method) (in module celery.utils.threads) get_implementation() (in module celery.concurrency) get_issuer() (celery.security.certificate.Certificate method) get_leaf() (celery.result.AsyncResult method) get_loader_cls() (in module celery.loaders)

get_logger() (in module celery.utils.log) get_multiprocessing_logger() (in module celery.utils.log) get_names() (celery.bin.amqp.AMQShell method) get_opt_string() (celery.bin.base.Option method) get_options() (celery.bin.base.Command method) (celery.bin.beat.beat method) (celery.bin.events.events method) (celery.bin.worker.worker method) get_pickleable_etype() (in module celery.utils.serialization) get_pickleable_exception() (in module celery.utils.serialization) get_pickled_exception() (in module celery.utils.serialization) get_queue() (celery.app.control.Control.Mailbox method) get_reply_queue() (celery.app.control.Control.Mailbox method) get_serial_number() (celery.security.certificate.Certificate method) get_task_logger() (in module celery.utils.log) getpids() (celery.bin.multi.MultiTool method) gossip graph (celery.result.AsyncResult attribute) (class in celery.bin.graph) GraphFormatter (celery.bootsteps.Blueprint attribute) green() (celery.utils.term.colored method) group (class in celery) GroupResult (celery.Celery attribute) (class in celery.result) grow() (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method)

H

handle_argv() (celery.bin.base.Command method) handle_error_state() (celery.app.trace.TraceInfo method) handle_event() (celery.worker.autoreload.KQueueMonitor method) handle_failure() (celery.app.trace.TraceInfo method) handle_retry() (celery.app.trace.TraceInfo method) has_expired() (celery.security.certificate.Certificate method) heart Heart (class in celery.worker.heartbeat) hello() (celery.app.control.Inspect method)

help() (celery.bin.multi.MultiTool method) HelpFormatter (class in celery.bin.base) host_format() (celery.bin.base.Command method) hostname, [1] hub, [1] Hub (class in celery.worker.components) human_state() (celery.bootsteps.Blueprint method) humanize() (celery.app.utils.Settings method) (celery.exceptions.Retry method)

I

iblue() (celery.utils.term.colored method) icyan() (celery.utils.term.colored method) id (celery.result.AsyncResult attribute) (celery.result.GroupResult attribute) idempotent identchars (celery.bin.amqp.AMQShell attribute) Ignore ignore_errno() (in module celery.platforms) ignore_result (celery.app.task.Task attribute) (Task attribute) igreen() (celery.utils.term.colored method) imagenta() (celery.utils.term.colored method) import_default_modules() (celery.loaders.base.BaseLoader method) import_from_cwd() (celery.loaders.base.BaseLoader method) (in module celery.utils.imports) import_module() (celery.loaders.base.BaseLoader method) import_modules signal import_task_module() (celery.loaders.base.BaseLoader method) ImproperlyConfigured in_sighandler() (in module celery.utils.log) inc_counter (celery.bin.amqp.AMQShell attribute) include() (celery.bootsteps.StartStopStep method) (celery.bootsteps.Step method) include_if() (celery.bootsteps.Step method) (celery.worker.components.Hub method) incr() (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) indent() (in module celery.utils.text) info (celery.concurrency.base.BasePool attribute) (celery.result.AsyncResult attribute) info() (celery.bin.multi.MultiTool method) (celery.bootsteps.Blueprint method) (celery.bootsteps.Step method) (celery.worker.WorkController method) (celery.worker.autoscale.Autoscaler method) (celery.worker.components.Pool method) init_worker() (celery.loaders.base.BaseLoader method) init_worker_process() (celery.loaders.base.BaseLoader method) initgroups() (in module celery.platforms)

InotifyMonitor (class in celery.worker.autoreload) inspect (celery.app.control.Control attribute) Inspect (class in celery.app.control) install_platform_tweaks() (celery.apps.worker.Worker method) instantiate() (celery.bootsteps.Step method) (in module celery.utils.imports) internal (celery.datastructures.ExceptionInfo attribute) InvalidTaskError ired() (celery.utils.term.colored method) IRON_PROJECT_ID IRON_TOKEN is_aborted() (celery.contrib.abortable.AbortableAsyncResult method) (celery.contrib.abortable.AbortableTask method) is_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.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) itercerts() (celery.security.certificate.CertStore method) iterdeps() (celery.result.AsyncResult method) iteritems() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) iterkeys() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) itervalues() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) iwhite() (celery.utils.term.colored method) iyellow() (celery.utils.term.colored method)

J

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

jsonify() (in module celery.utils)

K

keys() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) kill() (celery.bin.multi.MultiTool method) kombu

KQueueMonitor (class in celery.worker.autoreload) kwargs (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute)

L

label (celery.bootsteps.Step attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.components.Beat attribute) (celery.worker.components.Queues attribute) last (celery.bootsteps.Step attribute) (celery.worker.components.Consumer attribute) lazy (class in celery.utils.functional) leaf (celery.bin.base.Command attribute) LimitedSet (class in celery.datastructures) link() (celery.signature method) link_error() (celery.signature method) load() (celery.bin.base.Extensions method) load_average() (in module celery.utils.sysinfo) load_step() (celery.bootsteps.Blueprint method) loader (celery.Celery attribute) Loader (class in celery.loaders.default)

Local (class in celery.utils.threads) LocalManager (class in celery.utils.threads) LocalStack (in module celery.utils.threads) LockFailed log (celery.Celery attribute) Logging (class in celery.app.log) LoggingProxy (class in celery.utils.log) loglevel (celery.utils.log.LoggingProxy attribute) lookup_route() (celery.app.routes.Router method) lpmerge() (in module celery.utils) LRUCache (class in celery.datastructures) (class in celery.utils.functional)

M

magenta() (celery.utils.term.colored method) mail (celery.loaders.base.BaseLoader attribute) mail_admins() (celery.Celery method) (celery.loaders.base.BaseLoader method) Mailer (class in celery.utils.mail) main (celery.Celery attribute) main() (in module celery.bin.worker) maintain_pool() (celery.concurrency.base.BasePool method) map() (celery.app.task.Task method) MapAnnotation (class in celery.app.annotations) MapRoute (class in celery.app.routes) mattrgetter() (in module celery.utils.functional) max_retries (celery.app.task.Task attribute) (Task attribute) MaxRetriesExceededError maybe_detach() (celery.bin.worker.worker method) maybe_drop_privileges() (in module celery.platforms) maybe_evaluate() (in module celery.utils.functional) maybe_list() (in module celery.utils.functional) maybe_patch_concurrency() (celery.bin.base.Command method) maybe_reraise() (celery.result.AsyncResult method) (celery.result.ResultSet method) (in module celery.utils) maybe_scale() (celery.worker.autoscale.Autoscaler method) maybe_shutdown() (in module celery.worker.state) mem_rss() (in module celery.utils.debug)

memdump() (celery.app.control.Inspect method) (in module celery.utils.debug) memoize() (in module celery.utils.functional) memsample() (celery.app.control.Inspect method) merge() (celery.worker.state.Persistent method) message (celery.exceptions.Retry attribute) Message (class in celery.utils.mail) migrate_task() (in module celery.contrib.migrate) migrate_tasks() (in module celery.contrib.migrate) mlazy (class in celery.utils.functional) mlevel() (in module celery.utils.log) mode (celery.utils.log.LoggingProxy attribute) module_file() (in module celery.utils.imports) Monitor (celery.worker.autoreload.Autoreloader attribute) (in module celery.worker.autoreload) move() (in module celery.contrib.migrate) move_by_idmap() (in module celery.contrib.migrate) move_by_taskmap() (in module celery.contrib.migrate) move_task_by_id() (in module celery.contrib.migrate) MP_LOG, [1] mro_lookup() (in module celery.utils.objects) multi_call() (celery.app.control.Control.Mailbox method) MultiTool (class in celery.bin.multi)

N

name (celery.app.task.Task attribute) (Task attribute) (celery.bootsteps.Blueprint attribute) (celery.bootsteps.ConsumerStep attribute) (celery.bootsteps.StartStopStep attribute) (celery.bootsteps.Step attribute) (celery.utils.log.LoggingProxy attribute) (celery.worker.WorkController.Blueprint attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.components.Beat attribute) (celery.worker.components.Consumer attribute) (celery.worker.components.Hub attribute) (celery.worker.components.Pool attribute) (celery.worker.components.Queues attribute) (celery.worker.components.StateDB attribute) (celery.worker.components.Timer attribute) names() (celery.bin.multi.MultiTool method) namespace (celery.app.control.Control.Mailbox attribute) (celery.bin.base.Command attribute) (celery.bin.worker.worker attribute) needs_reconnect (celery.bin.amqp.AMQShell attribute) next() (celery.concurrency.base.BasePool.Timer method) (celery.utils.timer2.Timer method) no_color (celery.bin.base.Command attribute) no_color() (celery.utils.term.colored method) Node() (celery.app.control.Control.Mailbox method) node() (celery.utils.term.colored method) node_alive() (celery.bin.multi.MultiTool method) node_cls (celery.app.control.Control.Mailbox attribute) node_format() (celery.bin.base.Command method)

nodename() (in module celery.utils) nodesplit() (in module celery.utils) noop() (in module celery.utils.functional) NOSE_VERBOSE NotAPackage NotConfigured note() (celery.bin.amqp.AMQPAdmin method) (celery.bin.amqp.AMQShell method) (celery.bin.multi.MultiTool method) NotRegistered now() (celery.Celery method) (celery.loaders.base.BaseLoader method) nullipotent num_processes (celery.concurrency.base.BasePool attribute) (celery.concurrency.gevent.TaskPool attribute) (celery.concurrency.prefork.TaskPool attribute)

O

obj (celery.bootsteps.StartStopStep attribute) (celery.datastructures.DictAttribute attribute) objgraph() (celery.app.control.Inspect method) oid (celery.app.control.Control.Mailbox attribute) OK (celery.bin.multi.MultiTool attribute) on_after_init() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_apply() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.threads.TaskPool method) on_before_init() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_bound() (celery.app.task.Task class method) on_change() (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) on_close() (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) (celery.worker.WorkController method) on_concurrency_setup() (celery.bin.base.Command method) on_configure() (celery.Celery method) on_consumer_ready() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_crash() (celery.utils.threads.bgThread method) on_error() (celery.bin.base.Command method) on_event_loop_close() (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) on_failure() (celery.app.task.Task method) on_hard_timeout() (celery.concurrency.base.BasePool method) on_init() (celery.worker.autoreload.Autoreloader method) on_init_blueprint() (celery.apps.worker.Worker method) (celery.worker.WorkController method) on_process_cleanup() (celery.loaders.base.BaseLoader method) on_readable() (celery.worker.autoreload.InotifyMonitor method)

on_retry() (celery.app.task.Task method) on_soft_timeout() (celery.concurrency.base.BasePool method) on_start() (celery.apps.worker.Worker method) (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.prefork.TaskPool method) (celery.concurrency.threads.TaskPool method) (celery.worker.WorkController method) on_stop() (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) (celery.concurrency.prefork.TaskPool method) (celery.concurrency.threads.TaskPool method) on_stopped() (celery.worker.WorkController method) on_success() (celery.app.task.Task method) on_task_init() (celery.loaders.base.BaseLoader method) on_terminate() (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) on_tick (celery.concurrency.base.BasePool.Timer attribute) (celery.utils.timer2.Timer attribute) on_timer_error() (celery.worker.components.Timer method) on_timer_tick() (celery.worker.components.Timer method) on_usage_error() (celery.bin.base.Command method) on_worker_init() (celery.loaders.base.BaseLoader method) on_worker_process_init() (celery.loaders.base.BaseLoader method) on_worker_shutdown() (celery.loaders.base.BaseLoader method) onecmd() (celery.bin.amqp.AMQShell method) open() (celery.platforms.DaemonContext method) (celery.worker.state.Persistent method) Option (class in celery.app.defaults) (class in celery.bin.base) option_list (celery.bin.base.Command attribute) osx_proxy_detection_workaround() (celery.apps.worker.Worker method) out() (celery.bin.base.Command method) override_backends (celery.loaders.base.BaseLoader attribute)

P

padlist() (in module celery.utils.functional) parent (celery.result.ResultBase attribute) parse_doc() (celery.bin.base.Command method) parse_gid() (in module celery.platforms) parse_options() (celery.bin.base.Command method) parse_preload_options() (celery.bin.base.Command method) parse_uid() (in module celery.platforms) parseline() (celery.bin.amqp.AMQShell method) Parser (celery.bin.base.Command attribute) path (celery.platforms.Pidfile attribute) PENDING state PENDING (in module celery.states) periodic() (celery.app.registry.TaskRegistry method) Persistent (class in celery.worker.state) Pickler (celery.Celery attribute) Pidfile (class in celery.platforms) pidlock (celery.worker.WorkController attribute) ping control ping() (celery.app.control.Control method) (celery.app.control.Inspect method) pluralize() (in module celery.utils.text) pool, [1] (celery.Celery attribute) Pool (celery.concurrency.prefork.TaskPool attribute) pool (celery.worker.WorkController attribute) Pool (class in celery.worker.components) pool_grow() (celery.app.control.Control method) pool_restart control pool_shrink() (celery.app.control.Control method) pop_value() (celery.datastructures.LimitedSet method) popitem() (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) precedence() (in module celery.states)

prefetch count prefetch multiplier preload_options (celery.bin.base.Command attribute) prepare() (in module celery.app.annotations) (in module celery.app.routes) prepare_args() (celery.bin.base.Command method) (celery.worker.WorkController method) prepare_parser() (celery.bin.base.Command method) preparse_options() (celery.bin.base.Command method) pretty() (celery.bin.base.Command method) (in module celery.utils.text) pretty_dict_ok_error() (celery.bin.base.Command method) pretty_list() (celery.bin.base.Command method) PrivateKey (class in celery.security.key) process() (celery.bin.base.Option method) process_() (celery.worker.autoreload.InotifyMonitor method) process_cmdline_config() (celery.bin.base.Command method) process_destructor() (in module celery.concurrency.prefork) process_IN_ATTRIB() (celery.worker.autoreload.InotifyMonitor method) process_IN_MODIFY() (celery.worker.autoreload.InotifyMonitor method) process_initializer() (in module celery.concurrency.prefork) processes (celery.worker.autoscale.Autoscaler attribute) producer_or_acquire() (celery.Celery method) prog_name (celery.bin.base.Command attribute) prompt (celery.bin.amqp.AMQShell attribute) prompt_fmt (celery.bin.amqp.AMQShell attribute) PROPAGATE_STATES state protocol (celery.worker.state.Persistent attribute) ps() (in module celery.utils.debug) purge() (celery.app.control.Control method) (celery.datastructures.LimitedSet method) purge_messages() (celery.apps.worker.Worker method) pyimplementation() (in module celery.platforms) Python Enhancement Proposals PEP 8

Q

qos qty (celery.worker.autoscale.Autoscaler attribute) qualname() (in module celery.utils.imports) query_task() (celery.app.control.Inspect method)

queue (celery.concurrency.base.BasePool.Timer attribute) (celery.concurrency.eventlet.TaskPool.Timer.Schedule attribute) (celery.concurrency.gevent.TaskPool.Timer.Schedule attribute) (celery.utils.timer2.Timer attribute) QueueNotFound Queues (class in celery.worker.components)

R

rate_limit control rate_limit (celery.app.task.Task attribute) (Task attribute) rate_limit() (celery.app.control.Control method) Rdb (class in celery.contrib.rdb) read_configuration() (celery.loaders.base.BaseLoader method) (celery.loaders.default.Loader method) read_pid() (celery.platforms.Pidfile method) ready() (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) READY_STATES state RECEIVED (in module celery.states) receivers (celery.utils.dispatch.Signal attribute) (celery.utils.dispatch.signal.Signal attribute) red() (celery.utils.term.colored method) redirect_stdouts() (celery.app.log.Logging method) redirect_stdouts_to_logger() (celery.app.log.Logging method) redirect_to_null() (celery.platforms.DaemonContext method) reentrant regen() (in module celery.utils.functional) register() (celery.app.registry.TaskRegistry method) register_auth() (in module celery.security.serialization) register_with_event_loop() (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) (celery.worker.WorkController method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.autoreload.StatMonitor method) (celery.worker.autoreload.WorkerComponent method) (celery.worker.autoscale.WorkerComponent method) (celery.worker.components.Pool method) registered() (celery.app.control.Inspect method) registered_tasks() (celery.app.control.Inspect method) regular() (celery.app.registry.TaskRegistry method) release() (celery.platforms.Pidfile method) reload() (celery.worker.WorkController method) reload_from_cwd() (in module celery.utils.imports) remove() (celery.platforms.Pidfile method) (celery.result.ResultSet method) (hub method) remove_by (celery.app.defaults.Option attribute) remove_if_stale() (celery.platforms.Pidfile method) replace() (celery.signature method) reply_exchange (celery.app.control.Control.Mailbox attribute) reply_exchange_fmt (celery.app.control.Control.Mailbox attribute) reply_queue (celery.app.control.Control.Mailbox attribute) report() (celery.app.control.Inspect method) republish() (in module celery.contrib.migrate) request (Task attribute) (celery.app.task.Task attribute) requires (celery.bootsteps.ConsumerStep attribute) (celery.bootsteps.Step attribute) (celery.worker.autoreload.WorkerComponent attribute) (celery.worker.autoscale.WorkerComponent attribute) (celery.worker.components.Hub attribute) (celery.worker.components.Pool attribute) (celery.worker.components.Queues attribute) reraise_errors() (in module celery.security.utils) reserved() (celery.app.control.Inspect method) reserved_requests (in module celery.worker.state)

reset() (celery.utils.term.colored method) reset_multiprocessing_logger() (in module celery.utils.log) reset_rate_limits() (consumer method) reset_worker_optimizations() (in module celery.app.trace) resolve_all() (in module celery.app.annotations) respects_app_option (celery.bin.base.Command attribute) respond() (celery.bin.amqp.AMQShell method) restart() (celery.bin.multi.MultiTool method) (celery.bootsteps.Blueprint method) (celery.concurrency.base.BasePool method) (celery.concurrency.prefork.TaskPool method) restore() (celery.result.GroupResult class method) (celery.utils.serialization.UnpickleableExceptionWrapper method) result (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) result_from_tuple() (in module celery.result) ResultBase (class in celery.result) results (celery.result.GroupResult attribute) (celery.result.ResultSet attribute) ResultSet (class in celery.result) retcode (celery.bin.multi.MultiTool attribute) RETRY state Retry RETRY (in module celery.states) retry() (celery.app.task.Task method) retval (celery.app.trace.TraceInfo attribute) reverse() (celery.utils.term.colored method) revoke control revoke() (celery.app.control.Control method) (celery.result.AsyncResult method) (celery.result.EagerResult method) (celery.result.ResultSet method) REVOKED state REVOKED (in module celery.states) revoked (in module celery.worker.state) revoked() (celery.app.control.Inspect method) route() (celery.app.routes.Router method) route_for_task() (celery.app.routes.MapRoute method) Router (class in celery.app.routes) RUN (celery.concurrency.base.BasePool attribute) run() (celery.app.task.Task method) (celery.bin.amqp.AMQPAdmin method) (celery.bin.amqp.amqp method) (celery.bin.base.Command method) (celery.bin.beat.beat method) (celery.bin.events.events method) (celery.bin.graph.graph method) (celery.bin.worker.worker method) (celery.concurrency.base.BasePool.Timer method) (celery.utils.threads.bgThread method) (celery.utils.timer2.Timer method) run_evcam() (celery.bin.events.events method) run_evdump() (celery.bin.events.events method) run_evtop() (celery.bin.events.events method) run_from_argv() (celery.bin.base.Command method) (celery.bin.worker.worker method) running (celery.concurrency.base.BasePool.Timer attribute) (celery.utils.timer2.Timer attribute) rusage() (celery.worker.WorkController method)

S

s() (celery.app.task.Task method) safe_ref() (in module celery.utils.dispatch.saferef) sample() (in module celery.utils.debug) sample_mem() (in module celery.utils.debug) save() (celery.result.GroupResult method) (celery.worker.state.Persistent method) say() (celery.bin.amqp.AMQShell method) (celery.bin.multi.MultiTool method) say_chat() (celery.bin.base.Command method) say_remote_command_reply() (celery.bin.base.Command method) scale_down() (celery.worker.autoscale.Autoscaler method) scale_up() (celery.worker.autoscale.Autoscaler method) Schedule (celery.concurrency.base.BasePool.Timer attribute) (celery.utils.timer2.Timer attribute) (in module celery.utils.timer2) scheduled() (celery.app.control.Inspect method) SecureSerializer (class in celery.security.serialization) SecurityError select_queues() (celery.Celery method) semaphore (celery.worker.WorkController attribute) send() (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) (celery.utils.mail.ErrorMail method) (celery.utils.mail.Mailer method) send_all() (celery.bootsteps.Blueprint method) send_error_emails (celery.app.task.Task attribute) (Task attribute) send_robust() (celery.utils.dispatch.Signal method) (celery.utils.dispatch.signal.Signal method) send_task() (celery.Celery method) SendmailWarning serializable() (celery.result.AsyncResult method) (celery.result.GroupResult method) serialize() (celery.security.serialization.SecureSerializer method) serializer (celery.app.control.Control.Mailbox attribute) (Task attribute) (celery.app.task.Task attribute) SERVER_EMAIL setting set() (celery.signature method) set_current() (celery.Celery method) set_default_app() (in module celery._state) set_in_sighandler() (in module celery.utils.log) set_mp_process_title() (in module celery.platforms) set_process_status() (celery.apps.worker.Worker method) (celery.bin.events.events method) set_process_title() (in module celery.platforms) set_trace() (in module celery.contrib.rdb) setdefault() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) setgid() (in module celery.platforms) setgroups() (in module celery.platforms) setting ADMINS BROKER_CONNECTION_MAX_RETRIES BROKER_CONNECTION_RETRY BROKER_CONNECTION_TIMEOUT BROKER_FAILOVER_STRATEGY BROKER_HEARTBEAT BROKER_HEARTBEAT_CHECKRATE BROKER_LOGIN_METHOD BROKER_POOL_LIMIT BROKER_TRANSPORT BROKER_TRANSPORT_OPTIONS BROKER_URL BROKER_USE_SSL CASSANDRA_COLUMN_FAMILY CASSANDRA_DETAILED_MODE CASSANDRA_KEYSPACE CASSANDRA_READ_CONSISTENCY CASSANDRA_SERVERS CASSANDRA_WRITE_CONSISTENCY CELERYBEAT_MAX_LOOP_INTERVAL CELERYBEAT_SCHEDULE CELERYBEAT_SCHEDULER CELERYBEAT_SCHEDULE_FILENAME CELERYBEAT_SYNC_EVERY CELERYD_AUTORELOADER CELERYD_AUTOSCALER CELERYD_CONCURRENCY CELERYD_CONSUMER CELERYD_HIJACK_ROOT_LOGGER CELERYD_LOG_COLOR CELERYD_LOG_FORMAT CELERYD_MAX_TASKS_PER_CHILD CELERYD_POOL CELERYD_POOL_RESTARTS CELERYD_PREFETCH_MULTIPLIER CELERYD_STATE_DB CELERYD_TASK_LOG_FORMAT CELERYD_TASK_SOFT_TIME_LIMIT CELERYD_TASK_TIME_LIMIT CELERYD_TIMER CELERYD_TIMER_PRECISION CELERYD_WORKER_LOST_WAIT CELERYMON_LOG_FORMAT CELERY_ACCEPT_CONTENT CELERY_ACKS_LATE CELERY_ALWAYS_EAGER CELERY_ANNOTATIONS CELERY_BROADCAST_EXCHANGE CELERY_BROADCAST_EXCHANGE_TYPE CELERY_BROADCAST_QUEUE CELERY_CACHE_BACKEND CELERY_CACHE_BACKEND_OPTIONS CELERY_CHORD_PROPAGATES CELERY_COUCHBASE_BACKEND_SETTINGS CELERY_CREATE_MISSING_QUEUES CELERY_DEFAULT_DELIVERY_MODE CELERY_DEFAULT_EXCHANGE CELERY_DEFAULT_EXCHANGE_TYPE CELERY_DEFAULT_QUEUE CELERY_DEFAULT_RATE_LIMIT CELERY_DEFAULT_ROUTING_KEY CELERY_DISABLE_RATE_LIMITS CELERY_EAGER_PROPAGATES_EXCEPTIONS CELERY_ENABLE_REMOTE_CONTROL CELERY_ENABLE_UTC CELERY_EVENT_QUEUE_EXPIRES CELERY_EVENT_QUEUE_TTL CELERY_EVENT_SERIALIZER CELERY_IGNORE_RESULT CELERY_IMPORTS CELERY_INCLUDE CELERY_MAX_CACHED_RESULTS CELERY_MESSAGE_COMPRESSION CELERY_MONGODB_BACKEND_SETTINGS CELERY_QUEUES CELERY_QUEUE_HA_POLICY CELERY_REDIRECT_STDOUTS CELERY_REDIRECT_STDOUTS_LEVEL CELERY_REDIS_MAX_CONNECTIONS CELERY_RESULT_BACKEND CELERY_RESULT_DBURI CELERY_RESULT_DB_SHORT_LIVED_SESSIONS CELERY_RESULT_DB_TABLENAMES CELERY_RESULT_ENGINE_OPTIONS CELERY_RESULT_EXCHANGE CELERY_RESULT_EXCHANGE_TYPE CELERY_RESULT_PERSISTENT CELERY_RESULT_SERIALIZER CELERY_ROUTES CELERY_SECURITY_CERTIFICATE CELERY_SECURITY_CERT_STORE CELERY_SECURITY_KEY CELERY_SEND_EVENTS CELERY_SEND_TASK_ERROR_EMAILS CELERY_SEND_TASK_SENT_EVENT CELERY_STORE_ERRORS_EVEN_IF_IGNORED CELERY_TASK_PUBLISH_RETRY CELERY_TASK_PUBLISH_RETRY_POLICY CELERY_TASK_RESULT_EXPIRES CELERY_TASK_SERIALIZER CELERY_TIMEZONE CELERY_TRACK_STARTED CELERY_WORKER_DIRECT EMAIL_HOST EMAIL_HOST_PASSWORD EMAIL_HOST_USER EMAIL_PORT EMAIL_TIMEOUT EMAIL_USE_SSL EMAIL_USE_TLS SERVER_EMAIL Settings (class in celery.app.utils) setuid() (in module celery.platforms) setup() (celery.app.log.Logging method) setup_app_from_commandline() (celery.bin.base.Command method) setup_defaults() (celery.worker.WorkController method) setup_handlers() (celery.app.log.Logging method) setup_includes() (celery.worker.WorkController method) setup_instance() (celery.worker.WorkController method) setup_logger() (celery.app.log.Logging method) setup_logging signal setup_logging() (celery.apps.worker.Worker method) setup_logging_subsystem() (celery.app.log.Logging method) setup_queues() (celery.worker.WorkController method) setup_security() (celery.Celery method) (in module celery.security) setup_settings() (celery.loaders.default.Loader method) setup_task_loggers() (celery.app.log.Logging method) setup_worker_optimizations() (in module celery.app.trace) Shell (celery.bin.amqp.AMQPAdmin attribute) should_send() (celery.app.task.Task.ErrorMail method) (celery.utils.mail.ErrorMail method) should_use_eventloop() (celery.worker.WorkController method) show() (celery.bin.multi.MultiTool method) show_body (celery.bin.base.Command attribute) show_reply (celery.bin.base.Command attribute) shrink() (celery.concurrency.eventlet.TaskPool method) (celery.concurrency.gevent.TaskPool method) shutdown control

shutdown() (celery.bootsteps.ConsumerStep method) shutdown_nodes() (celery.bin.multi.MultiTool method) shutdown_worker() (celery.loaders.base.BaseLoader method) si() (celery.app.task.Task method) sign() (celery.security.key.PrivateKey method) signal after_setup_logger after_setup_task_logger after_task_publish beat_embedded_init beat_init before_task_publish celeryd_after_setup celeryd_init eventlet_pool_apply eventlet_pool_postshutdown eventlet_pool_preshutdown eventlet_pool_started import_modules setup_logging task_failure task_postrun task_prerun task_retry task_revoked task_sent task_success user_preload_options worker_init worker_process_init worker_process_shutdown worker_ready worker_shutdown Signal (class in celery.utils.dispatch) (class in celery.utils.dispatch.signal) signal_consumer_close() (celery.worker.WorkController method) signal_node() (celery.bin.multi.MultiTool method) signal_safe (celery.concurrency.base.BasePool attribute) (celery.concurrency.eventlet.TaskPool attribute) (celery.concurrency.gevent.TaskPool attribute) signature (class in celery) signature() (celery.Celery method) soft_time_limit (celery.app.task.Task attribute) (Task attribute) SoftTimeLimitExceeded SOFTWARE_INFO (in module celery.worker.state) Spec (class in celery.bin.amqp) splash() (celery.bin.multi.MultiTool method) starmap() (celery.app.task.Task method) start() (celery.bin.multi.MultiTool method) (celery.Celery method) (celery.bootsteps.Blueprint method) (celery.bootsteps.ConsumerStep method) (celery.bootsteps.StartStopStep method) (celery.concurrency.base.BasePool method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.worker.WorkController method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.autoreload.StatMonitor method) (celery.worker.components.Hub method) (celery.worker.heartbeat.Heart method) start_filter() (in module celery.contrib.migrate) STARTED state started (celery.bootsteps.Blueprint attribute) STARTED (in module celery.states) StartStopStep (class in celery.bootsteps) startup_info() (celery.apps.worker.Worker method) stat (celery.utils.sysinfo.df attribute) state ALL_STATES EXCEPTION_STATES FAILURE PENDING PROPAGATE_STATES READY_STATES RETRY REVOKED STARTED SUCCESS UNREADY_STATES state (celery.app.trace.TraceInfo attribute) (celery.bootsteps.Blueprint attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) (celery.worker.WorkController attribute) State (class in celery.contrib.migrate) state (class in celery.states) state_to_name (celery.bootsteps.Blueprint attribute) statedb StateDB (class in celery.worker.components) StatMonitor (class in celery.worker.autoreload) stats() (celery.app.control.Inspect method) (celery.worker.WorkController method) status (celery.bin.base.Command.Error attribute) (celery.bin.base.Command.UsageError attribute) (celery.bin.base.Error attribute) (celery.bin.base.UsageError attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) Step (class in celery.bootsteps) steps (celery.Celery attribute) stop() (celery.bin.multi.MultiTool method) (celery.bootsteps.Blueprint method) (celery.bootsteps.ConsumerStep method) (celery.bootsteps.StartStopStep method) (celery.concurrency.base.BasePool method) (celery.concurrency.base.BasePool.Timer method) (celery.concurrency.eventlet.TaskPool.Timer method) (celery.concurrency.gevent.TaskPool.Timer method) (celery.utils.threads.bgThread method) (celery.utils.timer2.Timer method) (celery.worker.WorkController method) (celery.worker.autoreload.Autoreloader method) (celery.worker.autoreload.BaseMonitor method) (celery.worker.autoreload.InotifyMonitor method) (celery.worker.autoreload.KQueueMonitor method) (celery.worker.components.Hub method) (celery.worker.heartbeat.Heart method) stop_verify() (celery.bin.multi.MultiTool method) StopFiltering stopwait() (celery.bin.multi.MultiTool method) storage (celery.worker.state.Persistent attribute) STORE_ACTIONS (celery.bin.base.Option attribute) store_errors_even_if_ignored (celery.app.task.Task attribute) (Task attribute) str_args_to_python() (celery.bin.amqp.Spec method) strategies Strategy (celery.app.task.Task attribute) strtobool() (in module celery.utils) strtotal (celery.contrib.migrate.State attribute) subclass_exception() (in module celery.utils.serialization) subject (celery.utils.mail.ErrorMail attribute) subtask() (celery.app.task.Task method) subtasks (celery.result.ResultSet attribute) SUCCESS state SUCCESS (in module celery.states) successful() (celery.result.AsyncResult method) (celery.result.ResultSet method) supports_args (celery.bin.base.Command attribute) (celery.bin.beat.beat attribute) (celery.bin.events.events attribute) (celery.bin.worker.worker attribute) supports_color() (celery.app.log.Logging method) supports_native_join (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) (celery.result.ResultSet attribute) symbol_by_name() (celery.bin.base.Command method) (in module celery.utils.imports) sync() (celery.worker.state.Persistent method) synloop() (in module celery.worker.loops)

T

table() (celery.app.utils.Settings method) take_action() (celery.bin.base.Option method) takes_value() (celery.bin.base.Option method) Task (celery.Celery attribute) (class in celery.app.task) task() (celery.Celery method) (in module celery.contrib.methods) task-failed event task-received event task-retried event task-revoked event task-sent event task-started event task-succeeded event Task.ErrorMail (class in celery.app.task) Task.MaxRetriesExceededError task_accepted() (in module celery.worker.state) task_buckets task_consumer task_failure signal task_id (celery.result.AsyncResult attribute) task_id_eq() (in module celery.contrib.migrate) task_id_in() (in module celery.contrib.migrate) task_join_will_block (celery.concurrency.base.BasePool attribute) (celery.concurrency.eventlet.TaskPool attribute) (celery.concurrency.gevent.TaskPool attribute) task_method (in module celery.contrib.methods) task_name (celery.result.EagerResult attribute) task_postrun signal task_prerun signal task_ready() (in module celery.worker.state), [1] task_reserved() (in module celery.worker.state), [1] task_retry signal task_revoked signal task_sent signal task_success signal 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.prefork) (class in celery.concurrency.solo) (class in celery.concurrency.threads) TaskPool.Timer (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent) TaskPool.Timer.Schedule (class in celery.concurrency.eventlet) (class in celery.concurrency.gevent)

TaskRegistry (class in celery.app.registry) TaskRegistry.NotRegistered TaskRevokedError tasks (celery.Celery attribute) TaskType (class in celery.app.task) tb (celery.datastructures.ExceptionInfo attribute) TERMINATE (celery.concurrency.base.BasePool attribute) terminate() (celery.bootsteps.StartStopStep method) (celery.concurrency.base.BasePool method) (celery.worker.WorkController method) (celery.worker.components.Hub method) (celery.worker.components.Pool method) terminate_job() (celery.concurrency.base.BasePool method) Terminated thaw() (State method) throws (celery.app.task.Task attribute) (Task attribute) time_limit (celery.app.task.Task attribute) (Task attribute) time_limit() (celery.app.control.Control method) TimeLimitExceeded TimeoutError timer, [1] Timer (class in celery.utils.timer2) (class in celery.worker.components) Timer.Entry (class in celery.utils.timer2) timezone (celery.Celery attribute) to_python() (celery.app.defaults.Option method) to_timestamp() (in module celery.utils.timer2) total_apx (celery.contrib.migrate.State attribute) total_blocks (celery.utils.sysinfo.df attribute) total_count (in module celery.worker.state) trace_task() (in module celery.app.trace) traceback (celery.datastructures.ExceptionInfo attribute) (celery.result.AsyncResult attribute) (celery.result.EagerResult attribute) TraceInfo (class in celery.app.trace) track_started (celery.app.task.Task attribute) (Task attribute) trail (celery.app.task.Task attribute) (Task attribute) tref (celery.concurrency.base.BasePool.Timer.Entry attribute) (celery.utils.timer2.Entry attribute) (celery.utils.timer2.Timer.Entry attribute) truncate() (in module celery.utils.text) type (celery.app.control.Control.Mailbox attribute) (celery.datastructures.ExceptionInfo attribute) TYPE_CHECKER (celery.bin.base.Option attribute) TYPED_ACTIONS (celery.bin.base.Option attribute) typemap (celery.app.defaults.Option attribute) TYPES (celery.bin.base.Option attribute)

U

underline() (celery.utils.term.colored method) uniq() (in module celery.utils.functional) UnpickleableExceptionWrapper UNREADY_STATES state unregister() (celery.app.registry.TaskRegistry method) update() (celery.datastructures.ConfigurationView method) (celery.datastructures.LRUCache method) (celery.datastructures.LimitedSet method) (celery.result.ResultSet method) (celery.utils.functional.LRUCache method) (celery.worker.autoscale.Autoscaler method) update_state() (celery.app.task.Task method)

usage() (celery.bin.base.Command method) (celery.bin.multi.MultiTool method) UsageError USE_FAST_LOCALS user_options (celery.Celery attribute) user_preload_options signal uses_semaphore (celery.concurrency.base.BasePool attribute) (celery.concurrency.prefork.TaskPool attribute)

V

value_set_for() (celery.app.utils.Settings method) values() (celery.datastructures.ConfigurationView method) (celery.datastructures.DictAttribute method) (celery.datastructures.LRUCache method) (celery.utils.functional.LRUCache method) verify() (celery.security.certificate.Certificate method)

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

W

wait() (celery.result.AsyncResult method) (celery.result.EagerResult method) waitexec() (celery.bin.multi.MultiTool method) waiting() (celery.result.ResultSet method) warn_deprecated() (in module celery.utils) when (celery.exceptions.Retry attribute) white() (celery.utils.term.colored method) with_detacher_default_options() (celery.bin.multi.MultiTool method) with_pool_option() (celery.bin.base.Command method) (celery.bin.worker.worker method) without_defaults() (celery.app.utils.Settings method) WorkController (celery.Celery attribute) (class in celery.worker) WorkController.Blueprint (class in celery.worker) Worker (celery.Celery attribute) (class in celery.apps.worker) worker (class in celery.bin.worker) worker-heartbeat event worker-offline event worker-online event worker_direct() (in module celery.utils)

worker_init signal worker_initialized (celery.loaders.base.BaseLoader attribute) worker_main() (celery.Celery method) worker_process_init signal worker_process_shutdown signal worker_ready signal worker_shutdown signal WorkerComponent (class in celery.worker.autoreload) (class in celery.worker.autoscale) WorkerLostError workers() (celery.bin.graph.graph method) WorkerShutdown WorkerTerminate write() (celery.utils.log.LoggingProxy method) write_pid() (celery.platforms.Pidfile method) write_stats (celery.concurrency.prefork.TaskPool attribute) writelines() (celery.utils.log.LoggingProxy method)

Y

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