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, Sender<()>>>>,
    task_completion_tx: &UnboundedSender<u64>,
)
Expand description

Schedule queued tasks if we have capacity