load_reschedule_context_for_ensembles

risingwave_meta::stream::scale

Function load_reschedule_context_for_ensembles 

Source 
async fn load_reschedule_context_for_ensembles(
    txn: &impl ConnectionTrait,
    ensembles: Vec<NoShuffleEnsemble>,
) -> MetaResult<RescheduleContext>