Function fragment_desc_to_distribution 

fn fragment_desc_to_distribution(
    fragment_desc: FragmentDesc,
    upstreams: Vec<FragmentId>,
) -> FragmentDistribution