llm-toolkit 0.63.1

A low-level, unopinionated Rust toolkit for the LLM last mile problem.
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
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

//! Error types for orchestrator operations.

use crate::agent::AgentError;
use thiserror::Error;

/// Errors that can occur during orchestrator operations.
#[derive(Debug, Error)]
pub enum OrchestratorError {
    /// A signal to the top-level execution loop to restart with a new strategy.
    #[error("A redesign has been triggered. Restarting execution.")]
    RedesignAndRestart,

    /// An agent execution failed.
    #[error("Agent error: {0}")]
    AgentError(#[from] AgentError),

    /// No agent with the specified name was found in the registry.
    #[error("No agent found with name: {0}")]
    AgentNotFound(String),

    /// Strategy generation failed (e.g., LLM call error, parsing error).
    #[error("Strategy generation failed: {0}")]
    StrategyGenerationFailed(String),

    /// Intent template rendering failed.
    #[error("Template rendering error: {0}")]
    TemplateRenderError(String),

    /// Strategy execution failed.
    #[error("Execution failed: {0}")]
    ExecutionFailed(String),

    /// Redesign determination failed.
    #[error("Redesign determination failed: {0}")]
    RedesignFailed(String),

    /// JSON parsing error during strategy generation.
    #[error("JSON error: {0}")]
    JsonError(#[from] serde_json::Error),

    /// Generic error for other cases.
    #[error("Orchestrator error: {0}")]
    Other(String),

    /// Step exceeded maximum remediation attempts.
    #[error("Step {step_index} exceeded maximum remediation attempts ({max_remediations})")]
    MaxStepRemediationsExceeded {
        step_index: usize,
        max_remediations: usize,
    },

    /// Total number of redesigns exceeded the maximum limit.
    #[error("Total number of redesigns exceeded the maximum limit ({0})")]
    MaxTotalRedesignsExceeded(usize),

    /// Total number of loop iterations exceeded the maximum limit.
    #[error("Total number of loop iterations exceeded the maximum limit ({0})")]
    MaxLoopIterationsExceeded(usize),

    /// The internal agent failed to recover even after a fallback attempt.
    #[error("The internal agent failed to recover even after a fallback attempt: {0}")]
    InternalAgentUnrecoverable(String),

    /// A step execution timed out.
    #[error("Step '{step_id}' timed out after {timeout:?}")]
    StepTimeout {
        step_id: String,
        timeout: std::time::Duration,
    },

    /// A step execution was cancelled.
    #[error("Step '{step_id}' was cancelled")]
    Cancelled { step_id: String },
}

impl OrchestratorError {
    /// Creates an error indicating no strategy is available.
    pub fn no_strategy() -> Self {
        Self::Other("No strategy available".to_string())
    }

    /// Creates an error indicating the blueprint is invalid.
    pub fn invalid_blueprint(reason: impl Into<String>) -> Self {
        Self::Other(format!("Invalid blueprint: {}", reason.into()))
    }
}