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

copyright:
  1. 2009 - 2011 by Ask Solem.
license:

BSD, see LICENSE for more details.

class celery.worker.state.Persistent(filename)
close()
db
merge(d)
open()
save()
sync(d)
celery.worker.state.REVOKES_MAX

maximum number of revokes to keep in memory.

celery.worker.state.REVOKE_EXPIRES

how many seconds a revoke will be active before being expired when the max limit has been exceeded.

celery.worker.state.SOFTWARE_INFO

Worker software/platform information.

celery.worker.state.active_requests

set of currently active TaskRequest‘s.

celery.worker.state.reserved_requests

set of all reserved TaskRequest‘s.

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.

celery.worker.state.task_reserved(request)

Updates global state when a task has been reserved.

celery.worker.state.total_count

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

Previous topic

celery.worker.heartbeat

Next topic

celery.worker.autoscale

This Page