This document describes an older version of Celery (2.1).
For the latest stable version please
go here.
In-memory Representation of Cluster State - celery.events.state
-
class celery.events.state.Element
-
class celery.events.state.State(callback=None, max_workers_in_memory=5000, max_tasks_in_memory=10000)
Records clusters state.
-
alive_workers()
Returns a list of (seemingly) alive workers.
-
clear(ready=True)
-
clear_tasks(ready=True)
-
event(event)
-
event_count = 0
-
freeze_while(fun, *args, **kwargs)
-
get_or_create_task(uuid)
Get or create task by uuid.
-
get_or_create_worker(hostname, **kwargs)
Get or create worker by hostname.
-
task_count = 0
-
task_event(type, fields)
Process task event.
-
task_types()
Returns a list of all seen task types.
-
tasks_by_timestamp(limit=None)
Get tasks by timestamp.
Returns a list of (uuid, task) tuples.
-
tasks_by_type(name, limit=None)
Get all tasks by type.
Returns a list of (uuid, task) tuples.
-
tasks_by_worker(hostname, limit=None)
Get all tasks by worker.
Returns a list of (uuid, task) tuples.
-
worker_event(type, fields)
Process worker event.
-
class celery.events.state.Task(**fields)
Task State.
-
info(fields=None, extra=[])
-
merge(state, timestamp, fields)
-
merge_rules = {'RECEIVED': ('name', 'args', 'kwargs', 'retries', 'eta', 'expires')}
-
on_failed(timestamp=None, **fields)
-
on_received(timestamp=None, **fields)
-
on_retried(timestamp=None, **fields)
-
on_revoked(timestamp=None, **fields)
-
on_started(timestamp=None, **fields)
-
on_succeeded(timestamp=None, **fields)
-
ready
-
update(state, timestamp, fields)
-
class celery.events.state.Worker(**fields)
Worker State.
-
alive
-
heartbeat_max = 4
-
on_heartbeat(timestamp=None, **kwargs)
-
on_offline(**kwargs)
-
on_online(timestamp=None, **kwargs)