This document describes Celery 2.4. For development docs, go here.
celery.worker.state¶
celery.worker.state¶
Internal worker state (global)
This includes the currently active and reserved tasks, statistics, and revoked tasks.
| copyright: |
|
|---|---|
| license: | BSD, see LICENSE for more details. |
-
class
celery.worker.state.Persistent(filename)¶ -
close()¶
-
db¶
-
merge(d)¶
-
open()¶
-
save()¶
-
storage= <module 'shelve' from '/usr/lib/python2.7/shelve.pyc'>¶
-
sync(d)¶
-
-
celery.worker.state.REVOKES_MAX= 10000¶ maximum number of revokes to keep in memory.
-
celery.worker.state.REVOKE_EXPIRES= 3600¶ how many seconds a revoke will be active before being expired when the max limit has been exceeded.
-
celery.worker.state.SOFTWARE_INFO= {'sw_sys': 'Linux', 'sw_ident': 'celeryd', 'sw_ver': '2.4.7'}¶ Worker software/platform information.
-
celery.worker.state.active_requests= set([])¶ set of currently active
TaskRequest‘s.
-
celery.worker.state.reserved_requests= set([])¶ set of all reserved
TaskRequest‘s.
-
celery.worker.state.revoked= LimitedSet([[]])¶ the list of currently revoked tasks. Persistent if statedb set.
-
celery.worker.state.task_accepted(request)¶ Updates global state when a task has been accepted.
-
celery.worker.state.task_ready(request)¶ Updates global state when a task is ready.
-
celery.worker.state.task_reserved(request)¶ Updates global state when a task has been reserved.
-
celery.worker.state.total_count= defaultdict(<function <lambda> at 0x7fb4ebfcb7d0>, {})¶ count of tasks executed by the worker, sorted by type.
