klieo-flows 3.4.0

Multi-agent composition shapes (Sequential / Parallel / Loop / Graph) for the klieo agent framework.
Documentation 
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

//! Errors raised by `klieo-flows`.

use thiserror::Error;

/// Errors returned by [`crate::flow::Flow::run`] and its concrete impls.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum FlowError {
    /// An underlying [`klieo_core::Agent`] returned an error. Stringly
    /// typed because `Agent::Error` is associated and not erasable.
    #[error("agent error: {0}")]
    Agent(String),

    /// Marshalling between typed I/O and `serde_json::Value` failed.
    #[error("json marshalling: {0}")]
    Json(#[from] serde_json::Error),

    /// [`crate::loop_flow::LoopFlow`] exceeded `max_iters` or its predicate
    /// returned `LoopVerdict::Failed`.
    #[error("loop terminated: {reason} (iter {iter})")]
    Loop {
        /// Human-readable reason.
        reason: String,
        /// Iteration count at termination.
        iter: u32,
    },

    /// [`crate::graph::GraphFlow`] hit a cycle, missing node, or missing edge.
    #[error("graph error: {0}")]
    Graph(String),

    /// Underlying bus surfaced a transient failure during a flow.
    #[error("bus error: {0}")]
    Bus(#[from] klieo_core::error::BusError),

    /// A [`crate::flow::Flow`] dispatched a tool via
    /// [`klieo_core::tool::ToolInvoker`] and the invocation itself failed.
    /// Typed (rather than stringified) so callers can match
    /// [`klieo_core::error::ToolError::Cancelled`] /
    /// [`klieo_core::error::ToolError::Retryable`] and keep the source
    /// chain intact.
    #[error("tool error: {0}")]
    Tool(#[from] klieo_core::error::ToolError),

    /// The flow observed [`AgentContext::cancel`](klieo_core::agent::AgentContext)
    /// before starting an iteration / step and stopped without doing further
    /// work. Distinct from a body agent's own error so callers can tell a
    /// cooperative cancellation apart from a failure.
    #[error("flow cancelled")]
    Cancelled,
}