Struct RuntimeGraphNodeHandler 

pub struct RuntimeGraphNodeHandler { /* private fields */ }

Production GraphNodeHandler wrapping the durable graph executor.

Tool dispatch goes straight through the shared ExtensionRuntime via dispatch_tool_call.

Implementations

impl RuntimeGraphNodeHandler

pub fn from_parts( graphs: Arc<dyn GraphConfigSource>, checkpoint: Arc<dyn CheckpointStore>, state_store: Arc<dyn AgentStateStore>, ext_runtime: Arc<ExtensionRuntime>, llm: Arc<dyn LlmBackend>, telemetry: Arc<dyn Telemetry>, token_meter: Arc<dyn TokenMeter>, ledger: Arc<dyn ToolLedger>, audit_sink: Option<AuditSink>, ) -> RuntimeGraphNodeHandler

Build a handler from the runtime’s constituent parts.

Deviation from the Task-7 from_runtime(runtime: Arc<AgentRuntime>, …) signature: AgentRuntime’s inner Arcs (ext_runtime, llm, telemetry, token_meter, ledger) are pub(crate) and cannot be extracted from an Arc<AgentRuntime> outside the greentic-aw-runtime crate, so a per-visit runtime cannot be reconstructed from a shared AgentRuntime. The task explicitly allows this: “an acceptable alternative is a from_parts(...) constructor taking those Arcs directly.” The pack loader (Task 8) already holds these Arcs when it would otherwise build an AgentRuntime, so it wires them here instead.

Trait Implementations

impl GraphNodeHandler for RuntimeGraphNodeHandler

fn execute<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, tenant_id: &'life1 str, env_id: &'life2 str, graph_id: &'life3 str, session_id: &'life4 str, flow_input: &'life5 Value, ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, RuntimeGraphNodeHandler: 'async_trait,

Execute (or resume) a graph run for this session. flow_input expects {"user_text": "..."}; returns {"reply", "trail", "terminated_by"} — the same envelope as DwAgent.