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