This document describes an older version of Celery (2.1). For the latest stable version please go here.

Worker State - celery.worker.state

class celery.worker.state.Persistent(filename)

close()

db

merge(d)

open()

save()

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

sync(d)

celery.worker.state.REVOKE_EXPIRES = 3600

celery.worker.state.active_requests

Set of currently active TaskRequest‘s.

celery.worker.state.total_count

Count of tasks executed by the worker, sorted by type.

celery.worker.state.revoked

The list of currently revoked tasks. (PERSISTENT if statedb set).

celery.worker.state.task_accepted(request)

Updates global state when a task has been accepted.

celery.worker.state.task_ready(request)

Updates global state when a task is ready.