smartcrab 0.1.2

Core library for SmartCrab workflow orchestration engine
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

use std::time::Duration;

/// Top-level error type for SmartCrab.
#[derive(Debug, thiserror::Error)]
pub enum SmartCrabError {
    #[error("DAG error: {0}")]
    Dag(#[from] DagError),

    #[error("`claude` command not found. Is Claude Code CLI installed?")]
    ClaudeCodeNotFound,

    #[error("Claude Code timed out after {timeout:?}")]
    ClaudeCodeTimeout { timeout: Duration },

    #[error("Claude Code failed with exit code {exit_code}: {stderr}")]
    ClaudeCodeFailed { exit_code: i32, stderr: String },

    #[error("Failed to parse Claude Code response: {source}")]
    ResponseParseError {
        response: String,
        source: Box<dyn std::error::Error + Send + Sync>,
    },

    #[error("IO error: {0}")]
    Io(#[from] std::io::Error),

    #[error("Telemetry initialization error: {0}")]
    Telemetry(String),

    #[error("{0}")]
    Other(String),
}

/// DAG-specific errors raised during build or execution.
#[derive(Debug, thiserror::Error)]
pub enum DagError {
    #[error("Cycle detected in DAG")]
    CycleDetected,

    #[error("Duplicate node name: {name}")]
    DuplicateNodeName { name: String },

    #[error("Unreachable node: {name}")]
    UnreachableNode { name: String },

    #[error("No input node found in DAG")]
    NoInputNode,

    #[error(
        "Type mismatch on edge {from} -> {to}: output type `{output_type}` != input type `{input_type}`"
    )]
    TypeMismatch {
        from: String,
        to: String,
        output_type: String,
        input_type: String,
    },

    #[error("Missing branch target node: {target} (from condition on {from})")]
    MissingBranch { from: String, target: String },

    #[error("Layer `{name}` failed: {source}")]
    LayerFailed {
        name: String,
        source: Box<dyn std::error::Error + Send + Sync>,
    },
}

pub type Result<T> = std::result::Result<T, SmartCrabError>;