Struct AsyncResult 

pub struct AsyncResult<S: ResultStore> { /* private fields */ }

AsyncResult handle for querying task results (Celery-compatible API)

Implementations

impl<S: ResultStore + Clone> AsyncResult<S>

pub fn new(task_id: TaskId, store: S) -> Self

Create a new AsyncResult for a task

pub fn with_parent(task_id: TaskId, store: S, parent: AsyncResult<S>) -> Self

Create an AsyncResult with a parent

pub fn with_children( task_id: TaskId, store: S, children: Vec<AsyncResult<S>>, ) -> Self

Create an AsyncResult with children (for group/chord results)

pub fn task_id(&self) -> TaskId

Get the task ID

pub fn parent(&self) -> Option<&AsyncResult<S>>

Get the parent result if this is a linked task

pub fn children(&self) -> &[AsyncResult<S>]

Get child results (for group/chord tasks)

pub fn add_child(&mut self, child: AsyncResult<S>)

Add a child result

pub async fn children_ready(&self) -> Result<bool>

Check if all children are ready (completed)

pub async fn collect_children( &self, timeout: Option<Duration>, ) -> Result<Vec<Option<Value>>>

Get results from all children

Returns a vector of results in the same order as children were added. Returns an error if any child failed.

pub async fn ready(&self) -> Result<bool>

Check if the task is ready (in terminal state)

pub async fn successful(&self) -> Result<bool>

Check if the task completed successfully

pub async fn failed(&self) -> Result<bool>

Check if the task failed

pub async fn state(&self) -> Result<TaskState>

Get the current task state

pub async fn info(&self) -> Result<Option<TaskResultValue>>

Get task information/metadata

pub async fn get(&self, timeout: Option<Duration>) -> Result<Option<Value>>

Get the result, blocking until it’s ready

Arguments

• timeout - Optional timeout duration. If None, waits indefinitely.

Returns

• Ok(Some(Value)) - Task succeeded with result
• Ok(None) - Task completed but has no result
• Err(_) - Task failed or timeout occurred

pub async fn result(&self) -> Result<Option<Value>>

Get the result without blocking

Returns None if the task is not yet complete

pub async fn traceback(&self) -> Result<Option<String>>

Get the error traceback if the task failed

pub async fn revoke(&self) -> Result<()>

Revoke the task

pub async fn forget(&self) -> Result<()>

Forget the task result (delete from store)

pub async fn wait(&self, timeout: Option<Duration>) -> Result<Value>

Wait for the task to complete and return the result

This is a convenience method that combines ready() and get()

Trait Implementations

impl<S: Clone + ResultStore> Clone for AsyncResult<S>

fn clone(&self) -> AsyncResult<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: ResultStore + Clone> Debug for AsyncResult<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: ResultStore + Clone> Display for AsyncResult<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.