Struct StepContext 

pub struct StepContext {
    pub workflow_id: String,
    pub current_step: String,
    pub outputs: HashMap<String, StepOutput>,
    pub metadata: HashMap<String, Value>,
}

Step execution context

Fields

workflow_id: String

Workflow ID

current_step: String

Current step ID

outputs: HashMap<String, StepOutput>

Outputs from previous steps

metadata: HashMap<String, Value>

Metadata

Implementations

impl StepContext

pub fn new(workflow_id: impl Into<String>) -> Self

Create a new step context

pub fn set_output(&mut self, step_id: impl Into<String>, output: StepOutput)

Set output for a step

pub fn get_output(&self, step_id: &str) -> Option<&StepOutput>

Get output from a previous step

pub fn set_metadata(&mut self, key: impl Into<String>, value: Value)

Set metadata

pub fn get_metadata(&self, key: &str) -> Option<&Value>

Get metadata

pub fn get<T: DeserializeOwned>(&self, key: &str) -> Result<T>

Get typed metadata value

Trait Implementations

impl Clone for StepContext

fn clone(&self) -> StepContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StepContext

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StepContext

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StepContext

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

where __S: Serializer,

Serialize this value into the given Serde serializer.