Struct ExecutionResult 

pub struct ExecutionResult {
    pub proceed: bool,
    pub outcome_value: Option<Value>,
    pub sleep_for: Option<Duration>,
    pub persistence_data: Option<Value>,
    pub event_name: Option<String>,
    pub event_key: Option<String>,
    pub event_as_of: Option<DateTime<Utc>>,
    pub branch_values: Option<Vec<Value>>,
    pub poll_endpoint: Option<PollEndpointConfig>,
    pub output_data: Option<Value>,
}

The result returned by a step’s run method.

ExecutionResult controls what the executor does next: proceed, branch, sleep, wait for an event, or persist state for the next execution.

Fields

proceed: bool

Whether the workflow should proceed to the next step.

outcome_value: Option<Value>

Outcome value for decision-based routing.

sleep_for: Option<Duration>

Duration to sleep before re-executing.

persistence_data: Option<Value>

Step-specific state to persist between executions.

event_name: Option<String>

Event name to wait for.

event_key: Option<String>

Event key to match.

event_as_of: Option<DateTime<Utc>>

Only consider events published after this time.

branch_values: Option<Vec<Value>>

Values to branch execution on (for ForEach/Parallel).

poll_endpoint: Option<PollEndpointConfig>

Poll endpoint configuration for external service polling.

output_data: Option<Value>

Output data to merge into workflow.data after step completion.

Implementations

impl ExecutionResult

pub fn next() -> Self

Continue to the next step.

pub fn outcome(value: impl Into<Value>) -> Self

Continue with an outcome value for decision routing.

pub fn persist(data: Value) -> Self

Pause execution and persist step-specific data.

pub fn branch(values: Vec<Value>, persistence_data: Option<Value>) -> Self

Create child branches for parallel/foreach execution.

pub fn sleep(duration: Duration, persistence_data: Option<Value>) -> Self

Sleep for a duration before re-executing.

pub fn wait_for_event( event_name: impl Into<String>, event_key: impl Into<String>, as_of: DateTime<Utc>, ) -> Self

Wait for an external event.

pub fn poll_endpoint(config: PollEndpointConfig) -> Self

Poll an external endpoint until a condition is met.

Trait Implementations

impl Clone for ExecutionResult

fn clone(&self) -> ExecutionResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionResult

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

Formats the value using the given formatter.

impl Default for ExecutionResult

fn default() -> ExecutionResult

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExecutionResult

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExecutionResult

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.