delete_expired_blocks

Function delete_expired_blocks 

Source
pub fn delete_expired_blocks(
    lake: &DataLakeConnection,
    expiration: DateTime<Utc>,
) -> impl Future<Output = Result<(), Error>>
Expand description

Deletes all expired blocks from the data lake.