This document describes an older version of Celery (2.2).
For the latest stable version please
go here.
celery.worker.state
-
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.2.10'}
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 0x631ad70>, {})
count of tasks executed by the worker, sorted by type.