This document describes the current stable version of Celery (3.1). 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.

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

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()

Update global state when a task has been reserved.

celery.worker.state.maybe_shutdown()

celery.worker.state.task_accepted(request, _all_total_count=[0])

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()

Update global state when a task has been reserved.

celery.worker.state.task_ready(request)

Updates global state when a task is ready.

class celery.worker.state.Persistent(state, filename, clock=None)

This is the persistent data stored by the worker when --statedb is enabled.

It currently only stores revoked task id’s.

close()

compress()

compress(string[, level]) – Returned compressed string.

Optional arg level is the compression level, in 0-9.

db

decompress()

decompress(string[, wbits[, bufsize]]) – Return decompressed string.

Optional arg wbits indicates the window buffer size and container format. Optional arg bufsize is the initial output buffer size.

merge()

open()

protocol = 2

save()

storage = <module 'shelve' from '/usr/lib/python2.7/shelve.pyc'>

sync()