Struct InvocationHandle 

pub struct InvocationHandle<R: DeserializeOwned = String> { /* private fields */ }

Handle to a submitted invocation with typed result access.

Mirrors pynenc’s BaseInvocation hierarchy. Provides:

• Status checking (non-blocking)
• Typed result retrieval (blocking or polling)
• Access to the invocation identity

Example

use rustvello_core::invocation::InvocationHandle;

// After submitting a task:
// let handle: InvocationHandle<i32> = app.submit(&my_task, params).await?;
// let status = handle.status().await?;
// let result: i32 = handle.result().await?;

Implementations

impl<R: DeserializeOwned> InvocationHandle<R>

pub fn new( invocation_id: InvocationId, orchestrator: Arc<dyn Orchestrator>, state_backend: Arc<dyn StateBackend>, ) -> Self

Create a new handle from raw parts.

pub fn invocation_id(&self) -> &InvocationId

Get the invocation’s unique identifier.

pub async fn status(&self) -> RustvelloResult<InvocationStatus>

Get the current status of this invocation.

pub async fn is_done(&self) -> RustvelloResult<bool>

Check if the invocation has finished (success or failure).

pub async fn result(&self) -> RustvelloResult<R>

Get the typed result of a completed invocation.

Returns an error if the invocation is not yet complete or failed.

pub async fn wait(&self, poll_interval: Duration) -> RustvelloResult<R>

Wait for the invocation to complete, polling at the given interval.

Returns the typed result once the invocation reaches a terminal state.

Note: Uses a fixed poll interval with no backoff. For long-running tasks, prefer a longer interval (e.g., 500ms–2s) to reduce backend load.

pub async fn wait_timeout( &self, timeout: Duration, poll_interval: Duration, ) -> RustvelloResult<R>

Wait for the invocation to complete with a timeout.

Returns Err(Timeout) if the invocation does not complete within the given duration.

pub fn into_untyped(self) -> InvocationHandle<String>

Erase the result type, returning a handle that yields raw JSON strings.

Trait Implementations

impl<R: DeserializeOwned> Debug for InvocationHandle<R>

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

Formats the value using the given formatter.