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 0x7f7f8b948e10>
-
Camera.TaskState.save(*args, **kwargs)
-
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 0x7f7f8b93fe10>
-
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.