Index

_

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

A

abbreviations() (in module celery.bin.celeryd_multi) ACKS_LATE (in module celery.conf) add() (celery.datastructures.LimitedSet method) add_option() (celery.bin.celeryd_multi.NamespacedOptionParser method) add_queue() (celery.routes.Router method) ADMINS (in module celery.conf)

ALL_STATES (in module celery.states) AlreadyRegistered ALWAYS_EAGER (in module celery.conf) as_dict() (celery.datastructures.LimitedSet method) AttributeDict (class in celery.datastructures)

B

BaseLoader (class in celery.loaders.base) BoundMethodWeakref (class in celery.utils.dispatch.saferef) BoundNonDescriptorMethodWeakref (class in celery.utils.dispatch.saferef) BROADCAST_EXCHANGE (in module celery.conf) BROADCAST_EXCHANGE_TYPE (in module celery.conf)

BROADCAST_QUEUE (in module celery.conf) BROKER_CONNECTION_MAX_RETRIES (in module celery.conf) BROKER_CONNECTION_RETRY (in module celery.conf) BROKER_CONNECTION_TIMEOUT (in module celery.conf)

C

calculate_key() (celery.utils.dispatch.saferef.BoundMethodWeakref class method) celery.bin.celeryd_multi (module) celery.datastructures (module) celery.exceptions (module) celery.loaders (module) celery.loaders.base (module) celery.loaders.default (module) celery.platform (module) celery.registry (module) celery.routes (module) celery.serialization (module) celery.states (module) celery.task.base (module), [1] celery.task.http (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.mail (module) celery.utils.patch (module) celery.utils.timeutils (module) CELERY_CACHE_BACKEND (in module celery.conf) CELERY_LOADER CELERY_SEND_TASK_ERROR_EMAILS (in module celery.conf) 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_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) chronologically (celery.datastructures.LimitedSet attribute) chunks() (in module celery.utils) clear() (celery.utils.compat.OrderedDict method) conf (celery.loaders.base.BaseLoader attribute) configured (celery.loaders.base.BaseLoader attribute) connect() (celery.utils.dispatch.signal.Signal method) consume_queue() (in module celery.datastructures) copy() (celery.utils.compat.OrderedDict method) create_exception_cls() (in module celery.serialization) current_loader() (in module celery.loaders)

D

decrement() (celery.datastructures.SharedCounter method) 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_ROUTING_KEY (in module celery.conf) deletion_methods (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) delta_resolution() (in module celery.utils.timeutils) DISABLE_RATE_LIMITS (in module celery.conf) disconnect() (celery.utils.dispatch.signal.Signal method)

E

EAGER_PROPAGATES_EXCEPTIONS (in module celery.conf) ensure_process_aware_logger() (in module celery.utils.patch) environment variable CELERY_LOADER NOSE_VERBOSE evaluate() (celery.utils.mpromise method) (celery.utils.promise method) evaluated (celery.utils.mpromise attribute), [1] 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) 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) ExceptionInfo (class in celery.datastructures) expand() (celery.bin.celeryd_multi.MultiTool method) expand_destination() (celery.routes.Router method)

F

FAILURE (in module celery.states) filled (celery.datastructures.PositionQueue attribute) filter_types() (celery.registry.TaskRegistry method) find_nearest_pickleable_exception() (in module celery.serialization) first (celery.datastructures.LimitedSet attribute) first() (in module celery.utils)

firstmethod() (in module celery.utils) format_opt() (in module celery.bin.celeryd_multi) from_exception() (celery.serialization.UnpickleableExceptionWrapper 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.bin.celeryd_multi.MultiTool method) get_bound_method_weakref() (in module celery.utils.dispatch.saferef) get_cls_by_name() (in module celery.utils)

get_full_cls_name() (in module celery.utils) get_loader_cls() (in module celery.loaders) get_pickleable_exception() (in module celery.serialization) get_pickled_exception() (in module celery.serialization)

H

help() (celery.bin.celeryd_multi.MultiTool method)

I

IGNORE_RESULT (in module celery.conf) ignore_signal() (in module celery.platform) 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) init_worker() (celery.loaders.base.BaseLoader method)

install_signal_handler() (in module celery.platform) instantiate() (in module celery.utils) is_iterable() (in module celery.utils) items() (celery.utils.compat.OrderedDict method) iteritems() (celery.utils.compat.OrderedDict method) iterkeys() (celery.utils.compat.OrderedDict method) itervalues() (celery.utils.compat.OrderedDict method)

K

key (celery.utils.dispatch.saferef.BoundMethodWeakref attribute) keys() (celery.utils.compat.OrderedDict method)

kwdict() (in module celery.utils)

L

length (celery.datastructures.PositionQueue attribute) LimitedSet (class in celery.datastructures) load_settings() (in module celery.loaders) Loader (class in celery.loaders.default)

LocalCache (class in celery.datastructures) LOG_LEVELS (in module celery.conf) 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.celeryd_multi) MapRoute (class in celery.routes) mattrgetter() (in module celery.utils)

MAX_CACHED_RESULTS (in module celery.conf) MaxRetriesExceededError maybe_promise() (in module celery.utils) Message (class in celery.utils.mail) mitemgetter() (in module celery.utils) mpromise (class in celery.utils) multi_args() (in module celery.bin.celeryd_multi) MultiTool (class in celery.bin.celeryd_multi)

N

names() (celery.bin.celeryd_multi.MultiTool method) NamespacedOptionParser (class in celery.bin.celeryd_multi) noop() (in module celery.utils)

NOSE_VERBOSE NotConfigured NotRegistered

O

on_process_cleanup() (celery.loaders.base.BaseLoader method) on_task_init() (celery.loaders.base.BaseLoader method) on_worker_init() (celery.loaders.base.BaseLoader method) (celery.loaders.default.Loader method)

optmerge() (celery.bin.celeryd_multi.NamespacedOptionParser method) OrderedDict (class in celery.utils.compat) override_backends (celery.loaders.base.BaseLoader attribute)

P

padlist() (in module celery.utils) parse() (celery.bin.celeryd_multi.NamespacedOptionParser method) parse_ns_range() (in module celery.bin.celeryd_multi) PENDING (in module celery.states) periodic() (celery.registry.TaskRegistry method) 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) prepare() (in module celery.routes) process_long_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method) process_short_opt() (celery.bin.celeryd_multi.NamespacedOptionParser method) promise (class in celery.utils) PROPAGATE_STATES (in module celery.states)

Q

QueueNotFound QUEUES (in module celery.conf)

quote() (in module celery.bin.celeryd_multi)

R

rate() (in module celery.utils.timeutils) read_configuration() (celery.loaders.default.Loader method) READY_STATES (in module celery.states) receivers (celery.utils.dispatch.signal.Signal attribute) register() (celery.registry.TaskRegistry method) regular() (celery.registry.TaskRegistry method) remaining() (in module celery.utils.timeutils) repeatlast() (in module celery.utils) reset_signal() (in module celery.platform) restore() (celery.serialization.UnpickleableExceptionWrapper method)

RESULT_BACKEND (in module celery.conf) RESULT_EXCHANGE (in module celery.conf) RETRY (in module celery.states) retry_over_time() (in module celery.utils) RetryTaskError REVOKED (in module celery.states) route() (celery.routes.Router method) route_for_task() (celery.routes.MapRoute method) Router (class in celery.routes)

S

safe_ref() (in module celery.utils.dispatch.saferef) say() (in module celery.bin.celeryd_multi) send() (celery.utils.dispatch.signal.Signal method) (celery.utils.mail.Mailer method) SEND_EVENTS (in module celery.conf) send_robust() (celery.utils.dispatch.signal.Signal method) SendmailWarning SERVER_EMAIL (in module celery.conf) set_mp_process_title() (in module celery.platform) set_process_title() (in module celery.platform) setdefault() (celery.utils.compat.OrderedDict method) Settings (class in celery.loaders.default)

setup_loader() (in module celery.loaders) setup_settings() (celery.loaders.default.Loader method) SharedCounter (class in celery.datastructures) Signal (class in celery.utils.dispatch.signal) SoftTimeLimitExceeded start() (celery.bin.celeryd_multi.MultiTool method) STARTED (in module celery.states) STORE_ERRORS_EVEN_IF_IGNORED (in module celery.conf) subclass_exception() (in module celery.serialization) SUCCESS (in module celery.states)

T

task_postrun (in module celery.signals) task_prerun (in module celery.signals) TASK_RESULT_EXPIRES (in module celery.conf) task_sent (in module celery.signals) TASK_SERIALIZER (in module celery.conf) TaskRegistry (class in celery.registry) TaskRegistry.NotRegistered

TaskRevokedError timedelta_seconds() (in module celery.utils.timeutils) TimeLimitExceeded TimeoutError traceback (celery.datastructures.ExceptionInfo attribute) TRACK_STARTED (in module celery.conf)

U

UnpickleableExceptionWrapper UNREADY_STATES (in module celery.states) unregister() (celery.registry.TaskRegistry method)

update() (celery.datastructures.LimitedSet method) (celery.utils.compat.OrderedDict method) usage() (celery.bin.celeryd_multi.MultiTool method)

V

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

W

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) worker_init (in module celery.signals)

worker_initialized (celery.loaders.base.BaseLoader attribute) worker_process_init (in module celery.signals) worker_ready (in module celery.signals) worker_shutdown (in module celery.signals) WorkerLostError