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)

Previous topic

Events - celery.events

Next topic

App: Worker Node - celery.apps.worker

This Page