Skip to content

Commit 0a671d0

Browse files
committed
update errors
1 parent 53a9b85 commit 0a671d0

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

server/src/handlers/http/query.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -290,6 +290,8 @@ pub enum QueryError {
290290
Execute(#[from] ExecuteError),
291291
#[error("ObjectStorage Error: {0}")]
292292
ObjectStorage(#[from] ObjectStorageError),
293+
#[error("Cache Error: {0}")]
294+
CacheError(#[from] CacheError),
293295
#[error("Evern Error: {0}")]
294296
EventError(#[from] EventError),
295297
#[error("Error: {0}")]

server/src/localcache.rs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,10 @@ use human_size::{Byte, Gigibyte, SpecificSize};
2525
use itertools::{Either, Itertools};
2626
use object_store::{local::LocalFileSystem, ObjectStore};
2727
use once_cell::sync::OnceCell;
28+
use parquet::errors::ParquetError;
2829
use tokio::{fs, sync::Mutex};
2930

30-
use crate::option::CONFIG;
31+
use crate::{metadata::error::stream_info::MetadataError, option::CONFIG};
3132

3233
pub const STREAM_CACHE_FILENAME: &str = ".cache.json";
3334
pub const CACHE_META_FILENAME: &str = ".cache_meta.json";
@@ -256,4 +257,8 @@ pub enum CacheError {
256257
MoveError(#[from] fs_extra::error::Error),
257258
#[error("{0}")]
258259
ObjectStoreError(#[from] object_store::Error),
260+
#[error("{0}")]
261+
ParquetError(#[from] ParquetError),
262+
#[error("{0}")]
263+
MetadataError(#[from] MetadataError),
259264
}

0 commit comments

Comments
 (0)