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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
use thiserror::Error;
/// Unified error type for all Jammi DB operations.
#[derive(Debug, Error)]
pub enum JammiError {
/// Invalid or missing configuration value.
#[error("Configuration error: {0}")]
Config(String),
/// SQLite catalog read/write failure.
#[error("Catalog error: {0}")]
Catalog(String),
/// Data source operation failure, scoped to a specific source.
#[error("Source error: {source_id}: {message}")]
Source {
/// Identifier of the failing source.
source_id: String,
/// Human-readable error description.
message: String,
},
/// Model lifecycle error, scoped to a specific model.
#[error("Model error: {model_id}: {message}")]
Model {
/// Identifier of the failing model.
model_id: String,
/// Human-readable error description.
message: String,
},
/// Inference execution failure.
#[error("Inference error: {0}")]
Inference(String),
/// Fine-tuning error.
#[error("Fine-tune error: {0}")]
FineTune(String),
/// Evaluation error.
#[error("Eval error: {0}")]
Eval(String),
/// GPU scheduling or detection error.
#[error("GPU error: {0}")]
Gpu(String),
/// Remote backend error (vLLM, HTTP).
#[error("Backend error: {0}")]
Backend(String),
/// Filesystem I/O error.
#[error("IO error: {0}")]
Io(#[from] std::io::Error),
/// Catalog backend (SQLite / Postgres) error.
#[error("Backend error: {0}")]
BackendDriver(#[from] crate::catalog::backend::BackendError),
/// Invalid tenant identifier (e.g., nil UUID, malformed string).
#[error("Tenant error: {0}")]
Tenant(String),
/// TOML configuration parse error.
#[error("TOML parse error: {0}")]
Toml(#[from] toml::de::Error),
/// JSON serialization/deserialization error.
#[error("JSON error: {0}")]
Json(#[from] serde_json::Error),
/// DataFusion query-engine error.
#[error("DataFusion error: {0}")]
DataFusion(#[from] datafusion::error::DataFusionError),
/// Evidence channel validation or registration error.
#[error("Evidence channel error: {0}")]
EvidenceChannel(String),
/// Mutable companion table error.
#[error("Mutable table error: {0}")]
MutableTable(#[from] crate::store::mutable::MutableTableError),
/// Trigger-stream error (topic registration, publish, subscribe).
#[error("Trigger error: {0}")]
Trigger(#[from] crate::trigger::TriggerError),
/// Object-store / storage-layer failure (URL parse, driver init,
/// remote I/O, on-the-wire layout corruption).
#[error("Storage error: {0}")]
Storage(#[from] crate::storage::StorageError),
/// A typed read from a Parquet table found a column whose Arrow type
/// disagrees with what the caller asked for (missing column, wrong
/// `DataType`, wrong inner type on a list).
#[error("Schema error: table {table:?} column {column:?}: expected {expected}, got {actual}")]
Schema {
/// Table the read targeted (typically `ResultTableRecord::table_name`).
table: String,
/// Name of the column the read targeted.
column: String,
/// Expected Arrow shape (e.g. `"FixedSizeList<Float32>"`).
expected: String,
/// What the on-disk schema actually carried (or `"missing"` if the
/// column wasn't present at all).
actual: String,
},
/// Catch-all for errors that don't fit another variant.
#[error("{0}")]
Other(String),
}
/// Convenience alias for `std::result::Result<T, JammiError>`.
pub type Result<T> = std::result::Result<T, JammiError>;