celery.worker.state
¶
Internal worker state (global).
This includes the currently active and reserved tasks, statistics, and revoked tasks.
- class celery.worker.state.Persistent(state, filename, clock=None)[исходный код]¶
Stores worker state between restarts.
This is the persistent data stored by the worker when
celery worker --statedb
is enabled.Currently only stores revoked task id’s.
- close()[исходный код]¶
- compress(level=-1)¶
Returns a bytes object containing compressed data.
- data
Binary data to be compressed.
- level
Compression level, in 0-9 or -1.
- property db¶
- decompress(wbits=15, bufsize=16384)¶
Returns a bytes object containing the uncompressed data.
- data
Compressed data.
- wbits
The window buffer size and container format.
- bufsize
The initial output buffer size.
- merge()[исходный код]¶
- open()[исходный код]¶
- protocol = 4¶
- save()[исходный код]¶
- storage = <module 'shelve' from '/home/gruy/.pyenv/versions/3.10.4/lib/python3.10/shelve.py'>¶
- sync()[исходный код]¶
- celery.worker.state.SOFTWARE_INFO = {'sw_ident': 'py-celery', 'sw_sys': 'Linux', 'sw_ver': '5.3.1'}¶
Worker software/platform information.
- celery.worker.state.maybe_shutdown()[исходный код]¶
Shutdown if flags have been set.
- celery.worker.state.revoked = <LimitedSet(0): maxlen=50000, expires=10800.0, minlen=0>¶
the list of currently revoked tasks. Persistent if
statedb
set.
- celery.worker.state.task_accepted(request, _all_total_count=None, add_request=<method-wrapper '__setitem__' of dict object>, add_active_request=<bound method WeakSet.add of set()>, add_to_total_count=<bound method Counter.update of Counter()>)[исходный код]¶
Update global state when a task has been accepted.
- celery.worker.state.task_ready(request, successful=False, remove_request=<built-in method pop of dict object>, discard_active_request=<bound method WeakSet.discard of set()>, discard_reserved_request=<bound method WeakSet.discard of set()>)[исходный код]¶
Update global state when a task is ready.
- celery.worker.state.task_reserved(request, add_request=<method-wrapper '__setitem__' of dict object>, add_reserved_request=<bound method WeakSet.add of set()>)[исходный код]¶
Update global state when a task has been reserved.
- celery.worker.state.total_count = {}¶
count of tasks accepted by the worker, sorted by type.