Skip to main content

resolve_reschedule_intent

risingwave_meta::barrier::worker

Function resolve_reschedule_intent 

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