Download 2.4-archived PDF

Transcript
Celery Documentation, Release 2.4.7
BaseBackend.restore_taskset(taskset_id, cache=True)
Get the result of a taskset.
BaseBackend.save_taskset(taskset_id, result)
Store the result and status of a task.
BaseBackend.store_result(task_id, result, status, traceback=None)
Store the result and status of a task.
BaseBackend.subpolling_interval = None
Time to sleep between polling each individual item in ResultSet.iterate. as opposed to the interval argument which is for each pass.
BaseBackend.wait_for(task_id, timeout=None, propagate=True, interval=0.5)
Wait for task and return its result.
If the task raises an exception, this exception will be re-raised by wait_for().
If timeout is not None, this raises the celery.exceptions.TimeoutError exception if the operation takes longer than timeout seconds.
class celery.backends.base.BaseDictBackend(*args, **kwargs)
delete_taskset(taskset_id)
forget(task_id)
get_result(task_id)
Get the result of a task.
get_status(task_id)
Get the status of a task.
get_task_meta(task_id, cache=True)
get_taskset_meta(taskset_id, cache=True)
get_traceback(task_id)
Get the traceback for a failed task.
reload_task_result(task_id)
reload_taskset_result(taskset_id)
restore_taskset(taskset_id, cache=True)
Get the result for a taskset.
save_taskset(taskset_id, result)
Store the result of an executed taskset.
store_result(task_id, result, status, traceback=None, **kwargs)
Store task result and status.
class celery.backends.base.DisabledBackend(*args, **kwargs)
get_result(*args, **kwargs)
get_status(*args, **kwargs)
get_traceback(*args, **kwargs)
store_result(*args, **kwargs)
wait_for(*args, **kwargs)
316
Chapter 11. Internals