somatize-core 0.3.0

Core types and traits for the Soma computational graph runtime
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 the Soma runtime.

use thiserror::Error;

#[derive(Error, Debug)]
#[non_exhaustive]
pub enum SomaError {
    #[error("filter requires labels (y) but none were provided")]
    RequiresLabels,

    #[error("cache error: {0}")]
    Cache(String),

    #[error("compilation error: {0}")]
    Compilation(String),

    #[error("execution error at node `{node_id}`: {message}")]
    Execution { node_id: String, message: String },

    #[error("trial pruned at step {step}: {reason}")]
    Pruned { step: usize, reason: String },

    #[error("schema mismatch: expected {expected}, got {got}")]
    SchemaMismatch { expected: String, got: String },

    #[error("node `{0}` not found in graph")]
    NodeNotFound(String),

    #[error("cycle detected in graph")]
    CycleDetected,

    #[error("serialization error: {0}")]
    Serialization(String),

    #[error("data store error: {0}")]
    DataStore(String),

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

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

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

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn error_display_messages() {
        let err = SomaError::RequiresLabels;
        assert_eq!(
            err.to_string(),
            "filter requires labels (y) but none were provided"
        );

        let err = SomaError::Execution {
            node_id: "scaler_1".into(),
            message: "dimension mismatch".into(),
        };
        assert_eq!(
            err.to_string(),
            "execution error at node `scaler_1`: dimension mismatch"
        );

        let err = SomaError::Pruned {
            step: 5,
            reason: "below median".into(),
        };
        assert_eq!(err.to_string(), "trial pruned at step 5: below median");
    }

    #[test]
    fn result_type_alias_works() {
        fn ok_fn() -> Result<i32> {
            Ok(42)
        }
        fn err_fn() -> Result<i32> {
            Err(SomaError::CycleDetected)
        }
        assert_eq!(ok_fn().unwrap(), 42);
        assert!(err_fn().is_err());
    }
}