Struct WorkflowState 

pub struct WorkflowState {
    pub outputs: HashMap<String, String>,
    pub last: String,
}

Carrier for shared cross-step data. Append-only outputs map keyed by step name; the latest emitted output is exposed as last.

Fields

outputs: HashMap<String, String>

Per-step output strings, keyed by step name.

last: String

Most-recent emitted output.

Trait Implementations

impl Clone for WorkflowState

fn clone(&self) -> WorkflowState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowState

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

Formats the value using the given formatter.

impl Default for WorkflowState

fn default() -> WorkflowState

Returns the “default value” for a type.

impl GraphState for WorkflowState

Manual GraphState impl: outputs keys overwrite; last replaces.

type Update = WorkflowStateUpdate

Per-field-reducer-aware delta type.

fn apply(&mut self, u: Self::Update)

Apply a delta to self.

fn reset_ephemeral(&mut self)

Reset any #[reducer(ephemeral)] fields to Default::default(). The engine calls this at the start of every superstep, before running tasks — so ephemeral fields hold only writes from the current step. Default impl is a no-op for state types with no ephemeral fields.

impl Runnable<String, WorkflowState> for Workflow

fn invoke<'life0, 'async_trait>( &'life0 self, input: String, __arg2: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<WorkflowState>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

One-shot invocation. The hot path.

fn name(&self) -> &str

Friendly name for telemetry / introspection.

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<I>, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, CognisError>> + Send + 'async_trait>>

where 'life0: 'async_trait, I: 'static, O: 'static, Self: Sized + Sync + 'async_trait,

Run multiple inputs in parallel. Defaults to buffer_unordered honouring config.max_concurrency.

fn stream<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<RunnableStream<O>, CognisError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Sized + Sync + 'async_trait,

Stream the final output (chunks of O). Default emits one item via invoke — non-streaming runnables are correct without override.

fn stream_events<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<EventStream, CognisError>> + Send + 'async_trait>>

where 'life0: 'async_trait, I: Serialize, O: Serialize, Self: Sized + Sync + 'async_trait,

Stream structured events. Default emits OnStart + OnEnd around an invoke call. Graph engines override to surface per-node events.

fn input_schema(&self) -> Option<Value>

JSON Schema for the input type, if known.

fn output_schema(&self) -> Option<Value>

JSON Schema for the output type, if known.

impl Serialize for WorkflowState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.