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