) -> Result<(), anyhow::Error> {
    let mut compressor = XzEncoder::new(buffer.as_slice(), 6);
    let mut data = vec![];
    compressor.read_to_end(&mut data).unwrap();
    let compressed_file_name = compressed_file_name.clone() + ".xz";
    let mut file = tokio::fs::File::create(compressed_file_name.clone()).await?;
    log::info!("process_compressed CREATE {}", compressed_file_name);

    file.write_all(data.as_slice()).await?;
    log::info!("process_compressed WRITE {}", compressed_file_name);

    tx.send(compressed_file_name).await?;

    Ok(())
}