Function query_sources_by_cluster 

pub(crate) async fn query_sources_by_cluster(
    client: &Client,
    cluster_names: &BTreeSet<String>,
) -> Result<BTreeMap<String, Vec<String>>, DatabaseValidationError>

Internal helper to query which sources exist on the given clusters using IN clause.