@@ -24,7 +24,7 @@ use chrono::Utc;
24
24
use http:: StatusCode ;
25
25
use serde:: { Deserialize , Serialize } ;
26
26
use serde_json:: { json, Value } ;
27
- use tracing:: { debug, warn} ;
27
+ use tracing:: { debug, error , warn} ;
28
28
29
29
use crate :: {
30
30
handlers:: http:: {
@@ -45,6 +45,7 @@ use crate::{
45
45
arrow:: record_batches_to_json,
46
46
time:: { TimeParseError , TimeRange } ,
47
47
} ,
48
+ validator:: error:: HotTierValidationError ,
48
49
LOCK_EXPECT ,
49
50
} ;
50
51
@@ -273,10 +274,13 @@ impl PrismDatasetRequest {
273
274
} = get_prism_logstream_info ( stream) . await ?;
274
275
275
276
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
+ } ,
280
284
_ => None ,
281
285
} ;
282
286
let records = CountsRequest {
0 commit comments