This document describes 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.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]

Previous topic

celery.worker.job

Next topic

celery.worker.strategy

This Page