Skip to main content

execute_continuation_async

Function execute_continuation_async 

Source
pub async fn execute_continuation_async(
    continuation: &WorkflowContinuation,
    input: Bytes,
) -> Result<Bytes, RuntimeError>
Expand description

Execute a workflow continuation asynchronously with parallel branch execution.

Uses the func from each task in the continuation for execution, and spawns branches in parallel using tokio tasks.

§Arguments

  • continuation - The workflow continuation to execute
  • input - Input bytes for the first task

§Errors

Returns an error if task execution fails.