Backend: AMQP - celery.backends.amqp¶

celery.backends.amqp

class celery.backends.amqp.Backend(*args, **kwargs)¶

AMQP backend. Publish results by sending messages to the broker using the task id as routing key.

NOTE: Results published using this backend is read-once only. After the result has been read, the result is deleted. (however, it’s still cached locally by the backend instance).

get_result(task_id)¶

Get the result for a task.

get_status(task_id)¶

Get the status of a task.

get_traceback(task_id)¶

Get the traceback for a failed task.

is_done(task_id)¶

Returns True if task with task_id has been executed.

store_result(task_id, result, status, traceback=None)¶

Send task return value and status.