collect_fragment_upstream_fragment_ids

risingwave_meta::barrier::checkpoint::creating_job

Function collect_fragment_upstream_fragment_ids 

Source 
fn collect_fragment_upstream_fragment_ids(
    fragment: &InflightFragmentInfo,
    upstream_fragment_ids: &mut HashSet<FragmentId>,
)