resolve_reschedule_intent

risingwave_meta::barrier::worker

Function resolve_reschedule_intent 

Source 
fn resolve_reschedule_intent(
    env: MetaSrvEnv,
    worker_nodes: HashMap<WorkerId, WorkerNode>,
    adaptive_parallelism_strategy: AdaptiveParallelismStrategy,
    database_info: Option<&InflightDatabaseInfo>,
    new_barrier: NewBarrier,
) -> MetaResult<Option<NewBarrier>>