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
¶
-
exception
-
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
¶
-
exception
-
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¶
-
class
-
djcelery.snapshot.
aware_tstamp
(secs)¶ Event timestamps uses the local timezone.