@@ -24,7 +24,7 @@ use chrono::Utc;
2424use http:: StatusCode ;
2525use serde:: { Deserialize , Serialize } ;
2626use serde_json:: { json, Value } ;
27- use tracing:: { debug, warn} ;
27+ use tracing:: { debug, error , warn} ;
2828
2929use crate :: {
3030 handlers:: http:: {
@@ -45,6 +45,7 @@ use crate::{
4545 arrow:: record_batches_to_json,
4646 time:: { TimeParseError , TimeRange } ,
4747 } ,
48+ validator:: error:: HotTierValidationError ,
4849 LOCK_EXPECT ,
4950} ;
5051
@@ -273,10 +274,13 @@ impl PrismDatasetRequest {
273274 } = get_prism_logstream_info ( stream) . await ?;
274275
275276 let hottier = match HotTierManager :: global ( ) {
276- Some ( hot_tier_manager) => {
277- let stats = hot_tier_manager. get_hot_tier ( stream) . await ?;
278- Some ( stats)
279- }
277+ Some ( manager) => match manager. get_hot_tier ( stream) . await {
278+ Ok ( stats) => Some ( stats) ,
279+ Err ( HotTierError :: HotTierValidationError (
280+ HotTierValidationError :: NotFound ( _) ,
281+ ) ) => None ,
282+ Err ( err) => return Err ( err. into ( ) ) ,
283+ } ,
280284 _ => None ,
281285 } ;
282286 let records = CountsRequest {
0 commit comments