cortex-ai 0.1.9

An asynchronous flow-based processing framework for building flexible data pipelines with conditional branching and error handling
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

use std::{error::Error, fmt};

/// Error type specific to Flow operations.
#[derive(Debug, Clone)]
pub enum FlowError {
    Source(String),
    Process(String),
    Condition(String),
    NoSource,
    Custom(String),
}

impl fmt::Display for FlowError {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        match self {
            Self::Source(msg) => write!(f, "Source error: {msg}"),
            Self::Process(msg) => write!(f, "Process error: {msg}"),
            Self::Condition(msg) => write!(f, "Condition error: {msg}"),
            Self::NoSource => write!(f, "Flow error: No source configured"),
            Self::Custom(msg) => write!(f, "Flow error: {msg}"),
        }
    }
}
impl Error for FlowError {}