cancel_iceberg_task

risingwave_storage::hummock::compactor

Function cancel_iceberg_task 

Source 
fn cancel_iceberg_task(
    task_id: u64,
    task_queue: &mut IcebergTaskQueue,
    shutdown_map: &Arc<Mutex<HashMap<(u64, usize), Sender<()>>>>,
    task_trackers: &mut HashMap<u64, IcebergTaskTracker>,
)