oris-runtime 0.61.0

An agentic workflow runtime and programmable AI execution system in Rust: stateful graphs, agents, tools, and multi-step execution.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

//! AgentStepFnAdapter: wraps UnifiedAgent as a sync StepFn for the kernel.
//!
//! Runs one agent "step" via block_on. Currently one step = full invoke; a future
//! extension can map one plan + optional tool call to Next::Do(CallTool) when the
//! executor exposes single-step execution.

use std::sync::Arc;

use serde::{Deserialize, Serialize};

use crate::kernel::event::Event;
use crate::kernel::state::KernelState;
use crate::kernel::step::{Next, StepFn};
use crate::kernel::KernelError;
use crate::prompt::PromptArgs;

use super::unified_agent::{AgentInput, UnifiedAgent};
use crate::graph::RunnableConfig;

/// State for the kernel when driving an agent: prompt args (input) and optional last output.
#[derive(Clone, Debug, Default, Serialize, Deserialize)]
pub struct AgentStepState {
    /// Input for the agent (e.g. chat_history, input).
    #[serde(default)]
    pub prompt_args: PromptArgs,
    /// Last output from the agent (set by reducer on StateUpdated).
    #[serde(default)]
    pub last_output: Option<String>,
}

impl AgentStepState {
    pub fn new(prompt_args: PromptArgs) -> Self {
        Self {
            prompt_args,
            last_output: None,
        }
    }
}

impl KernelState for AgentStepState {
    fn version(&self) -> u32 {
        1
    }
}

/// Sync StepFn that runs the agent (one full invoke per step) via block_on.
pub struct AgentStepFnAdapter {
    pub agent: Arc<UnifiedAgent>,
    pub config: RunnableConfig,
}

impl AgentStepFnAdapter {
    pub fn new(agent: Arc<UnifiedAgent>, config: RunnableConfig) -> Self {
        Self { agent, config }
    }
}

impl StepFn<AgentStepState> for AgentStepFnAdapter {
    /// Requires a Tokio runtime on the current thread; use `Handle::try_current()` to check.
    /// From async, use `block_in_place` or a dedicated thread.
    fn next(&self, state: &AgentStepState) -> Result<Next, KernelError> {
        let handle = tokio::runtime::Handle::try_current().map_err(|_| {
            KernelError::Driver(
                "Tokio runtime required: call from a thread with an entered runtime (e.g. after Runtime::new() and rt.enter()), or use block_in_place from an async task. Do not call from inside an async task without block_in_place.".into(),
            )
        })?;
        let agent = Arc::clone(&self.agent);
        let config = self.config.clone();
        let prompt_args = state.prompt_args.clone();
        let result = handle.block_on(async move {
            agent
                .invoke_with_config(AgentInput::State(prompt_args), &config)
                .await
        });
        match result {
            Ok(super::AgentInvokeResult::Complete(output)) => {
                let payload = serde_json::json!({ "output": output });
                Ok(Next::Emit(vec![Event::StateUpdated {
                    step_id: Some("agent".to_string()),
                    payload,
                }]))
            }
            Ok(super::AgentInvokeResult::Interrupt { interrupt_value }) => {
                Ok(Next::Interrupt(crate::kernel::step::InterruptInfo {
                    value: interrupt_value,
                }))
            }
            Err(e) => Err(KernelError::Driver(e.to_string())),
        }
    }
}