Struct NodeContext 

pub struct NodeContext {
    pub state: State,
    pub config: ExecutionConfig,
    pub step: usize,
    /* private fields */
}

Context passed to nodes during execution

Fields

state: State

Current graph state (read-only view)

config: ExecutionConfig

Configuration for this execution

step: usize

Current step number

Implementations

impl NodeContext

pub fn new(state: State, config: ExecutionConfig, step: usize) -> Self

Create a new node context

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

Get a value from state

pub fn get_as<T: DeserializeOwned>(&self, key: &str) -> Option<T>

Get a value from state as a specific type

pub fn report_progress(&self)

Report progress, resetting the idle timeout counter.

Nodes performing long-running work should call this periodically to prevent the idle timeout from firing. If no progress handle is attached (e.g., when no idle timeout is configured), this is a no-op.

Example

async fn execute(&self, ctx: &NodeContext) -> Result<NodeOutput> {
    for chunk in large_dataset.chunks(100) {
        process(chunk).await;
        ctx.report_progress(); // reset idle timeout
    }
    Ok(NodeOutput::new())
}

pub fn set_progress_handle(&mut self, handle: ProgressHandle)

Attach a progress handle for idle timeout tracking.

This is called by the executor before running a node with an idle timeout policy. Nodes do not need to call this directly.

pub fn progress_handle(&self) -> Option<&ProgressHandle>

Get a reference to the attached progress handle, if any.