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