pub fn delete_expired_blocks( lake: &DataLakeConnection, expiration: DateTime<Utc>, ) -> impl Future<Output = Result<(), Error>>
Deletes all expired blocks from the data lake.