Struct TimeoutPolicy 

pub struct TimeoutPolicy {
    pub run_timeout: Duration,
    pub idle_timeout: Option<Duration>,
    pub refresh_on: Option<Arc<dyn Fn(&Value) -> bool + Send + Sync>>,
}

Node-level timeout policy

Prevents LLM calls or tool execution from blocking indefinitely. Configured per-node through the graph builder.

Examples

use juncture_core::pregel::context::TimeoutPolicy;
use std::time::Duration;

let policy = TimeoutPolicy::default()
    .with_run_timeout(Duration::from_secs(60));

Fields

run_timeout: Duration

Maximum runtime for a single execution

idle_timeout: Option<Duration>

Idle timeout: if no progress signal within this time, consider timed out

refresh_on: Option<Arc<dyn Fn(&Value) -> bool + Send + Sync>>

Progress signal detector (refreshes idle_timeout on heartbeat)

Receives a serializable event representation containing event type and node name.

Implementations

impl TimeoutPolicy

pub fn new() -> Self

Create a new timeout policy with defaults

pub const fn with_run_timeout(self, timeout: Duration) -> Self

Set the run timeout

pub const fn with_idle_timeout(self, timeout: Duration) -> Self

Set the idle timeout

Trait Implementations

impl Clone for TimeoutPolicy

fn clone(&self) -> TimeoutPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TimeoutPolicy

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

Formats the value using the given formatter.

impl Default for TimeoutPolicy

fn default() -> Self

Returns the “default value” for a type.