collect_done_fragments

risingwave_meta::barrier::progress

Function collect_done_fragments 

Source 
pub(crate) fn collect_done_fragments(
    job_id: JobId,
    fragment_infos: &HashMap<FragmentId, InflightFragmentInfo>,
) -> Vec<FragmentBackfillProgress>