pub(super) async fn try_cached_replay(
state: &AppState,
cache_key: &str,
layout: ParquetLayout,
stream_shapes: StreamShapes,
data_model_entities: DataModelEntities,
) -> Result<Option<Response>, ApiError>Expand description
Try to serve a parse_parquet_stream request from the cache. Returns
Ok(Some(response)) on a usable cache hit (the caller drops its admission
guard and returns the response as-is), Ok(None) on a miss or a
short/corrupt cached blob (the caller falls through to the live parse,
which overwrites the bad entry).