Celery 3.1 now supports Django out of the box, please see the new tutorial

Event Snapshots - djcelery.snapshot

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

class TaskState(id, state, task_id, name, tstamp, args, kwargs, eta, expires, result, traceback, runtime, retries, worker, 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>

Camera.TaskState.save(*args, **kwargs)

Camera.TaskState.worker

class Camera.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>

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)

Handle snapshotted event.

Camera.handle_worker(hostname_worker)

Camera.on_cleanup()

Camera.on_shutter(state, commit_every=100)

Camera.update_task(state, **kwargs)

Camera.worker_update_freq = 60

djcelery.snapshot.aware_tstamp(secs)

Event timestamps uses the local timezone.