async fn validate_data_snapshot( storage: &dyn SnapshotStorage, chunks: &[ChunkMeta], schemas: &[String], ) -> Result<HashSet<String>>