Backend: Base - celery.backends.base¶

celery.backends.base

class celery.backends.base.BaseBackend¶

The base backend class. All backends should inherit from this.

cleanup()¶

Backend cleanup. Is run by celery.task.DeleteExpiredTaskMetaTask.

get_result(task_id)¶

Get the result of a task.

get_status(task_id)¶

Get the status of a task.

is_done(task_id)¶

Returns True if the task was successfully executed.

mark_as_done(task_id, result)¶

Mark task as successfully executed.

mark_as_failure(task_id, exc)¶

Mark task as executed with failure. Stores the execption.

mark_as_retry(task_id, exc)¶

Mark task for retry.

prepare_result(result)¶

Prepare result for storage.

store_result(task_id, result, status)¶

Store the result and status of a task.

wait_for(task_id, timeout=None)¶

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.timer.TimeoutError exception if the operation takes longer than timeout seconds.