Index

Symbols

--maxtasksperchild celeryd command line option --purge, --discard 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 -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

_

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

A

abbr() (in module celery.bin.celeryev) abbreviations() (in module celery.bin.celeryd_multi) abbrtask() (in module celery.bin.celeryev) abort() (celery.contrib.abortable.AbortableAsyncResult method) AbortableAsyncResult (class in celery.contrib.abortable) AbortableTask (class in celery.contrib.abortable) abstract (celery.task.base.Task attribute) (celery.task.Task attribute) acknowledge() (celery.worker.job.TaskRequest method) acknowledged (celery.worker.job.TaskRequest attribute) acks_late (celery.task.base.Task attribute) (celery.task.Task attribute) ACKS_LATE (in module celery.conf) active() (celery.task.control.inspect method) active_requests (in module celery.worker.state) add() (celery.datastructures.LimitedSet method) add_bucket_for_type() (celery.worker.buckets.TaskBucket method) add_option() (celery.bin.celeryd_multi.NamespacedOptionParser method) add_queue() (celery.routes.Router method) ADMINS (in module celery.conf) after_return() (celery.task.base.Task method) (celery.task.Task method) alert() (celery.bin.celeryev.CursesMonitor method) alert_remote_control_reply() (celery.bin.celeryev.CursesMonitor method)

alive (celery.events.state.Worker attribute) alive_workers() (celery.events.state.State method) ALL_STATES (in module celery.states) AlreadyExecutedError AlreadyRegistered ALWAYS_EAGER (in module celery.conf) amqp (celery.bin.camqadm.AMQShell attribute) AMQPAdmin (class in celery.bin.camqadm) AMQPBackend (class in celery.backends.amqp) AMQShell (class in celery.bin.camqadm) apply() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool.Pool method) (celery.task.Task class method) (celery.task.TaskSet method) (celery.task.base.Task class method) (celery.task.sets.TaskSet method) (celery.task.sets.subtask method) (in module celery.execute) apply_async() (celery.beat.Scheduler method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.pool.Pool method) (celery.concurrency.threads.TaskPool method) (celery.task.Task class method) (celery.task.TaskSet method) (celery.task.base.Task class method) (celery.task.sets.TaskSet method) (celery.task.sets.subtask method) (in module celery.execute) args (celery.worker.job.TaskRequest attribute) as_dict() (celery.datastructures.LimitedSet method) AsynchronousMapTask (class in celery.task.builtins) AsyncResult (class in celery.result) AsyncResult() (celery.contrib.abortable.AbortableTask class method) (celery.task.Task class method) (celery.task.base.Task class method) AttributeDict (class in celery.datastructures) authkey (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) autoregister (celery.task.base.Task attribute) (celery.task.Task attribute)

B

backend (celery.result.AsyncResult attribute) (celery.result.BaseAsyncResult attribute) (celery.task.Task attribute) (celery.task.base.Task attribute) BackgroundThread (class in celery.worker.controllers) BaseAsyncResult (class in celery.result) BaseAsyncResult.TimeoutError BaseBackend (class in celery.backends.base) BaseBackend.TimeoutError BaseDictBackend (class in celery.backends.base) BaseLoader (class in celery.loaders.base) Beat (class in celery.bin.celerybeat) Beat.ClockService (class in celery.bin.celerybeat) BoundMethodWeakref (class in celery.utils.dispatch.saferef) BoundNonDescriptorMethodWeakref (class in celery.utils.dispatch.saferef)

bpm (celery.worker.heartbeat.Heart attribute) broadcast() (in module celery.task.control) BROADCAST_EXCHANGE (in module celery.conf) BROADCAST_EXCHANGE_TYPE (in module celery.conf) BROADCAST_QUEUE (in module celery.conf) BroadcastConsumer (class in celery.messaging) BroadcastPublisher (class in celery.messaging) BROKER_CONNECTION_MAX_RETRIES (in module celery.conf) BROKER_CONNECTION_RETRY (in module celery.conf) BROKER_CONNECTION_TIMEOUT (in module celery.conf) Bunch (class in celery.backends.mongodb)

C

CacheBackend (class in celery.backends.cache) calculate_key() (celery.utils.dispatch.saferef.BoundMethodWeakref class method) callback (celery.worker.controllers.Mediator attribute) camqadm() (in module celery.bin.camqadm) can_consume() (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TokenBucketQueue method) capacity (celery.worker.buckets.TokenBucketQueue attribute) capture() (celery.events.EventReceiver method) CarrotListener (class in celery.worker.listener) CassandraBackend (class in celery.backends.cassandra) 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.pyredis (module) celery.backends.tyrant (module) celery.beat (module) celery.bin.camqadm (module) celery.bin.celerybeat (module) celery.bin.celeryd (module) celery.bin.celeryd_multi (module) celery.bin.celeryev (module) celery.concurrency.processes (module) celery.concurrency.processes.pool (module) celery.concurrency.threads (module) celery.contrib.abortable (module) celery.datastructures (module) celery.db.models (module) celery.db.session (module) celery.decorators (module) celery.events (module) celery.events.state (module) celery.exceptions (module) celery.execute (module) celery.execute.trace (module) celery.loaders (module) celery.loaders.base (module) celery.loaders.default (module) celery.log (module) celery.messaging (module) celery.platform (module) celery.registry (module) celery.result (module) celery.routes (module) celery.serialization (module) celery.states (module) celery.task (module) celery.task.base (module), [1], [2] celery.task.builtins (module) celery.task.control (module) celery.task.http (module), [1] celery.task.schedules (module) 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.functional (module) celery.utils.info (module) celery.utils.mail (module) celery.utils.patch (module) celery.utils.timeutils (module) celery.worker (module) celery.worker.buckets (module)

celery.worker.control (module) celery.worker.control.builtins (module) celery.worker.control.registry (module) celery.worker.controllers (module) celery.worker.heartbeat (module) celery.worker.job (module) celery.worker.listener (module) celery.worker.scheduler (module) celery.worker.state (module) CELERY_CACHE_BACKEND (in module celery.conf) CELERY_LOADER CELERY_SEND_TASK_ERROR_EMAILS (in module celery.conf) celerybeat command line option -f, --logfile -l, --loglevel -s, --schedule CELERYBEAT_LOG_FILE (in module celery.conf) CELERYBEAT_LOG_LEVEL (in module celery.conf) CELERYBEAT_MAX_LOOP_INTERVAL (in module celery.conf) CELERYBEAT_SCHEDULE_FILENAME (in module celery.conf) celeryd command line option --maxtasksperchild --purge, --discard --soft-time-limit --time-limit -B, --beat -E, --events -Q, queues -c, --concurrency -f, --logfile -l, --loglevel -n, --hostname -s, --schedule CELERYD_CONCURRENCY (in module celery.conf) CELERYD_ETA_SCHEDULER (in module celery.conf) CELERYD_LISTENER (in module celery.conf) CELERYD_LOG_FILE (in module celery.conf) CELERYD_LOG_FORMAT (in module celery.conf) CELERYD_LOG_LEVEL (in module celery.conf) CELERYD_MEDIATOR (in module celery.conf) CELERYD_POOL (in module celery.conf) CELERYD_PREFETCH_MULTIPLIER (in module celery.conf) CELERYD_TASK_LOG_FORMAT (in module celery.conf) CELERYMON_LOG_FILE (in module celery.conf) CELERYMON_LOG_LEVEL (in module celery.conf) chain_from_iterable() (in module celery.utils.compat) (in module celery.worker.buckets) chronologically (celery.datastructures.LimitedSet attribute) chunks() (in module celery.utils) cleanup() (celery.backends.base.BaseBackend method) (celery.backends.cassandra.CassandraBackend method) (celery.backends.database.DatabaseBackend method) (celery.backends.mongodb.MongoBackend method) (celery.beat.Scheduler method) clear() (celery.utils.compat.OrderedDict method) (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) (celery.worker.scheduler.Scheduler method) client (celery.backends.cache.CacheBackend attribute) ClockService (class in celery.beat) close() (celery.backends.amqp.AMQPBackend method) (celery.backends.pyredis.RedisBackend method) (celery.backends.tyrant.TyrantBackend method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.pool.Pool method) (celery.events.EventDispatcher method) (celery.log.LoggingProxy method) (celery.worker.state.Persistent method) close_connection() (celery.worker.listener.CarrotListener method) coerce() (celery.bin.camqadm.Spec method) collect() (celery.messaging.ControlReplyConsumer method) ColorFormatter (class in celery.log) completed_count() (celery.result.TaskSetResult method) completenames() (celery.bin.camqadm.AMQShell method) concurrency (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) conf (celery.loaders.base.BaseLoader attribute) connect() (celery.bin.camqadm.AMQPAdmin method) (celery.utils.dispatch.signal.Signal method) connection (celery.backends.amqp.AMQPBackend attribute) consume() (celery.backends.amqp.AMQPBackend method) consume_messages() (celery.worker.listener.CarrotListener method) consume_queue() (in module celery.datastructures) consumer() (celery.events.EventReceiver method) ConsumerSet (class in celery.messaging) control_dispatch (celery.worker.listener.CarrotListener attribute) ControlDispatch (class in celery.worker.control) ControlDispatch.Panel (class in celery.worker.control) ControlReplyConsumer (class in celery.messaging) ControlReplyPublisher (class in celery.messaging) copy() (celery.utils.compat.OrderedDict method) create_event() (in module celery.events) create_exception_cls() (in module celery.serialization) create_session() (in module celery.db.session) crontab (class in celery.task.schedules) crontab_parser (class in celery.task.schedules) current_loader() (in module celery.loaders) CursesMonitor (class in celery.bin.celeryev)

D

daemon (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) DatabaseBackend (class in celery.backends.database) date_done (celery.db.models.Task attribute) (celery.db.models.TaskSet attribute) day_of_week (celery.task.schedules.crontab attribute) db (celery.worker.state.Persistent attribute) declare() (celery.messaging.TaskPublisher method) decrement() (celery.datastructures.SharedCounter method) (celery.worker.listener.QoS method) decrement_eventually() (celery.worker.listener.QoS method) default() (celery.bin.camqadm.AMQShell method) default_backend (in module celery.backends) DEFAULT_DELIVERY_MODE (in module celery.conf) DEFAULT_EXCHANGE (in module celery.conf) DEFAULT_EXCHANGE_TYPE (in module celery.conf) DEFAULT_QUEUE (in module celery.conf) DEFAULT_RATE_LIMIT (in module celery.conf) default_retry_delay (celery.task.base.Task attribute) (celery.task.Task attribute) DEFAULT_ROUTING_KEY (in module celery.conf) DefaultBackend (class in celery.backends) (in module celery.backends) delay() (celery.task.base.Task class method) (celery.task.Task class method) (celery.task.sets.subtask method) delay_task() (celery.messaging.TaskPublisher method) (in module celery.execute) DeleteExpiredTaskMetaTask (class in celery.task.builtins) deletion_methods (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) delivery_info (celery.worker.job.TaskRequest attribute) delivery_mode (celery.task.base.Task attribute) (celery.task.Task attribute) delta_resolution() (in module celery.utils.timeutils) disable() (celery.events.EventDispatcher method)

disable_error_emails (celery.task.base.Task attribute) (celery.task.Task attribute) disable_events() (celery.task.control.inspect method) (in module celery.worker.control.builtins) DISABLE_RATE_LIMITS (in module celery.conf) discard_all() (in module celery.task) (in module celery.task.control) disconnect() (celery.utils.dispatch.signal.Signal method) dispatch() (celery.bin.camqadm.AMQShell method) (celery.task.http.HttpDispatch method) dispatch_from_message() (celery.worker.control.ControlDispatch method) dispatcher (celery.task.http.URL attribute) display_command_help() (celery.bin.camqadm.AMQShell method) DisplayThread (class in celery.bin.celeryev) dmap() (in module celery.task) dmap_async() (in module celery.task) do_exit() (celery.bin.camqadm.AMQShell method) do_help() (celery.bin.camqadm.AMQShell method) do_work() (in module celery.concurrency.threads) draw() (celery.bin.celeryev.CursesMonitor method) DummyClient (class in celery.backends.cache) dump_active() (in module celery.worker.control.builtins) dump_message() (in module celery.bin.camqadm) dump_reserved() (in module celery.worker.control.builtins) dump_revoked() (in module celery.worker.control.builtins) dump_schedule() (in module celery.worker.control.builtins) dump_tasks() (in module celery.worker.control.builtins) dump_version() (in module celery.bin.celeryd) Dumper (class in celery.bin.celeryev)

E

EAGER_PROPAGATES_EXCEPTIONS (in module celery.conf) EagerResult (class in celery.result) EagerResult.TimeoutError Element (class in celery.events.state) embed_clockservice (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) EmbeddedClockService() (in module celery.beat) emergency_error() (in module celery.log) empty() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) (celery.worker.scheduler.Scheduler method) enable() (celery.events.EventDispatcher method) enable_events() (celery.task.control.inspect method) (in module celery.worker.control.builtins) encode_result() (celery.backends.base.BaseBackend method) ensure_process_aware_logger() (in module celery.utils.patch) enter() (celery.worker.scheduler.Scheduler method) environment variable CELERY_LOADER NOSE_VERBOSE establish_connection() (celery.task.base.Task class method) (celery.task.Task class method) (in module celery.messaging) eta_schedule (celery.worker.listener.CarrotListener attribute) evaluate() (celery.utils.mpromise method) (celery.utils.promise method) evaluated (celery.utils.mpromise attribute) event() (celery.events.state.State method) Event() (in module celery.events) event_dispatcher (celery.worker.listener.CarrotListener attribute) EVENT_EXCHANGE (in module celery.conf) EVENT_EXCHANGE_TYPE (in module celery.conf) EVENT_QUEUE (in module celery.conf) EVENT_ROUTING_KEY (in module celery.conf) EVENT_SERIALIZER (in module celery.conf) EventConsumer (class in celery.messaging) EventDispatcher (class in celery.events)

eventdump() (in module celery.bin.celeryev) EventPublisher (class in celery.messaging) EventReceiver (class in celery.events) eventtop() (in module celery.bin.celeryev) exc_args (celery.serialization.UnpickleableExceptionWrapper attribute) exc_cls_name (celery.serialization.UnpickleableExceptionWrapper attribute) exc_module (celery.serialization.UnpickleableExceptionWrapper attribute) exception (celery.datastructures.ExceptionInfo attribute) EXCEPTION_STATES (in module celery.states) exception_to_python() (celery.backends.base.BaseBackend method) ExceptionInfo (class in celery.datastructures) exchange (celery.task.base.Task attribute) (celery.task.Task attribute) exchange_type (celery.task.base.Task attribute) (celery.task.Task attribute) execute() (celery.execute.trace.TaskTrace method) (celery.task.Task method) (celery.task.base.Task method) (celery.worker.control.ControlDispatch method) (celery.worker.job.TaskRequest method) (celery.worker.job.WorkerTaskTrace method) execute_and_trace() (in module celery.worker.job) execute_remote() (in module celery.task) execute_safe() (celery.worker.job.WorkerTaskTrace method) execute_using_pool() (celery.worker.job.TaskRequest method) executed (celery.worker.job.TaskRequest attribute) ExecuteRemoteTask (class in celery.task.builtins) exitcode (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) expand() (celery.bin.celeryd_multi.MultiTool method) expand_destination() (celery.routes.Router method) expected_time() (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TokenBucketQueue method) extend_with_default_kwargs() (celery.worker.job.TaskRequest method) extract_msg_options() (in module celery.messaging) extract_response() (in module celery.task.http)

F

failed() (celery.result.BaseAsyncResult method) (celery.result.TaskSetResult method) FAILURE (in module celery.states) FastQueue (class in celery.worker.buckets) fileno() (celery.log.LoggingProxy method) fill_rate (celery.worker.buckets.TokenBucketQueue attribute) filled (celery.datastructures.PositionQueue attribute) filter_types() (celery.registry.TaskRegistry method) find_nearest_pickleable_exception() (in module celery.serialization) find_position() (celery.bin.celeryev.CursesMonitor method) first (celery.datastructures.LimitedSet attribute) first() (in module celery.utils) firstmethod() (in module celery.utils) flatten_reply() (in module celery.task.control) flush() (celery.events.EventDispatcher method) (celery.log.LoggingProxy method) format() (celery.log.ColorFormatter method)

format_arg() (celery.bin.camqadm.Spec method) format_broker_info() (in module celery.utils.info) format_declare_queue() (in module celery.bin.camqadm) format_opt() (in module celery.bin.celeryd_multi) format_queues() (in module celery.utils.info) format_response() (celery.bin.camqadm.Spec method) format_row() (celery.bin.celeryev.CursesMonitor method) format_signature() (celery.bin.camqadm.Spec method) format_task_event() (celery.bin.celeryev.Dumper method) from_exception() (celery.serialization.UnpickleableExceptionWrapper class method) from_message() (celery.worker.job.TaskRequest class method) fromkeys() (celery.utils.compat.OrderedDict class method) full() (celery.datastructures.PositionQueue method) fun_takes_kwargs() (in module celery.utils)

G

gen_unique_id() (in module celery.utils) get() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.pyredis.RedisBackend method) (celery.backends.tyrant.TyrantBackend method) (celery.bin.celeryd_multi.MultiTool method) (celery.result.BaseAsyncResult 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_broker_info() (in module celery.utils.info) get_bucket_for_type() (celery.worker.buckets.TaskBucket method) get_cls_by_name() (in module celery.utils) get_consumer() (celery.task.base.Task class method) (celery.task.Task class method) get_consumer_set() (in module celery.messaging) get_default_backend_cls (in module celery.backends) get_default_logger() (in module celery.log) get_engine() (in module celery.db.session) get_full_cls_name() (in module celery.utils) get_key_for_task() (celery.backends.base.KeyValueStoreBackend method) get_key_for_taskset() (celery.backends.base.KeyValueStoreBackend method)

get_loader_cls() (in module celery.loaders) get_logger() (celery.task.base.Task class method) (celery.task.Task class method) get_names() (celery.bin.camqadm.AMQShell method) get_nowait() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue 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.serialization) get_pickled_exception() (in module celery.serialization) get_publisher() (celery.task.base.Task class method) (celery.task.Task class method) get_result() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) get_status() (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) get_task() (celery.beat.Scheduler method) get_task_logger() (in module celery.log) 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) get_type() (celery.task.sets.subtask method)

H

handle_after_return() (celery.execute.trace.TaskTrace method) handle_failure() (celery.execute.trace.TaskTrace method) (celery.worker.job.WorkerTaskTrace method) handle_keypress() (celery.bin.celeryev.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) hart (celery.worker.listener.CarrotListener attribute) Heart (class in celery.worker.heartbeat) help() (celery.bin.celeryd_multi.MultiTool method)

hostname (celery.worker.listener.CarrotListener attribute) hour (celery.task.schedules.crontab attribute) http_headers (celery.task.http.HttpDispatch attribute) HttpDispatch (class in celery.task.http) HttpDispatchTask (class in celery.task) (class in celery.task.http) humanize_seconds() (in module celery.utils.info) humanize_type() (in module celery.bin.celeryev)

I

id (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_result (celery.task.base.Task attribute) (celery.task.Task attribute) IGNORE_RESULT (in module celery.conf) ignore_signal() (in module celery.platform) 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) import_default_modules() (celery.loaders.base.BaseLoader method) import_from_cwd() (celery.loaders.default.Loader method) import_task_module() (celery.loaders.base.BaseLoader method) ImproperlyConfigured increment() (celery.datastructures.SharedCounter method) (celery.worker.listener.QoS method) info (celery.concurrency.processes.TaskPool attribute) info() (celery.events.state.Task method) (celery.worker.job.TaskRequest method) (celery.worker.scheduler.Scheduler method) init_callback (celery.worker.listener.CarrotListener attribute) init_loader() (celery.bin.celerybeat.Beat method) (celery.bin.celeryd.Worker method) init_queues() (celery.bin.celeryd.Worker method) init_screen() (celery.bin.celeryev.CursesMonitor method) init_with_registry() (celery.worker.buckets.TaskBucket method) init_worker() (celery.loaders.base.BaseLoader method) initial_prefetch_count (celery.worker.listener.CarrotListener attribute) inspect (class in celery.task.control) install_HUP_not_supported_handler() (in module celery.bin.celeryd)

install_platform_tweaks() (celery.bin.celeryd.Worker method) install_signal_handler() (in module celery.platform) install_sync_handler() (celery.bin.celerybeat.Beat method) install_worker_int_again_handler() (in module celery.bin.celeryd) install_worker_int_handler() (in module celery.bin.celeryd) install_worker_restart_handler() (in module celery.bin.celeryd) install_worker_term_handler() (in module celery.bin.celeryd) instantiate() (in module celery.utils) InvalidResponseError InvalidTaskError 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.beat.Scheduler method) (celery.task.PeriodicTask method) (celery.task.base.PeriodicTask method) (celery.task.schedules.crontab method) (celery.task.schedules.schedule method) is_iterable() (in module celery.utils) isatty() (celery.log.LoggingProxy method) items (celery.worker.buckets.FastQueue attribute) (celery.worker.buckets.TaskBucket attribute) (celery.worker.buckets.TokenBucketQueue attribute) items() (celery.utils.compat.OrderedDict method) iterate() (celery.result.TaskSetResult method) iteritems() (celery.utils.compat.OrderedDict method) iterkeys() (celery.utils.compat.OrderedDict method) itersubtasks() (celery.result.TaskSetResult method) itervalues() (celery.utils.compat.OrderedDict 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.TaskSetResult method)

K

key (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) keys() (celery.utils.compat.OrderedDict method) KeyValueStoreBackend (class in celery.backends.base)

kwargs (celery.worker.job.TaskRequest attribute) kwdict() (in module celery.utils)

L

last_run_at (celery.beat.ScheduleEntry attribute) length (celery.datastructures.PositionQueue attribute) limit (celery.concurrency.processes.TaskPool attribute) LimitedSet (class in celery.datastructures) listener (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) load_settings() (in module celery.loaders) Loader (class in celery.loaders.default)

LocalCache (class in celery.datastructures) LOG_LEVELS (in module celery.conf) logfile (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) logger (celery.beat.Scheduler attribute) (celery.bin.celeryd.Worker.WorkController attribute) (celery.concurrency.processes.TaskPool attribute) (celery.worker.WorkController attribute) (celery.worker.listener.CarrotListener attribute) LoggingProxy (class in celery.log) loglevel (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) lookup_route() (celery.routes.Router method)

M

mail_admins() (in module celery.utils.mail) MAIL_HOST (in module celery.conf) MAIL_HOST_PASSWORD (in module celery.conf) MAIL_HOST_USER (in module celery.conf) MAIL_PORT (in module celery.conf) Mailer (class in celery.utils.mail) main() (in module celery.bin.camqadm) (in module celery.bin.celerybeat) (in module celery.bin.celeryd) (in module celery.bin.celeryd_multi) (in module celery.bin.celeryev) make_request() (celery.task.http.HttpDispatch method) mandatory (celery.task.base.Task attribute) (celery.task.Task attribute) map() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool.Pool method) map_async() (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.TaskPool.Pool method) MapRoute (class in celery.routes) mark_as_done() (celery.backends.base.BaseBackend method) mark_as_failure() (celery.backends.base.BaseBackend method) mark_as_retry() (celery.backends.base.BaseBackend method) mark_as_revoked() (celery.backends.base.BaseBackend method) mark_as_started() (celery.backends.base.BaseBackend method) mattrgetter() (in module celery.utils) MAX_CACHED_RESULTS (in module celery.conf) max_interval (celery.beat.Scheduler attribute) max_retries (celery.task.base.Task attribute) (celery.task.Task attribute)

MaxRetriesExceededError maybe_conn_error() (celery.worker.listener.CarrotListener method) maybe_promise() (in module celery.utils) maybe_utf8() (in module celery.task.http) mediator (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) Mediator (class in celery.worker.controllers) merge() (celery.worker.state.Persistent method) message (celery.worker.job.TaskRequest attribute) Message (class in celery.utils.mail) method (celery.task.http.HttpDispatchTask attribute) (celery.task.HttpDispatchTask attribute) minute (celery.task.schedules.crontab attribute) mitemgetter() (in module celery.utils) MongoBackend (class in celery.backends.mongodb) move_selection() (celery.bin.celeryev.CursesMonitor method) move_selection_down() (celery.bin.celeryev.CursesMonitor method) move_selection_up() (celery.bin.celeryev.CursesMonitor method) mpromise (class in celery.utils) multi_args() (in module celery.bin.celeryd_multi) MultiTool (class in celery.bin.celeryd_multi) MutableURL (class in celery.task.http)

N

name (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) (celery.task.Task attribute) (celery.task.base.Task attribute) names() (celery.bin.celeryd_multi.MultiTool method) NamespacedOptionParser (class in celery.bin.celeryd_multi) nap() (celery.bin.celeryev.CursesMonitor method) next (celery.worker.listener.QoS attribute)

next() (celery.beat.ScheduleEntry method) noop() (in module celery.utils) NOSE_VERBOSE NotConfigured NotRegistered

O

on_accepted() (celery.worker.job.TaskRequest method) on_ack (celery.worker.job.TaskRequest attribute) on_control() (celery.worker.listener.CarrotListener method) on_decode_error (celery.messaging.ConsumerSet attribute) on_decode_error() (celery.worker.listener.CarrotListener method) on_event() (celery.bin.celeryev.Dumper method) on_failed() (celery.events.state.Task method) on_failure() (celery.task.base.Task method) (celery.task.Task method) (celery.worker.job.TaskRequest method) on_heartbeat() (celery.events.state.Worker method) on_iteration() (celery.worker.controllers.BackgroundThread method) (celery.worker.controllers.Mediator method) (celery.worker.controllers.ScheduleController method) on_listener_ready() (celery.bin.celeryd.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.processes.TaskPool method) (celery.concurrency.threads.TaskPool method) on_received() (celery.events.state.Task method) on_retried() (celery.events.state.Task method) on_retry() (celery.task.base.Task method) (celery.task.Task method)

on_revoked() (celery.events.state.Task method) on_start() (celery.worker.controllers.BackgroundThread method) on_started() (celery.events.state.Task method) on_stop() (celery.worker.controllers.BackgroundThread method) on_succeeded() (celery.events.state.Task method) on_success() (celery.task.base.Task method) (celery.task.Task method) (celery.worker.job.TaskRequest method) on_task() (celery.worker.listener.CarrotListener method) on_task_init() (celery.loaders.base.BaseLoader method) on_timeout() (celery.worker.job.TaskRequest method) on_worker_error() (celery.concurrency.processes.TaskPool method) on_worker_init() (celery.loaders.base.BaseLoader method) (celery.loaders.default.Loader method) onecmd() (celery.bin.camqadm.AMQShell method) open() (celery.backends.pyredis.RedisBackend method) (celery.backends.tyrant.TyrantBackend method) (celery.worker.state.Persistent method) open_schedule() (celery.beat.ClockService method) (celery.bin.celerybeat.Beat.ClockService method) optmerge() (celery.bin.celeryd_multi.NamespacedOptionParser method) OrderedDict (class in celery.utils.compat) osx_proxy_detection_workaround() (celery.bin.celeryd.Worker method)

P

padlist() (in module celery.utils) Panel (class in celery.worker.control.registry) parse() (celery.bin.celeryd_multi.NamespacedOptionParser method) (celery.task.schedules.crontab_parser method) parse_ns_range() (in module celery.bin.celeryd_multi) parse_options() (in module celery.bin.camqadm) (in module celery.bin.celerybeat) (in module celery.bin.celeryd) (in module celery.bin.celeryev) parseline() (celery.bin.camqadm.AMQShell method) PENDING (in module celery.states) periodic() (celery.registry.TaskRegistry method) periodic_task() (in module celery.decorators) PeriodicTask (class in celery.task) (class in celery.task.base) Persistent (class in celery.worker.state) pid (celery.concurrency.processes.pool.Pool.Process attribute) (celery.concurrency.processes.TaskPool.Pool.Process attribute) ping() (in module celery.task) (in module celery.task.control) (in module celery.worker.control.builtins) PingTask (class in celery.task.builtins) poll() (celery.backends.amqp.AMQPBackend method) pool (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) Pool (class in celery.concurrency.processes.pool) Pool.AckHandler (class in celery.concurrency.processes.pool) Pool.Process (class in celery.concurrency.processes.pool) Pool.ResultHandler (class in celery.concurrency.processes.pool) Pool.SoftTimeLimitExceeded Pool.Supervisor (class in celery.concurrency.processes.pool) Pool.TaskHandler (class in celery.concurrency.processes.pool)

Pool.TimeoutHandler (class in celery.concurrency.processes.pool) pop() (celery.registry.TaskRegistry method) (celery.utils.compat.OrderedDict method) pop_value() (celery.datastructures.LimitedSet method) popitem() (celery.utils.compat.OrderedDict method) PositionQueue (class in celery.datastructures) PositionQueue.UnfilledPosition (class in celery.datastructures) post_async() (celery.task.http.URL method) prepare() (in module celery.routes) prepare_exception() (celery.backends.base.BaseBackend method) prepare_value() (celery.backends.base.BaseBackend method) process() (celery.events.EventReceiver method) process_cleanup() (celery.backends.base.BaseBackend method) (celery.backends.cassandra.CassandraBackend method) (celery.backends.mongodb.MongoBackend method) (celery.backends.pyredis.RedisBackend method) (celery.backends.tyrant.TyrantBackend 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.bin.celeryd.Worker.WorkController method) (celery.worker.WorkController method) promise (class in celery.utils) prompt (celery.bin.camqadm.AMQShell attribute) PROPAGATE_STATES (in module celery.states) purge_messages() (celery.bin.celeryd.Worker method) put() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) put_nowait() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method)

Q

QoS (class in celery.worker.listener) qsize() (celery.worker.buckets.TaskBucket method) (celery.worker.buckets.TokenBucketQueue method) query (celery.task.http.MutableURL attribute) queue (celery.task.base.Task attribute) (celery.task.Task attribute) (celery.worker.scheduler.Scheduler attribute)

QueueNotFound QUEUES (in module celery.conf) quote() (in module celery.bin.celeryd_multi)

R

rate() (in module celery.utils.timeutils) rate_limit (celery.task.base.Task attribute) (celery.task.Task attribute) rate_limit() (in module celery.task.control) (in module celery.worker.control.builtins) RateLimitExceeded read_configuration() (celery.loaders.default.Loader method) readline() (celery.bin.celeryev.CursesMonitor method) ready (celery.events.state.Task attribute) ready() (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.result.TaskSetResult method) ready_queue (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) (celery.worker.controllers.Mediator attribute) (celery.worker.listener.CarrotListener attribute) READY_STATES (in module celery.states) receive_message() (celery.worker.listener.CarrotListener method) receivers (celery.utils.dispatch.signal.Signal attribute) redirect_stdouts_to_logger() (celery.bin.celeryd.Worker method) (in module celery.log) redis_host (celery.backends.pyredis.RedisBackend attribute) redis_port (celery.backends.pyredis.RedisBackend attribute) RedisBackend (class in celery.backends.pyredis) refresh() (celery.worker.buckets.TaskBucket method) register() (celery.registry.TaskRegistry method) (celery.worker.control.ControlDispatch.Panel class method) (celery.worker.control.registry.Panel class method) registered_tasks() (celery.task.control.inspect method) registry (celery.beat.Scheduler attribute) regular() (celery.registry.TaskRegistry method) relative (celery.task.base.PeriodicTask attribute) (celery.task.PeriodicTask attribute) 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.task.base.PeriodicTask method) (celery.task.PeriodicTask method) (celery.task.schedules.crontab method) (celery.task.schedules.schedule method) RemoteExecuteError repeatlast() (in module celery.utils) reply() (celery.worker.control.ControlDispatch method) (in module celery.messaging) ReplyPublisher (celery.worker.control.ControlDispatch attribute) ReplyTo (celery.messaging.BroadcastPublisher attribute) reserved() (celery.task.control.inspect method)

reset_connection() (celery.worker.listener.CarrotListener method) reset_signal() (in module celery.platform) resetscreen() (celery.bin.celeryev.CursesMonitor method) respond() (celery.bin.camqadm.AMQShell method) restore() (celery.result.TaskSetResult class method) (celery.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) RESULT_BACKEND (in module celery.conf) RESULT_EXCHANGE (in module celery.conf) ResultConsumer (class in celery.backends.amqp) ResultPublisher (class in celery.backends.amqp) ResultSession() (celery.backends.database.DatabaseBackend method) (in module celery.db.session) RETRY (in module celery.states) retry() (celery.task.base.Task class method) (celery.task.Task class method) retry_over_time() (in module celery.utils) RetryTaskError revoke() (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.result.TaskSetResult method) (in module celery.task.control) (in module celery.worker.control.builtins) REVOKE_EXPIRES (in module celery.worker.state) revoke_selection() (celery.bin.celeryev.CursesMonitor method) REVOKED (in module celery.states) revoked (in module celery.worker.state) revoked() (celery.task.control.inspect method) (celery.worker.job.TaskRequest method) route() (celery.routes.Router method) route_for_task() (celery.routes.MapRoute method) Router (class in celery.routes) routing_key (celery.task.base.Task attribute) (celery.task.Task attribute) run() (celery.bin.camqadm.AMQPAdmin method) (celery.bin.celerybeat.Beat method) (celery.bin.celeryd.Worker method) (celery.bin.celeryev.DisplayThread method) (celery.concurrency.processes.TaskPool.Pool.AckHandler method) (celery.concurrency.processes.TaskPool.Pool.Process 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.AckHandler method) (celery.concurrency.processes.pool.Pool.Process method) (celery.concurrency.processes.pool.Pool.ResultHandler method) (celery.concurrency.processes.pool.Pool.Supervisor method) (celery.concurrency.processes.pool.Pool.TaskHandler method) (celery.concurrency.processes.pool.Pool.TimeoutHandler method) (celery.task.HttpDispatchTask method) (celery.task.Task method) (celery.task.base.Task method) (celery.task.builtins.AsynchronousMapTask method) (celery.task.builtins.DeleteExpiredTaskMetaTask method) (celery.task.builtins.ExecuteRemoteTask method) (celery.task.builtins.PingTask method) (celery.task.http.HttpDispatchTask method) (celery.worker.controllers.BackgroundThread method) (celery.worker.heartbeat.Heart method) run_celerybeat() (in module celery.bin.celerybeat) run_celeryev() (in module celery.bin.celeryev) run_every (celery.task.base.PeriodicTask attribute) (celery.task.PeriodicTask attribute) run_worker() (celery.bin.celeryd.Worker method) (in module celery.bin.celeryd)

S

safe_ref() (in module celery.utils.dispatch.saferef) save() (celery.result.TaskSetResult method) (celery.worker.state.Persistent method) save_taskset() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) say() (celery.bin.camqadm.AMQPAdmin method) (celery.bin.camqadm.AMQShell method) (in module celery.bin.camqadm) (in module celery.bin.celeryd_multi) schedule (celery.beat.ClockService attribute) (celery.beat.Scheduler attribute), [1] (celery.bin.celerybeat.Beat.ClockService attribute) (class in celery.task.schedules) schedule_controller (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) schedule_registry() (celery.beat.Scheduler method) ScheduleController (class in celery.worker.controllers) scheduled() (celery.task.control.inspect method) ScheduleEntry (class in celery.beat) scheduler (celery.beat.ClockService attribute) (celery.bin.celerybeat.Beat.ClockService attribute) Scheduler (class in celery.beat) (class in celery.worker.scheduler) scheduler_cls (celery.beat.ClockService attribute) (celery.bin.celerybeat.Beat.ClockService attribute) SchedulingError selection_info() (celery.bin.celeryev.CursesMonitor method) selection_rate_limit() (celery.bin.celeryev.CursesMonitor method) selection_result() (celery.bin.celeryev.CursesMonitor method) selection_traceback() (celery.bin.celeryev.CursesMonitor method) send() (celery.events.EventDispatcher method) (celery.messaging.BroadcastPublisher method) (celery.utils.dispatch.signal.Signal method) (celery.utils.mail.Mailer method) send_error_email() (celery.worker.job.TaskRequest method) send_event() (celery.worker.job.TaskRequest method) send_events (celery.bin.celeryd.Worker.WorkController attribute) (celery.worker.WorkController attribute) (celery.worker.listener.CarrotListener attribute) SEND_EVENTS (in module celery.conf) send_robust() (celery.utils.dispatch.signal.Signal method) send_task() (in module celery.execute) SendmailWarning serializer (celery.task.base.Task attribute) (celery.task.Task attribute) SERVER_EMAIL (in module celery.conf) servers (celery.backends.cassandra.CassandraBackend attribute) set() (celery.backends.base.KeyValueStoreBackend method) (celery.backends.cache.CacheBackend method) (celery.backends.cache.DummyClient method) (celery.backends.pyredis.RedisBackend method) (celery.backends.tyrant.TyrantBackend method) (celery.worker.listener.QoS method) set_loglevel() (in module celery.worker.control.builtins) set_mp_process_title() (in module celery.platform) set_process_status() (in module celery.bin.celeryd)

set_process_title() (celery.bin.celerybeat.Beat method) (in module celery.platform) setdefault() (celery.utils.compat.OrderedDict method) Settings (class in celery.loaders.default) setup_loader() (in module celery.loaders) setup_logger() (in module celery.log) setup_results() (in module celery.db.session) setup_settings() (celery.loaders.default.Loader method) setup_task_logger() (in module celery.log) SharedCounter (class in celery.datastructures) shutdown() (in module celery.worker.control.builtins) Signal (class in celery.utils.dispatch.signal) SilenceRepeated (class in celery.log) SoftTimeLimitExceeded Spec (class in celery.bin.camqadm) start() (celery.beat.ClockService method) (celery.bin.celerybeat.Beat.ClockService method) (celery.bin.celeryd.Worker.WorkController method) (celery.bin.celeryd_multi.MultiTool method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.concurrency.processes.pool.Pool.Process method) (celery.concurrency.threads.TaskPool method) (celery.worker.WorkController method) (celery.worker.listener.CarrotListener method) start_scheduler() (celery.bin.celerybeat.Beat method) STARTED (in module celery.states) startup_info() (celery.bin.celerybeat.Beat method) (celery.bin.celeryd.Worker method) State (class in celery.events.state) stats() (celery.task.control.inspect method) (in module celery.worker.control.builtins) status (celery.db.models.Task attribute) (celery.result.BaseAsyncResult attribute) (celery.result.EagerResult attribute) stop() (celery.beat.ClockService method) (celery.bin.celerybeat.Beat.ClockService method) (celery.bin.celeryd.Worker.WorkController method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.threads.TaskPool method) (celery.worker.WorkController method) (celery.worker.controllers.BackgroundThread method) (celery.worker.heartbeat.Heart method) (celery.worker.listener.CarrotListener method) stop_consumers() (celery.worker.listener.CarrotListener method) STORE_ERRORS_EVEN_IF_IGNORED (in module celery.conf) store_result() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) (celery.backends.base.BaseDictBackend method) str_args_to_python() (celery.bin.camqadm.Spec method) subclass_exception() (in module celery.serialization) subtask (class in celery.task.sets) subtask() (celery.task.base.Task class method) (celery.task.Task class method) subtasks (celery.result.TaskSetResult attribute) SUCCESS (in module celery.states) successful() (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.result.TaskSetResult method) sync() (celery.beat.ClockService method) (celery.bin.celerybeat.Beat.ClockService method) (celery.worker.state.Persistent method)

T

task (celery.beat.ScheduleEntry attribute) (celery.task.TaskSet attribute) (celery.task.sets.TaskSet attribute) Task (class in celery.db.models) (class in celery.events.state) (class in celery.task) (class in celery.task.base) task() (in module celery.decorators) Task.MaxRetriesExceededError, [1] task_accepted() (in module celery.worker.state) task_event() (celery.events.state.State method) task_id (celery.db.models.Task attribute) (celery.result.AsyncResult attribute) (celery.result.BaseAsyncResult attribute) (celery.worker.job.TaskRequest attribute) task_name (celery.task.sets.TaskSet attribute) (celery.task.TaskSet attribute) (celery.worker.job.TaskRequest attribute) task_postrun (in module celery.signals) task_prerun (in module celery.signals) task_ready() (in module celery.worker.state) TASK_RESULT_EXPIRES (in module celery.conf) task_sent (in module celery.signals) TASK_SERIALIZER (in module celery.conf) task_types() (celery.events.state.State method) TaskBucket (class in celery.worker.buckets) TaskConsumer (class in celery.messaging) tasklist() (celery.bin.celeryd.Worker method) TaskPool (class in celery.concurrency.processes) (class in celery.concurrency.threads) TaskPool.Pool (class in celery.concurrency.processes) TaskPool.Pool.AckHandler (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) TaskPublisher (class in celery.messaging) TaskRegistry (class in celery.registry) TaskRegistry.NotRegistered TaskRequest (class in celery.worker.job) TaskRevokedError

tasks (celery.bin.celeryev.CursesMonitor attribute) (celery.task.TaskSet attribute) (celery.task.sets.TaskSet attribute) tasks_by_timestamp() (celery.events.state.State method) tasks_by_type() (celery.events.state.State method) tasks_by_worker() (celery.events.state.State method) TaskSet (class in celery.db.models) (class in celery.task) (class in celery.task.sets) taskset_id (celery.db.models.TaskSet attribute) (celery.result.TaskSetResult attribute) TaskSetResult (class in celery.result) TaskTrace (class in celery.execute.trace) TaskType (class in celery.task.base) terminate() (celery.bin.celeryd.Worker.WorkController method) (celery.concurrency.processes.TaskPool method) (celery.concurrency.processes.TaskPool.Pool method) (celery.concurrency.processes.TaskPool.Pool.Process method) (celery.concurrency.processes.pool.Pool method) (celery.concurrency.processes.pool.Pool.Process method) (celery.worker.WorkController method) textindent() (in module celery.utils.info) tick() (celery.beat.Scheduler method) timedelta_seconds() (celery.task.base.PeriodicTask method) (celery.task.PeriodicTask method) (in module celery.utils.timeutils) TimeLimitExceeded TimeoutError timestamp (celery.worker.buckets.TokenBucketQueue attribute) to_dict() (celery.db.models.Task method) (celery.db.models.TaskSet method) TokenBucketQueue (class in celery.worker.buckets) TokenBucketQueue.RateLimitExceeded total (celery.result.TaskSetResult attribute) (celery.task.TaskSet 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.task.base.Task attribute) (celery.task.Task attribute) TRACK_STARTED (in module celery.conf) type (celery.task.base.Task attribute) (celery.task.Task attribute) tyrant_host (celery.backends.tyrant.TyrantBackend attribute) tyrant_port (celery.backends.tyrant.TyrantBackend attribute) TyrantBackend (class in celery.backends.tyrant)

U

UnknownStatusError UnpickleableExceptionWrapper UNREADY_STATES (in module celery.states) unregister() (celery.registry.TaskRegistry method) update() (celery.datastructures.LimitedSet method) (celery.events.state.Task method) (celery.utils.compat.OrderedDict method) (celery.worker.listener.QoS method)

update_bucket_for_type() (celery.worker.buckets.TaskBucket method) url (celery.task.http.HttpDispatchTask attribute) (celery.task.HttpDispatchTask attribute) URL (class in celery.task.http) usage() (celery.bin.celeryd_multi.MultiTool method) utf8dict() (in module celery.task.http)

V

values() (celery.utils.compat.OrderedDict method)

W

wait() (celery.result.BaseAsyncResult method) (celery.result.EagerResult method) (celery.worker.buckets.FastQueue method) (celery.worker.buckets.TokenBucketQueue method) wait_for() (celery.backends.amqp.AMQPBackend method) (celery.backends.base.BaseBackend method) waiting() (celery.result.TaskSetResult method) wanted_module_item() (in module celery.loaders.default) weak_func (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) weak_self (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) weekday() (in module celery.utils.timeutils) with_connection() (in module celery.messaging) WorkController (class in celery.worker) Worker (class in celery.bin.celeryd) (class in celery.events.state) Worker.WorkController (class in celery.bin.celeryd)

worker_event() (celery.events.state.State method) worker_init (in module celery.signals) worker_init() (celery.bin.celeryd.Worker method) worker_process_init (in module celery.signals) worker_ready (in module celery.signals) worker_shutdown (in module celery.signals) WorkerLostError workers (celery.bin.celeryev.CursesMonitor attribute) WorkerTaskTrace (class in celery.worker.job) write() (celery.log.LoggingProxy method) writelines() (celery.log.LoggingProxy method)