Struct NodePartial 

pub struct NodePartial {
    pub messages: Option<Vec<Message>>,
    pub extra: Option<FxHashMap<String, Value>>,
    pub errors: Option<Vec<ErrorEvent>>,
    pub frontier: Option<FrontierCommand>,
}

Partial state updates returned by node execution.

Represents the changes a node wants to make to the workflow state. All fields are optional, allowing nodes to update only the state aspects they care about. The workflow runtime merges these partial updates.

Examples

use weavegraph::node::NodePartial;
use weavegraph::message::{Message, Role};
use weavegraph::channels::errors::{ErrorEvent, WeaveError};
use serde_json::json;
use weavegraph::utils::collections::new_extra_map;

// Simple message-only response
let partial = NodePartial::new()
    .with_messages(vec![Message::with_role(Role::Assistant, "Done")]);

// Rich response with metadata
let mut extra = new_extra_map();
extra.insert("status".to_string(), json!("success"));
extra.insert("duration_ms".to_string(), json!(150));
let partial = NodePartial::new()
    .with_messages(vec![Message::with_role(
        Role::Assistant,
        "Processing complete",
    )])
    .with_extra(extra);

// Response with warnings
let errors = vec![ErrorEvent {
    error: WeaveError {
        message: "Low confidence result".to_string(),
        ..Default::default()
    },
    ..Default::default()
}];
let partial = NodePartial::new()
    .with_messages(vec![Message::with_role(
        Role::Assistant,
        "Result with warnings",
    )])
    .with_errors(errors);

Fields

messages: Option<Vec<Message>>

Messages to add to the workflow’s message history.

extra: Option<FxHashMap<String, Value>>

Additional key-value data to merge into the workflow’s extra storage.

errors: Option<Vec<ErrorEvent>>

Errors to add to the workflow’s error collection.

frontier: Option<FrontierCommand>

Frontier commands emitted by the node to influence subsequent routing.

Implementations

impl NodePartial

pub fn new() -> Self

pub fn with_messages(self, messages: Vec<Message>) -> Self

Create a NodePartial with one or more messages.

pub fn with_extra(self, extra: FxHashMap<String, Value>) -> Self

Create a NodePartial with extra data.

pub fn with_errors(self, errors: Vec<ErrorEvent>) -> Self

Create a NodePartial with one or more errors.

pub fn with_frontier_replace<I>(self, targets: I) -> Self

where I: IntoIterator<Item = NodeKind>,

Replace the default frontier with the provided list of targets.

The runner will skip conditional edges for the originating node when a replace command is present.

pub fn with_frontier_append<I>(self, targets: I) -> Self

where I: IntoIterator<Item = NodeKind>,

Append additional targets to the frontier alongside the default routes.

The default unconditional edges remain in place and the supplied routes are appended in-order for deterministic processing.

pub fn with_frontier_command(self, command: FrontierCommand) -> Self

Attach a pre-built frontier command.

Trait Implementations

impl Clone for NodePartial

fn clone(&self) -> NodePartial

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodePartial

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

Formats the value using the given formatter.

impl Default for NodePartial

fn default() -> NodePartial

Returns the “default value” for a type.