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(data, /, level=-1, wbits=15)

Returns a bytes object containing compressed data.

data

Binary data to be compressed.

level

Compression level, in 0-9 or -1.

wbits

The window buffer size and container format.

property db

decompress(data, /, 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 '/opt/hostedtoolcache/Python/3.12.10/x64/lib/python3.12/shelve.py'>

sync()

celery.worker.state.SOFTWARE_INFO = {'sw_ident': 'py-celery', 'sw_sys': 'Linux', 'sw_ver': '5.5.1'}

Worker software/platform information.

celery.worker.state.active_requests = set()

set of currently active Request's.

celery.worker.state.maybe_shutdown()

Shutdown if flags have been set.

celery.worker.state.reserved_requests = set()

set of all reserved Request's.

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.