restore_progress

risingwave_meta::barrier::cdc_progress

Function restore_progress 

Source 
async fn restore_progress(
    meta_store: &SqlMetaStore,
) -> MetaResult<HashMap<JobId, (u64, bool)>>