Function validate_snapshot 

pub(crate) async fn validate_snapshot(
    storage: &dyn SnapshotStorage,
    manifest: &Manifest,
    schemas: &[String],
) -> Result<()>

Matches every completed schema chunk to its source DDL before target writes.