schedule_queued_tasks

Function schedule_queued_tasks 

Source
fn schedule_queued_tasks(
    task_queue: &mut IcebergTaskQueue,
    compactor_context: &CompactorContext,
    shutdown_map: &Arc<Mutex<HashMap<(u64, usize), Sender<()>>>>,
    task_completion_tx: &UnboundedSender<(u64, usize)>,
)
Expand description

Schedule queued tasks if we have capacity