Event Snapshots - djcelery.snapshot

class djcelery.snapshot.Camera(*args, **kwargs)
class TaskState(*args, **kwargs)

TaskState(id, state, task_id, name, tstamp, args, kwargs, eta, expires, result, traceback, runtime, retries, worker_id, hidden)

exception DoesNotExist
exception Camera.TaskState.MultipleObjectsReturned
Camera.TaskState.get_next_by_tstamp(*moreargs, **morekwargs)
Camera.TaskState.get_previous_by_tstamp(*moreargs, **morekwargs)
Camera.TaskState.get_state_display(*moreargs, **morekwargs)
Camera.TaskState.objects = <djcelery.managers.TaskStateManager object at 0x10317b7d0>
Camera.TaskState.worker
class Camera.WorkerState(*args, **kwargs)

WorkerState(id, hostname, last_heartbeat)

exception DoesNotExist
exception Camera.WorkerState.MultipleObjectsReturned
Camera.WorkerState.heartbeat_timestamp
Camera.WorkerState.is_alive()
Camera.WorkerState.objects = <djcelery.managers.ExtendedManager object at 0x103178850>
Camera.WorkerState.taskstate_set
Camera.clear_after = True
Camera.expire_states = {frozenset(['SUCCESS']): datetime.timedelta(1), frozenset(['STARTED', 'RECEIVED', 'RETRY', 'PENDING']): datetime.timedelta(5), frozenset(['FAILURE', 'RETRY', 'REVOKED']): datetime.timedelta(3)}
Camera.get_heartbeat(worker)
Camera.handle_task((uuid, task), worker=None)
Camera.handle_worker((hostname, worker))
Camera.on_cleanup()
Camera.on_shutter(*args, **kwargs)
Camera.update_task(state, **kwargs)
Camera.worker_update_freq = 60

Previous topic

Periodic Task Schedulers - djcelery.schedulers

Next topic

Database Backend - djcelery.backends.database

This Page