This document describes the current stable version of Celery (3.1). For development docs,
go here.
celery.utils.threads
Threading utilities.
-
class celery.utils.threads.bgThread(name=None, **kwargs)[source]
-
body()[source]
-
on_crash(msg, *fmt, **kwargs)[source]
-
run()[source]
-
stop()[source]
Graceful shutdown.
-
class celery.utils.threads.Local[source]
-
celery.utils.threads.LocalStack
alias of _LocalStack
-
class celery.utils.threads.LocalManager(locals=None, ident_func=None)[source]
Local objects cannot manage themselves. For that you need a local
manager. You can pass a local manager multiple locals or add them
later by appending them to manager.locals. Everytime the manager
cleans up it, will clean up all the data left in the locals for this
context.
The ident_func parameter can be added to override the default ident
function for the wrapped locals.
-
cleanup()[source]
Manually clean up the data in the locals for this context.
Call this at the end of the request or use make_middleware().
-
get_ident()[source]
Return the context identifier the local objects use internally
for this context. You cannot override this method to change the
behavior but use it to link other context local objects (such as
SQLAlchemy’s scoped sessions) to the Werkzeug locals.
-
celery.utils.threads.get_ident()
-
celery.utils.threads.default_socket_timeout(*args, **kwds)[source]