In-memory Representation of Cluster State - celery.events.state

class celery.events.state.Element(**fields)

Base class for types.

class celery.events.state.State(callback=None, max_workers_in_memory=5000, max_tasks_in_memory=10000)

Represents a snapshot of a clusters state.

alive_workers()

Returns a list of (seemingly) alive workers.

event(event)

Process event.

get_or_create_task(uuid, **kwargs)

Get or create task by uuid.

get_or_create_worker(hostname, **kwargs)

Get or create worker by hostname.

task_event(type, fields)

Process task event.

task_types()

Returns a list of all seen task types.

tasks_by_timestamp()

Get tasks by timestamp.

Returns a list of (uuid, task) tuples.

tasks_by_type(name)

Get all tasks by type.

Returns a list of (uuid, task) tuples.

tasks_by_worker(hostname)

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=[])

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(d, **extra)

class celery.events.state.Worker(**fields)

Worker State.

alive

on_heartbeat(timestamp=None, **kwargs)

on_offline(**kwargs)

on_online(timestamp=None, **kwargs)