pub async fn daemon<F>(
lakehouse: Arc<LakehouseContext>,
views_to_update: Vec<Arc<dyn View>>,
shutdown: F,
grace: Duration,
) -> Result<()>Expand description
Starts the maintenance daemon, which runs various scheduled tasks.
This function initializes and spawns several CronTasks for daily, hourly, minute,
and second-based maintenance operations, such as data materialization and cleanup.
All four runner loops react to shutdown: they stop scheduling and drain in-flight
tasks. A deadline arm forces return after grace even if tasks haven’t drained.
§Arguments
lakehouse- The lakehouse context with shared metadata cache.views_to_update- A vector of views that need to be updated by the daemon.shutdown- Future that completes when the process should begin shutting down.grace- Maximum time to wait for in-flight tasks after the shutdown signal.