risingwave_storage::hummock::compactor

Function get_task_progress

source 
fn get_task_progress(
    task_progress: Arc<Mutex<RawMutex, HashMap<u64, Arc<TaskProgress>>>>,
) -> Vec<CompactTaskProgress>