Struct WorkflowContext 

pub struct WorkflowContext { /* private fields */ }

Collects the effects an executor produces while handling a message: messages to send downstream, workflow outputs, custom events, info requests, and access to run-scoped SharedState.

This is a cheap, cloneable handle (interior mutability) so executor closures may own it and hold it across await points. Rust equivalent of WorkflowContext.

Implementations

impl WorkflowContext

pub async fn send_message(&self, data: impl Into<Value>) -> Result<(), Error>

Send a message to all connected downstream executors.

pub async fn send_to( &self, target_id: impl Into<String>, data: impl Into<Value>, ) -> Result<(), Error>

Send a message to a specific downstream executor.

pub async fn yield_output(&self, data: impl Into<Value>) -> Result<(), Error>

Emit a workflow-level output.

pub fn add_event(&self, event: WorkflowEvent)

Add a custom event to the event stream.

pub async fn request_info(&self, data: impl Into<Value>) -> Result<(), Error>

Request external information (human-in-the-loop).

Records a request whose response, once supplied via the run handle, is delivered back to this executor as a message. Mirrors Python’s ctx.request_info.

pub fn shared_state(&self) -> SharedState

Access the run-scoped SharedState shared by all executors.

pub fn executor_id(&self) -> &str

The id of the executor this context belongs to.

pub fn source_executor_ids(&self) -> &[String]

The id(s) of the executor(s) that sent the current message.

Trait Implementations

impl Clone for WorkflowContext

fn clone(&self) -> WorkflowContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.