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.

All fields are optional; nodes update only the aspects of state they care about. The workflow runtime merges these partial updates at each barrier.

Example

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

let mut extra = new_extra_map();
extra.insert("status".to_string(), json!("success"));

let partial = NodePartial::new()
    .with_messages(vec![Message::with_role(Role::Assistant, "Done")])
    .with_extra(extra);

Fields

messages: Option<Vec<Message>>

Messages to append to the workflow’s message history.

extra: Option<FxHashMap<String, Value>>

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

errors: Option<Vec<ErrorEvent>>

Errors to record in the workflow’s error collection.

frontier: Option<FrontierCommand>

Frontier command to influence subsequent routing.

Implementations

impl NodePartial

pub fn new() -> Self

Create an empty partial with all fields unset.

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

Set the messages to append.

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

Set the extra data to merge.

pub fn with_typed_extra<T: Serialize>( self, key: StateKey<T>, value: T, ) -> Result<Self, StateSlotError>

Insert a typed value into this partial’s extra updates.

The value is serialized to JSON and stored under the key returned by StateKey::storage_key. Any existing value at the same storage key is replaced.

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

Set the errors to record.

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

where I: IntoIterator<Item = NodeKind>,

Replace the default frontier with the provided targets.

The runner skips 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 default routes.

Default unconditional edges remain in place; 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.

pub fn clear_extra_keys<I, S>(self, keys: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Write null markers for the given extra keys.

MapMerge follows JSON Merge Patch semantics (RFC 7396) and deletes keys whose incoming value is null.

Example

use weavegraph::node::NodePartial;

let partial = NodePartial::new()
    .clear_extra_keys(["wq:feature_snapshot:v1", "wq:signal_event:v1"]);

pub fn clear_typed_extra_key<T>(self, key: StateKey<T>) -> Self

Write a null marker for a single typed extra key.

Typed companion to clear_extra_keys. The storage key is derived from the StateKey’s (namespace, name, schema_version) triple.

Example

use weavegraph::node::NodePartial;
use weavegraph::state::{StateKey, StateLifecycle};

const CURRENT_EVENT: StateKey<u64> =
    StateKey::new("wq", "event", 1).invocation_scoped();

let partial = NodePartial::new().clear_typed_extra_key(CURRENT_EVENT);

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.