This document describes Celery 3.1. For development docs,
go here.
celery.worker.state
Internal worker state (global)
This includes the currently active and reserved tasks,
statistics, and revoked tasks.
-
celery.worker.state.SOFTWARE_INFO = {'sw_sys': 'Linux', 'sw_ident': 'py-celery', 'sw_ver': '3.1.6'}
Worker software/platform information.
-
celery.worker.state.reserved_requests = set([])
set of all reserved Request‘s.
-
celery.worker.state.active_requests = set([])
set of currently active Request‘s.
-
celery.worker.state.total_count = Counter()
count of tasks accepted by the worker, sorted by type.
-
celery.worker.state.revoked = LimitedSet(0)
the list of currently revoked tasks. Persistent if statedb set.
-
celery.worker.state.task_reserved()[source]
Update global state when a task has been reserved.
-
celery.worker.state.maybe_shutdown()[source]
-
celery.worker.state.task_accepted(request)[source]
Updates global state when a task has been accepted.
-
celery.worker.state.task_ready(request)[source]
Updates global state when a task is ready.
-
celery.worker.state.task_reserved()[source]
Update global state when a task has been reserved.
-
celery.worker.state.task_ready(request)[source]
Updates global state when a task is ready.
-
class celery.worker.state.Persistent(state, filename, clock=None)[source]
This is the persistent data stored by the worker when
--statedb is enabled.
It currently only stores revoked task id’s.
-
close()[source]
-
compress()
compress(string[, level]) – Returned compressed string.
Optional arg level is the compression level, in 0-9.
-
db[source]
-
decompress()
decompress(string[, wbits[, bufsize]]) – Return decompressed string.
Optional arg wbits is the window buffer size. Optional arg bufsize is
the initial output buffer size.
-
merge()[source]
-
open()[source]
-
protocol = 2
-
save()[source]
-
storage = <module 'shelve' from '/usr/lib/python2.7/shelve.pyc'>
-
sync()[source]