async fn query_existing_schema_pairs( client: &Client, schema_pairs: &BTreeSet<(String, String)>, ) -> Result<BTreeSet<(String, String)>, DatabaseValidationError>